回顧
第一章講到卧斟，通過建立簡(jiǎn)單工廠翁都，來實(shí)現(xiàn)對(duì)調(diào)用層的封裝，實(shí)現(xiàn)了工廠描扯、接口盯滚、本地上傳代碼的實(shí)現(xiàn)踢械。
這一節(jié)我們將討論在java中，如果通過FTP上傳魄藕、下載資源内列。
依賴
我們通過引入commons-net依賴，使用FTPClient來進(jìn)行相應(yīng)上傳下載操作背率。
<dependency>
<groupId>commons-net</groupId>
<artifactId>commons-net</artifactId>
<version>3.6</version>
</dependency>
如何使用：
我們考慮下话瞧，要上傳一個(gè)ftp資源要進(jìn)行的主要步驟
1、建立連接
2寝姿、進(jìn)入資源目錄交排、或者創(chuàng)建
3、上傳饵筑、下載資源
4埃篓、關(guān)閉連接
建立連接
//創(chuàng)建ftp對(duì)象
FTPClient ftpClient = new FTPClient();
//構(gòu)建用戶名、密碼并連接程序
ftpClient.connect(props.getHost(), props.getPort());
ftpClient.login(props.getUsername(), props.getPassword());
log.info("連接FTP服務(wù)器返回碼{}", ftpClient.getReplyCode());
//設(shè)置buffer大小
ftpClient.setBufferSize(props.getBufferSize());
//設(shè)置傳輸為二進(jìn)制流
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
//設(shè)置為被動(dòng)模式翻翩，客戶端通知服務(wù)器打開傳輸端口都许，由客戶端連接到服務(wù)器進(jìn)行數(shù)據(jù)傳輸，
//默認(rèn)為主動(dòng)模式嫂冻，采用采用被動(dòng)模式的原因在于胶征，可能本地端口無法正常打開，導(dǎo)致程序卡死
ftpClient.enterLocalPassiveMode();
//判定是否連接成功
int reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
throw new Exception("失敗相應(yīng)狀態(tài)碼"+reply);
}
return ftpClient
以上代碼為建立連接過程桨仿，需要遠(yuǎn)程地址睛低、端口、用戶名服傍、密碼信息钱雷。
創(chuàng)建、進(jìn)入目錄
進(jìn)入核心方法：
ftpClient.changeWorkingDirectory(pathName);
創(chuàng)建目錄方法：
ftpClient.makeDirectory(pathName)
通過以上兩個(gè)核心方法實(shí)現(xiàn)目錄切換和創(chuàng)建
//通過hashmap緩存路徑吹零，減少客戶端查詢服務(wù)器的次數(shù)罩抗，目錄無刪除操作，故可采用此方法灿椅，
//如果有刪除且為分布式套蒂，考慮使用redis緩存
private static ConcurrentHashMap<String,Boolean> pathMap=new ConcurrentHashMap<>();
/**
* 判定目錄是否為空，并切換目錄
*/
private static void checkAndCreate(String pathName,FTPClient ftpClient) throws IOException {
//增加緩存機(jī)制茫蛹，無須重復(fù)上服務(wù)器檢測(cè)操刀。
if(pathMap.containsKey(pathName)) {
//切換目錄
ftpClient.changeWorkingDirectory(pathName);
return;
}
//檢出目錄是否存在，如果存在婴洼，則加入緩存
if(ftpClient.changeWorkingDirectory(pathName)){
pathMap.put(pathName,true);
}else {
//嘗試創(chuàng)建目錄骨坑，創(chuàng)建失敗，則遞歸創(chuàng)建父級(jí)目錄
if (ftpClient.makeDirectory(pathName)) {
pathMap.put(pathName, true);
} else {
//進(jìn)行上級(jí)創(chuàng)建
int splitIndex = pathName.lastIndexOf("/");
String prePath = pathName.substring(0, splitIndex);
checkAndCreate(prePath, ftpClient);
checkAndCreate(pathName, ftpClient);
}
ftpClient.changeWorkingDirectory(pathName);
}
}
上傳資源
try (OutputStream out = ftpClient.storeFileStream(encodingPath(reallyFileName))) {
out.write(file.getBytes());
return true;
}
catch (IOException ex){
log.error("IO寫入異常"+ex);
return false;
}
catch (Exception ex) {
log.error("寫入異常"+ex);
return false;
}
finally {
ftpClient.completePendingCommand();
//這里使用了數(shù)據(jù)池柬采，把對(duì)象放回池子欢唾。后續(xù)介紹
releaseFtpClient(ftpClient);
}
注意：上面方法中的使用了ftpClient.completePendingCommand();方法，具體使用時(shí)機(jī)及原因詳見：FTPClient中使用completePendingCommand方法注意事項(xiàng)
下載資源
try (InputStream in = ftpClient.retrieveFileStream(encodingPath(fileName));
OutputStream out = response.getOutputStream())
{
int size = 0;
byte[] buf = new byte[10240];
while ((size = in.read(buf)) > 0) {
out.write(buf, 0, size);
out.flush();
}
} finally {
ftpClient.completePendingCommand();
releaseFtpClient(ftpClient);
}
同理上傳相似警没，不過下載的時(shí)候我們沒有一次讀取出來匈辱，而是通過循環(huán)，邊讀取杀迹，邊寫入客戶端亡脸，這樣可以提升傳輸效率
一個(gè)復(fù)用性問題
我們知道，線程有線程池树酪，數(shù)據(jù)庫(kù)有連接池浅碾，ftp新建連接每次都重新連接，顯然效率低下续语，我們?nèi)绾魏?jiǎn)單的實(shí)現(xiàn)一個(gè)自己的ftp線程池呢垂谢？
下一章將會(huì)講到。
參考資料
Springboot項(xiàng)目搭建有ftpClientPool的Ftp工具類
【特此聲明：本文原創(chuàng)疮茄，禁止轉(zhuǎn)載滥朱！覺得有用打賞一個(gè)吧】
