快捷導(dǎo)航

解決調(diào)用ftpClient.retrieveFileStream(String?remoteFilePath)第二次讀取為空問(wèn)題

更新時(shí)間：2023年08月08日 10:41:19 作者：DaXianZ

這篇文章主要給大家介紹了關(guān)于如何解決調(diào)用ftpClient.retrieveFileStream(String?remoteFilePath)第二次讀取為空問(wèn)題的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),需要的朋友可以參考下

描述：當(dāng)讀取一個(gè)文件夾時(shí)，文件夾中又存在多個(gè)文件，循環(huán)讀取時(shí)，第一次調(diào)用

InputStream inputStream = ftpClient.retrieveFileStream(String remoteFilePath)可以讀出數(shù)據(jù)，當(dāng)再次調(diào)用時(shí)，inputStream = null;

解決方法：在執(zhí)行完inputStream.close()；方法之后，執(zhí)行ftpClient.completePendingCommand();

代碼：

public ResultData getFromFtpDataToDatabase(HttpServletRequest request){
        ResultData resultData = new ResultData(Result_Code.SUCCESS);
        String IP = Tools.processNull("***.***.***.***");
        //ftp端口是21 使用WinSCP 采用的是SSH連接端口號(hào)是22
        String PORT = Tools.processNull("21");
        String userName= Tools.processNull("userName");
        String passWord = Tools.processNull("passWord");
        String directory = Tools.processNull("");
        String upload = Tools.processNull("/upload/");
        String history = Tools.processNull("/history/");
        String filepath = "/test/";
        String paths = null;
        try {
            paths = new String(filepath.getBytes(),"UTF-8");
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        //創(chuàng)建FTPClient對(duì)象
        FTPClient ftpClient = new FTPClient();
        try{
            //解決文件夾有中文是讀不出文件問(wèn)題
            ftpClient.setAutodetectUTF8(true);
            ftpClient.connect(IP, Integer.parseInt(PORT));
            ftpClient.enterLocalPassiveMode();
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            ftpClient.setFileTransferMode(FTP.BLOCK_TRANSFER_MODE);
            ftpClient.login(userName, passWord);
            //讀取文件夾下文件
            FTPFile[] files = ftpClient.listFiles(paths);
            //獲取文件名稱
            String saveAsFileName = null;
            for (int i = 0; i < files.length; i++) {
                saveAsFileName=files[i].getName();
                //文件路徑
                String remoteFile = filepath+saveAsFileName;
                // get output stream of the response
                InputStream inputStream = ftpClient.retrieveFileStream(remoteFile);
                int available = inputStream.available();
                //將文件值轉(zhuǎn)為二進(jìn)制數(shù)據(jù)
                byte[] bytesArray = new byte[available];
                inputStream.read(bytesArray);
                //插入到數(shù)據(jù)庫(kù)中,代碼未體現(xiàn)
                inputStream.close();
                //ftpClient.getReply();
                //調(diào)用ftpClient.completePendingCommand()解決第二次讀取為空情況
                ftpClient.completePendingCommand();

}
        }catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            try {
                // 注銷(xiāo)FTP客戶端
                if(ftpClient!=null){
                    ftpClient.logout();
                }
            } catch (Exception e) {
                // 如果FTP注銷(xiāo)失敗什么也不做，忽略掉異常。
            }
            if (ftpClient.isConnected()) {
                try {
                    ftpClient.disconnect();
                } catch (IOException ex2) {
                    ex2.printStackTrace();
                }
            }
        }
        resultData.put("msg","操作成功");
        return resultData;
    }

解決方案：

調(diào)用ftpClient.completePendingCommand();
<strong>注意：</strong>FTP Server只有在接受到InputStream?執(zhí)行close方法時(shí)，才會(huì)返回。所以一定先要執(zhí)行close方法。不然在第一次下載一個(gè)文件成功之后，之后再次獲取inputStream 就會(huì)返回null

存在問(wèn)題：使用inputStream.available();進(jìn)行讀取數(shù)據(jù)時(shí)，由于時(shí)網(wǎng)絡(luò)傳輸，可能會(huì)導(dǎo)致數(shù)據(jù)的丟失，讀取的數(shù)據(jù)長(zhǎng)度也會(huì)有限制，后續(xù)做改正.........

到此這篇關(guān)于解決調(diào)用ftpClient.retrieveFileStream(String remoteFilePath)第二次讀取為空問(wèn)題的文章就介紹到這了,更多相關(guān)ftpClient.retrieveFileStream(String remoteFilePath)讀取為空內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！