..

Aria/src/main/java/com/arialyy/aria/core/download/downloader/FtpThreadTask.java

@@ -15,6 +15,8 @@
  */
 package com.arialyy.aria.core.download.downloader;
 
+import android.os.Handler;
+import android.os.Message;
 import android.text.TextUtils;
 import android.util.Log;
 import com.arialyy.aria.util.BufferedRandomAccessFile;
@@ -100,7 +102,7 @@ class FtpThreadTask extends AbsThreadTask {
         }
       }
       if (STATE.isCancel || STATE.isStop) return;
-      if (client.completePendingCommand()) {
+      //if (client.completePendingCommand()) {
       Log.i(TAG, "任务【" + mConfig.TEMP_FILE.getName() + "】线程__" + mConfig.THREAD_ID + "__下载完毕");
       writeConfig(true, 1);
       STATE.COMPLETE_THREAD_NUM++;
@@ -112,16 +114,18 @@ class FtpThreadTask extends AbsThreadTask {
         STATE.isDownloading = false;
         mListener.onComplete();
       }
-        file.close();
-        is.close();
-        Log.d(TAG, "SUCCESS");
-      }
     } catch (IOException e) {
       failDownload(mChildCurrentLocation, "下载失败【" + mConfig.DOWNLOAD_URL + "】", e);
     } catch (Exception e) {
       failDownload(mChildCurrentLocation, "获取流失败", e);
     } finally {
       try {
+        if (file != null){
+          file.close();
+        }
+        if (is != null){
+          is.close();
+        }
         if (client != null && client.isConnected()) {
           //client.logout();
           client.disconnect();

app/src/main/java/com/arialyy/simple/download/FtpDownloadActivity.java

@@ -45,7 +45,9 @@ public class FtpDownloadActivity extends BaseActivity<ActivityFtpDownloadBinding
       case R.id.start:
         Aria.download(this)
             //.load("172.18.104.129", "21", "cd.mp3")
-            .load("172.18.104.129", "21", "gg.png")
+            //.load("192.168.1.8", "21", "gg.png")
+            .load("192.168.1.8", "21", "23.pdf")
+            //.load("192.168.1.8", "21", "heh.txt")
             .login("lao", "123456")
             .setDownloadPath("/mnt/sdcard/tt.png")
             .charSet("gbk")