Android FTP 多線程斷點(diǎn)續(xù)傳下載/上傳的實(shí)例

2019-10-22 18:30:56

字體：大中小

供稿：網(wǎng)友

?最近在給我的開源下載框架Aria增加FTP斷點(diǎn)續(xù)傳下載和上傳功能，在此過程中，爬了FTP的不少坑，終于將功能實(shí)現(xiàn)了，在此把一些核心功能點(diǎn)記錄下載。

FTP下載原理

FTP單線程斷點(diǎn)續(xù)傳

FTP和傳統(tǒng)的HTTP協(xié)議有所不同，由于FTP沒有所謂的頭文件，因此我們不能像HTTP那樣通過設(shè)置header向服務(wù)器指定下載區(qū)間。

但是FTP協(xié)議提供了一個更好用的命令REST用于從指定位置恢復(fù)任務(wù)，同時FTP協(xié)議也提供了一個命令SIZE用于獲取下載的文件大小，有了這兩個命令，F(xiàn)TP斷點(diǎn)續(xù)傳也就沒有什么問題。

FTP斷點(diǎn)續(xù)傳的原理和HTTP的斷點(diǎn)續(xù)傳原理差不多，在暫停時記錄文件的停止位置，再次下載時，先讀取記錄的位置，如果位置存在，則通過REST命令告訴服務(wù)器從指定區(qū)間進(jìn)行下載。

FTP多線程斷點(diǎn)續(xù)傳

多線程下載的原理和HTTP多線程下載的原理差不多。先獲取文件大小，然后根據(jù)線程數(shù)，對整個文件進(jìn)行分段下載，在任務(wù)停止時，記錄每一條線程的暫停位置，重新開始下載，每一條線程讀取對應(yīng)的下載記錄，然后每一線程從指定位置開始下載。

Android,多線程斷點(diǎn)續(xù)傳下載,多線程斷點(diǎn)續(xù)傳上傳

分段下載

和HTTP所不同的是，F(xiàn)TP并沒有提供文件區(qū)間的API，因此，F(xiàn)TP在分段下載中，只有起始位置而沒有結(jié)束位置。
因此，你需要在指定位置手動停止線程。

功能實(shí)現(xiàn)

本文使用將采用apache commons-net實(shí)現(xiàn)FTP斷點(diǎn)續(xù)傳下載/上傳功能。<br>

通過下文的幾步操作，你就能很簡單的實(shí)現(xiàn)FTP斷點(diǎn)續(xù)傳。

登錄

FTP協(xié)議和HTTP協(xié)議有所不同，使用FTP進(jìn)行下載時，你需要進(jìn)行登錄操作。

當(dāng)然，如果你服務(wù)器沒有登錄功能，你可以忽略登錄操作。

FTPClient client = new FTPClient();client.connect(serverIp, port); //連接到FTP服務(wù)器client.login(userName, passsword);

通過上面三行代碼，就可以很簡單的登錄到FTP服務(wù)器上。

在進(jìn)行登錄后，還需要驗(yàn)證是否登錄成功

int reply = client.getReplyCode();if (!FTPReply.isPositiveCompletion(reply)) {  client.disconnect();  Log.d(TAG, "無法連接到ftp服務(wù)器，錯誤碼為：" + reply);  return; }

由于FTP協(xié)議中，連接成功的狀態(tài)有多個，因此需要通過FTPReply.isPositiveCompletion(reply)用于驗(yàn)證是否成功連接到FTP服務(wù)器。

文件信息獲取

在連接到FTP服務(wù)器后，就需要開始獲取下載最重要的幾個參數(shù)（文件長度、文件名）。

客戶端可以通過client.listFiles(remotePath)獲取FTP服務(wù)器上該路徑的文件列表。

如果路徑是文件，只會返回一個長度為1的數(shù)組。
如果該路徑為文件夾，則會返回該文件夾下對應(yīng)的所有文件。

String remotePath = "/upload/qjnn.apk"; //FTP服務(wù)器上文件路徑FTPFile[] files = client.listFiles(remotePath);FTPFile file = files[0]; //文件信息long size = file.getSize();String fileaName = file.getName();

如果你的文件為英文名，并且路徑中沒有中文，那么通過上述代碼，便可以獲取到正確的文件信息。

但如果FTP上的服務(wù)器上的文件名有中文或路徑有中文，那么上述代碼，你將獲取不到正確的文件信息。

正確的寫法

由于FTP服務(wù)器默認(rèn)的編碼是ISO-8859-1，因此，客戶端在獲取文件信息時

需要請求服務(wù)器使用UTF-8編碼（如果服務(wù)器支持的話），如果服務(wù)器不支持開啟UTF-8編碼，那么客戶端需要指定字符串編碼格式
客戶端在請求remotePath路徑、獲取文件名時，都需要對路徑進(jìn)行編碼轉(zhuǎn)換處理。

String remotePath = "/upload/qjnn.apk"; //FTP服務(wù)器上文件路徑String charSet = "UTF-8";if (!FTPReply.isPositiveCompletion(client.sendCommand("OPTS UTF8", "ON"))) {  //向服務(wù)器請求使用"UTF-8"編碼  charSet = "GBK";}FTPFile[] files = client.listFiles(new String(remotePath.getBytes(charSet), "ISO-8859-1")); //對remotePath進(jìn)行編碼轉(zhuǎn)換FTPFile file = files[0]; //文件信息long size = file.getSize();String fileaName = new String(fileName.getBytes(), Charset.forName(charSet));

通過以上代碼，便可以獲取到正確的文件信息。

文件下載

配置每條線程的下載區(qū)間

long fileLength = mEntity.getFileSize();Properties pro = CommonUtil.loadConfig(mConfigFile);int blockSize = (int) (fileLength / mThreadNum);int[] recordL = new int[mThreadNum];for (int i = 0; i < mThreadNum; i++) { recordL[i] = -1;}int rl = 0;for (int i = 0; i < mThreadNum; i++) { long startL = i * blockSize, endL = (i + 1) * blockSize; Object state = pro.getProperty(mTempFile.getName() + "_state_" + i); if (state != null && Integer.parseInt(state + "") == 1) { //該線程已經(jīng)完成  if (resumeRecordLocation(i, startL, endL)) return;  continue; } //分配下載位置 Object record = pro.getProperty(fileName + "_record_" + i); //如果有記錄，則恢復(fù)下載 if (record != null && Long.parseLong(record + "") >= 0) {  Long r = Long.parseLong(record + "");  mConstance.CURRENT_LOCATION += r - startL;  Log.d(TAG, "任務(wù)【" + mEntity.getFileName() + "】線程__" + i + "__恢復(fù)下載");  startL = r;  recordL[rl] = i;  rl++; } else {  recordL[rl] = i;  rl++; } //最后一個線程的結(jié)束位置即為文件的總長度 if (i == (mThreadNum - 1)) endL = fileLength; //創(chuàng)建分段線程 AbsThreadTask task = createSingThreadTask(i, startL, endL, fileLength); if (task == null) return; mTask.put(i, task);}startSingleTask(recordL);

在上面的代碼中，主要做了兩步操作：

在文件下載前，先從本地文件中讀取當(dāng)前下載的每一條線程的下載情況
如果下載記錄存在，從記錄位置開始下載，如果記錄不存在，則重新開始下載

FTP 分段線程區(qū)間自動停止

由于FTP協(xié)議沒有區(qū)間下載的原因，為了讓線程只下載特定區(qū)間的內(nèi)容，需要客戶端在單條線程累計(jì)讀的數(shù)據(jù)長度已經(jīng)超過了所分配的區(qū)間長度的時候，停止該條線程。

 client.enterLocalPassiveMode();  //設(shè)置被動模式 client.setFileType(FTP.BINARY_FILE_TYPE); //設(shè)置文件傳輸模式 client.setRestartOffset(mConfig.START_LOCATION);  //設(shè)置恢復(fù)下載的位置 client.allocate(mBufSize); is = client.retrieveFileStream(new String(remotePath.getBytes(charSet), SERVER_CHARSET)); //發(fā)送第二次指令時，還需要再做一次判斷 reply = client.getReplyCode(); if (!FTPReply.isPositivePreliminary(reply)) {  client.disconnect();  fail(mChildCurrentLocation, "獲取文件信息錯誤，錯誤碼為：" + reply, null);  return; } file = new BufferedRandomAccessFile(mConfig.TEMP_FILE, "rwd", mBufSize); file.seek(mConfig.START_LOCATION); byte[] buffer = new byte[mBufSize]; int len; while ((len = is.read(buffer)) != -1) {   //如果該條線程讀取的數(shù)據(jù)長度大于所分配的區(qū)間長度，則只能讀到區(qū)間的最大長度  if (mChildCurrentLocation + len >= mConfig.END_LOCATION) {    len = (int) (mConfig.END_LOCATION - mChildCurrentLocation);    file.write(buffer, 0, len);    progress(len);    break;  } else {    file.write(buffer, 0, len);    progress(len);  } }

這里還有幾個坑需要處理一下：