From 7830527e6293bad453657de64ed79bc058f3fc27 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=99=BD=E6=9D=89?= <ly228832@alibaba-inc.com>
Date: Tue, 19 Dec 2023 12:38:16 +0800
Subject: [PATCH] feat:add download api

---
 app/build.gradle                              |   4 +-
 .../com/alicloud/databox/demo/AliyunpanApp.kt |   8 +
 .../com/alicloud/databox/demo/MainActivity.kt |  62 ++-
 app/src/main/AndroidManifest.xml              |   2 +
 app/src/main/res/layout/activity_main.xml     |   6 +
 opensdk/build.gradle                          |   3 +-
 .../databox/opensdk/AliyunpanClient.kt        |  51 +-
 .../databox/opensdk/AliyunpanClientConfig.kt  |  25 +-
 .../databox/opensdk/AliyunpanException.kt     |   2 +
 .../databox/opensdk/http/OKHttpHelper.kt      |  70 ++-
 .../databox/opensdk/io/AliyunpanDownloader.kt | 481 ++++++++++++++++++
 .../alicloud/databox/opensdk/io/BaseTask.kt   |  73 +++
 .../opensdk/io/BufferRandomAccessFile.kt      |  54 ++
 .../opensdk/io/AliyunpanDownloaderTest.kt     |  29 ++
 14 files changed, 857 insertions(+), 13 deletions(-)
 create mode 100644 opensdk/src/main/java/com/alicloud/databox/opensdk/io/AliyunpanDownloader.kt
 create mode 100644 opensdk/src/main/java/com/alicloud/databox/opensdk/io/BaseTask.kt
 create mode 100644 opensdk/src/main/java/com/alicloud/databox/opensdk/io/BufferRandomAccessFile.kt
 create mode 100644 opensdk/src/test/java/com/alicloud/databox/opensdk/io/AliyunpanDownloaderTest.kt

diff --git a/app/build.gradle b/app/build.gradle
index aba6cd3..fd7ae15 100644
--- a/app/build.gradle
+++ b/app/build.gradle
@@ -64,9 +64,9 @@ android {
 }
 
 dependencies {
-//    implementation project(":opensdk")
+    implementation project(":opensdk")
+//    implementation 'com.github.alibaba:aliyunpan-android-sdk:v0.1.4'
     implementation "com.squareup.okhttp3:okhttp:4.11.0"
-    implementation 'com.github.alibaba:aliyunpan-android-sdk:v0.1.4'
 
     implementation 'androidx.core:core-ktx:1.7.0'
     implementation 'androidx.appcompat:appcompat:1.6.1'
diff --git a/app/src/callback/java/com/alicloud/databox/demo/AliyunpanApp.kt b/app/src/callback/java/com/alicloud/databox/demo/AliyunpanApp.kt
index 8b7c965..42e79bc 100644
--- a/app/src/callback/java/com/alicloud/databox/demo/AliyunpanApp.kt
+++ b/app/src/callback/java/com/alicloud/databox/demo/AliyunpanApp.kt
@@ -1,8 +1,10 @@
 package com.alicloud.databox.demo
 
 import android.content.Context
+import android.os.Environment
 import com.alicloud.databox.opensdk.AliyunpanClient
 import com.alicloud.databox.opensdk.AliyunpanClientConfig
+import java.io.File
 
 object AliyunpanApp {
 
@@ -11,6 +13,12 @@ object AliyunpanApp {
     fun initApp(context: Context) {
         // 配置
         val config = AliyunpanClientConfig.Builder(context, BuildConfig.APP_KEY)
+            .downFolder(
+                File(
+                    Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS),
+                    "Aliyunpan-Sdk"
+                )
+            )
             .build()
         // 初始化client
         aliyunpanClient = AliyunpanClient.init(config)
diff --git a/app/src/callback/java/com/alicloud/databox/demo/MainActivity.kt b/app/src/callback/java/com/alicloud/databox/demo/MainActivity.kt
index 628366c..505e3c6 100644
--- a/app/src/callback/java/com/alicloud/databox/demo/MainActivity.kt
+++ b/app/src/callback/java/com/alicloud/databox/demo/MainActivity.kt
@@ -5,12 +5,14 @@ import android.view.View
 import android.widget.TextView
 import androidx.appcompat.app.AppCompatActivity
 import com.alicloud.databox.demo.ViewHelper.appendWithTime
+import com.alicloud.databox.opensdk.io.BaseTask
 import com.alicloud.databox.opensdk.scope.AliyunpanFileScope
 import com.alicloud.databox.opensdk.scope.AliyunpanUserScope
 
 class MainActivity : AppCompatActivity() {
 
     private var defaultDriveId: String? = null
+    private var fileId: String? = null
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
@@ -33,6 +35,10 @@ class MainActivity : AppCompatActivity() {
         findViewById<View>(R.id.btnFileListInfo).setOnClickListener {
             getFileList(defaultDriveId, tvResult)
         }
+
+        findViewById<View>(R.id.btnFileDownload).setOnClickListener {
+            startDownloadFile(defaultDriveId, fileId, tvResult)
+        }
     }
 
     private fun startOAuth(tvResult: TextView) {
@@ -66,10 +72,56 @@ class MainActivity : AppCompatActivity() {
             return
         }
         AliyunpanApp.aliyunpanClient
-            ?.send(AliyunpanFileScope.GetFileList(driveId, parentFileId = "root", fields = "*", limit = 2), {
-                tvResult.appendWithTime("GetFileList success: $it")
-            }, {
-                tvResult.appendWithTime("GetFileList failed: $it")
-            })
+            ?.send(
+                AliyunpanFileScope.GetFileList(
+                    driveId,
+                    parentFileId = "root",
+                    fields = "*",
+                    limit = 2,
+                    type = "file",
+                    orderBy = "size",
+                    orderDirection = "ASC"
+                ), {
+                    tvResult.appendWithTime("GetFileList success: $it")
+
+                    val items = it.data.asJSONObject().optJSONArray("items")
+                    fileId = items.getJSONObject(0).optString("file_id")
+
+                }, {
+                    tvResult.appendWithTime("GetFileList failed: $it")
+                })
+    }
+
+    private fun startDownloadFile(defaultDriveId: String?, fileId: String?, tvResult: TextView) {
+        AliyunpanApp.aliyunpanClient?.buildDownload(defaultDriveId ?: "", fileId ?: "", { task ->
+            tvResult.appendWithTime("buildDownload success $task")
+            task.addStateChange { taskState ->
+                when (taskState) {
+                    BaseTask.TaskState.Abort -> {
+                        tvResult.appendWithTime("taskState Abort ")
+                    }
+
+                    is BaseTask.TaskState.Completed -> {
+                        tvResult.appendWithTime("taskState Completed ${taskState.filePath}")
+                    }
+
+                    is BaseTask.TaskState.Failed -> {
+                        tvResult.appendWithTime("taskState Failed ${taskState.exception}")
+                    }
+
+                    is BaseTask.TaskState.Running -> {
+                        tvResult.appendWithTime("taskState Running ${taskState.completedChunkSize}/${taskState.totalChunkSize} Progress=${taskState.getProgress()}")
+                    }
+
+                    BaseTask.TaskState.Waiting -> {
+                        tvResult.appendWithTime("taskState Waiting")
+                    }
+                }
+            }
+            val startResult = task.start()
+            tvResult.appendWithTime("start task = $task startResult = $startResult")
+        }, {
+            tvResult.appendWithTime("buildDownload failed $it")
+        })
     }
 }
\ No newline at end of file
diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
index 7f77ef3..07e770a 100644
--- a/app/src/main/AndroidManifest.xml
+++ b/app/src/main/AndroidManifest.xml
@@ -2,6 +2,8 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
     xmlns:tools="http://schemas.android.com/tools">
 
+<!--    <uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE"/>-->
+<!--    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>-->
 
     <application
         android:name=".MainApp"
diff --git a/app/src/main/res/layout/activity_main.xml b/app/src/main/res/layout/activity_main.xml
index 3842f73..ac670fb 100644
--- a/app/src/main/res/layout/activity_main.xml
+++ b/app/src/main/res/layout/activity_main.xml
@@ -37,6 +37,12 @@
         android:layout_height="wrap_content"
         android:text="获取文件列表" />
 
+    <Button
+        android:id="@+id/btnFileDownload"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:text="下载文件" />
+
     <androidx.core.widget.NestedScrollView
         android:layout_width="match_parent"
         android:layout_height="wrap_content">
diff --git a/opensdk/build.gradle b/opensdk/build.gradle
index d09fdaa..47ea370 100644
--- a/opensdk/build.gradle
+++ b/opensdk/build.gradle
@@ -13,7 +13,7 @@ android {
 
         consumerProguardFiles "consumer-rules.pro"
 
-        buildConfigField 'String', 'VERSION', '"' + String.valueOf("0.0.1") + '"'
+        buildConfigField 'String', 'VERSION', '"' + String.valueOf("0.1.5") + '"'
     }
 
     buildFeatures {
@@ -44,6 +44,7 @@ dependencies {
     implementation 'androidx.appcompat:appcompat:1.6.1'
     implementation 'androidx.localbroadcastmanager:localbroadcastmanager:1.0.0'
 
+    testImplementation 'junit:junit:4.13.2'
 }
 
 afterEvaluate {
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClient.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClient.kt
index 3dbf166..9467935 100644
--- a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClient.kt
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClient.kt
@@ -8,19 +8,25 @@ import android.net.Uri
 import android.os.Handler
 import android.os.Looper
 import com.alicloud.databox.opensdk.AliyunpanException.Companion.buildError
+import com.alicloud.databox.opensdk.io.AliyunpanDownloader
 import com.alicloud.databox.opensdk.http.OKHttpHelper
 import com.alicloud.databox.opensdk.http.OKHttpHelper.enqueue
+import com.alicloud.databox.opensdk.http.OKHttpHelper.execute
 import com.alicloud.databox.opensdk.http.TokenAuthenticator
+import com.alicloud.databox.opensdk.io.BaseTask
 import okhttp3.HttpUrl
 import okhttp3.MediaType.Companion.toMediaType
 import okhttp3.Request
 import okhttp3.RequestBody.Companion.toRequestBody
 import org.json.JSONObject
+import kotlin.jvm.Throws
 
 class AliyunpanClient private constructor(private val config: AliyunpanClientConfig) : AliyunpanBaseClient,
     TokenAuthenticator.TokenAuthenticatorConfig {
 
-    private val handler = Handler(Looper.myLooper()!!)
+    internal val handler = Handler(Looper.myLooper()!!)
+
+    private val downloader: AliyunpanDownloader by lazy { AliyunpanDownloader(this, config.downloadFolderPath) }
 
     private val okHttpInstance = OKHttpHelper.buildOKHttpClient(this, config)
 
@@ -203,6 +209,17 @@ class AliyunpanClient private constructor(private val config: AliyunpanClientCon
         send(request, onSuccess, onFailure)
     }
 
+    @Throws(Exception::class)
+    internal fun sendSync(scope: AliyunpanScope): ResultResponse {
+        val request = buildRequest(scope)
+        if (request == null) {
+            val exception = AliyunpanException.CODE_REQUEST_INVALID.buildError("build request failed")
+            LLogger.log(TAG, "sendSync failed", exception)
+            throw exception
+        }
+        return okHttpInstance.execute(request)
+    }
+
     /**
      * Send 发送请求
      *
@@ -214,6 +231,38 @@ class AliyunpanClient private constructor(private val config: AliyunpanClientCon
         okHttpInstance.enqueue(request, handler, onSuccess, onFailure)
     }
 
+    fun buildDownload(
+        driveId: String,
+        fileId: String,
+        onSuccess: Consumer<BaseTask>,
+        onFailure: Consumer<Exception>
+    ) {
+        this.buildDownload(driveId, fileId, null, onSuccess, onFailure)
+    }
+
+    /**
+     * Build download
+     *
+     * @param driveId
+     * @param fileId
+     * @param expireSec 下载地址过期时间 单位秒 默认900秒
+     * @param onSuccess
+     * @param onFailure
+     */
+    fun buildDownload(
+        driveId: String,
+        fileId: String,
+        expireSec: Int? = null,
+        onSuccess: Consumer<BaseTask>,
+        onFailure: Consumer<Exception>
+    ) {
+        if (expireSec != null && expireSec <= 0) {
+            onFailure.accept(AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("expireSec must be more than 0"))
+            return
+        }
+        downloader.buildDownload(driveId, fileId, expireSec, onSuccess, onFailure)
+    }
+
     private fun buildRequest(scope: AliyunpanScope): Request? {
         val baseHttpUrl = HttpUrl.Builder()
             .scheme("https")
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClientConfig.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClientConfig.kt
index bbcc685..b787fea 100644
--- a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClientConfig.kt
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanClientConfig.kt
@@ -5,12 +5,14 @@ import android.os.Build
 import com.alicloud.databox.opensdk.auth.AliyunpanPKCECredentials
 import com.alicloud.databox.opensdk.auth.AliyunpanServerCredentials
 import com.alicloud.databox.opensdk.http.HttpHeaderInterceptor
+import java.io.File
 
 class AliyunpanClientConfig private constructor(
     internal val context: Context,
     internal val scope: String,
     internal val baseApi: String,
-    internal val credentials: AliyunpanCredentials
+    internal val credentials: AliyunpanCredentials,
+    internal val downloadFolderPath: String
 ) : HttpHeaderInterceptor.HttpHeaderConfig {
 
     private val userAgent: String by lazy {
@@ -41,7 +43,7 @@ class AliyunpanClientConfig private constructor(
 
     companion object {
 
-        private const val USER_AGENT_FORMAT = "%s/%s (%s; build:{%s}; Android %s) AliyunpanSDK/%s"
+        private const val USER_AGENT_FORMAT = "%s/%s (%s; build:%s; Android %s) AliyunpanSDK/%s"
     }
 
     class Builder {
@@ -66,6 +68,8 @@ class AliyunpanClientConfig private constructor(
 
         private var tokenServer: AliyunpanTokenServer? = null
 
+        private var downloadFolderPath: String = ""
+
         constructor(context: Context, appId: String) {
             this.context = context.applicationContext
             this.appId = appId
@@ -77,6 +81,20 @@ class AliyunpanClientConfig private constructor(
 
         fun tokenServer(tokenServer: AliyunpanTokenServer) = apply { this.tokenServer = tokenServer }
 
+        /**
+         * Down folder
+         * 配置文件下载文件夹路径，下载时注意文件读写权限授予
+         * @param downloadFolderPath 下载文件夹路径
+         */
+        fun downFolder(downloadFolderPath: String) = apply { this.downloadFolderPath = downloadFolderPath }
+
+        /**
+         * Down folder
+         * 配置文件下载文件夹，下载时注意文件读写权限授予
+         * @param downloadFolder 下载文件夹
+         */
+        fun downFolder(downloadFolder: File) = apply { this.downloadFolderPath = downloadFolder.absolutePath }
+
         fun build(): AliyunpanClientConfig {
             val aliyunpanTokenServer = tokenServer
             val credentials = if (aliyunpanTokenServer == null) {
@@ -89,7 +107,8 @@ class AliyunpanClientConfig private constructor(
                 context,
                 scope,
                 baseApi,
-                credentials
+                credentials,
+                downloadFolderPath
             )
         }
     }
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanException.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanException.kt
index d8f3c2c..2de45d9 100644
--- a/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanException.kt
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/AliyunpanException.kt
@@ -13,6 +13,8 @@ open class AliyunpanException(open val code: String, override val message: Strin
 
         const val CODE_REQUEST_INVALID = "RequestInvalid"
 
+        const val CODE_DOWNLOAD_ERROR = "DownloadError"
+
         inline fun String.buildError(message: String) = AliyunpanException(this, message)
     }
 }
\ No newline at end of file
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/http/OKHttpHelper.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/http/OKHttpHelper.kt
index 3701e60..c78d150 100644
--- a/opensdk/src/main/java/com/alicloud/databox/opensdk/http/OKHttpHelper.kt
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/http/OKHttpHelper.kt
@@ -1,10 +1,12 @@
 package com.alicloud.databox.opensdk.http
 
 import android.os.Handler
-import android.os.Looper
+import com.alicloud.databox.opensdk.AliyunpanException
+import com.alicloud.databox.opensdk.AliyunpanException.Companion.buildError
 import com.alicloud.databox.opensdk.BuildConfig
 import com.alicloud.databox.opensdk.Consumer
 import com.alicloud.databox.opensdk.ResultResponse
+import com.alicloud.databox.opensdk.io.BufferRandomAccessFile
 import okhttp3.Call
 import okhttp3.Callback
 import okhttp3.OkHttpClient
@@ -12,9 +14,13 @@ import okhttp3.Request
 import okhttp3.Response
 import okhttp3.logging.HttpLoggingInterceptor
 import org.json.JSONObject
+import java.io.File
 import java.io.IOException
+import java.io.InputStream
 
 internal object OKHttpHelper {
+
+    private const val NOTIFY_SIZE_THRESHOLD: Long = 512
     fun buildOKHttpClient(
         authenticatorConfig: TokenAuthenticator.TokenAuthenticatorConfig,
         httpHeaderConfig: HttpHeaderInterceptor.HttpHeaderConfig
@@ -28,6 +34,12 @@ internal object OKHttpHelper {
         }
         .build()
 
+    @Throws(Exception::class)
+    fun OkHttpClient.execute(request: Request): ResultResponse {
+        val response = this.newCall(request).execute()
+        return buildResultResponse(response)
+    }
+
     fun OkHttpClient.enqueue(
         request: Request,
         handler: Handler,
@@ -69,4 +81,60 @@ internal object OKHttpHelper {
         }
         throw buildAHttpException(response)
     }
+
+    @Throws(AliyunpanException::class)
+    fun OkHttpClient.download(url: String, start: Long, end: Long, downloadTempFile: File, listener: Consumer<Long>?) {
+        val rangeHeader = "bytes=" + start + "-" + if (end < 0) "" else end
+        val request: Request = Request.Builder()
+            .addHeader("Range", rangeHeader)
+            .url(url)
+            .build()
+
+        var response: Response? = null
+        var inputStream: InputStream? = null
+        var randomAccessFile: BufferRandomAccessFile? = null
+
+        try {
+            response = this.newCall(request).execute()
+            if (!response.isSuccessful) {
+                throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("download not success")
+            }
+
+            val body = response.body
+            if (body == null) {
+                throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("download body is null")
+            }
+
+            inputStream = body.byteStream()
+            randomAccessFile = BufferRandomAccessFile(downloadTempFile)
+
+            var size: Int
+            var notifySize: Long = 0
+            var addUpNotifySize = 0
+            val buff = ByteArray(1024)
+            randomAccessFile?.seek(start)
+
+            while (inputStream.read(buff).also { size = it } != -1) {
+                randomAccessFile.write(buff, 0, size)
+                notifySize += size
+                if (notifySize >= NOTIFY_SIZE_THRESHOLD) {
+                    listener?.accept(notifySize)
+                    notifySize = 0
+                }
+                addUpNotifySize += size
+
+                randomAccessFile.flushAndSync()
+            }
+            if (notifySize > 0) {
+                listener?.accept(notifySize)
+            }
+            randomAccessFile?.flushAndSync()
+        } catch (e: IOException) {
+            throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError(e.message ?: "download error")
+        } finally {
+            response?.close()
+            inputStream?.close()
+            randomAccessFile?.close()
+        }
+    }
 }
\ No newline at end of file
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/io/AliyunpanDownloader.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/AliyunpanDownloader.kt
new file mode 100644
index 0000000..06fc2c5
--- /dev/null
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/AliyunpanDownloader.kt
@@ -0,0 +1,481 @@
+package com.alicloud.databox.opensdk.io
+
+import com.alicloud.databox.opensdk.AliyunpanClient
+import com.alicloud.databox.opensdk.AliyunpanException
+import com.alicloud.databox.opensdk.AliyunpanException.Companion.buildError
+import com.alicloud.databox.opensdk.Consumer
+import com.alicloud.databox.opensdk.LLogger
+import com.alicloud.databox.opensdk.http.OKHttpHelper.download
+import com.alicloud.databox.opensdk.scope.AliyunpanFileScope
+import java.io.File
+import java.util.concurrent.Callable
+import java.util.concurrent.ConcurrentHashMap
+import java.util.concurrent.CopyOnWriteArrayList
+import java.util.concurrent.ExecutionException
+import java.util.concurrent.Executors
+import java.util.concurrent.ForkJoinPool
+import java.util.concurrent.Future
+import java.util.concurrent.atomic.AtomicBoolean
+import kotlin.math.ceil
+
+/**
+ * Aliyunpan downloader
+ * 下载器
+ * 支持分片下载，并通知任务状态和下载分片进度
+ * // TODO 支持断点续传 2023/12/19
+ * @property client
+ * @property downloadFolderPath
+ * @constructor Create empty Aliyunpan downloader
+ */
+internal class AliyunpanDownloader(private val client: AliyunpanClient, private val downloadFolderPath: String) {
+
+    private val handler = client.handler
+
+    /**
+     * Download group executor
+     * 最大并行下载任务 线程池
+     */
+    private val downloadGroupExecutor = Executors.newFixedThreadPool(DEFAULT_MAX_DOWNLOAD_TASK_RUNNING_SIZE)
+
+    /**
+     * Download sub fork join pool
+     * 子任务并发池
+     */
+    private val downloadSubForkJoinPool = ForkJoinPool(DEFAULT_MAX_DOWNLOAD_CHUNK_RUNNING_SIZE)
+
+    private val downloadRunningTaskMap = ConcurrentHashMap<DownloadTask, Future<*>>()
+
+    init {
+        LLogger.log(TAG, "AliyunpanDownloader init")
+    }
+
+    fun buildDownload(
+        driveId: String,
+        fileId: String,
+        expireSec: Int? = null,
+        onSuccess: Consumer<BaseTask>,
+        onFailure: Consumer<Exception>
+    ) {
+
+        if (driveId.isEmpty() || fileId.isEmpty()) {
+            val exception = AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("driveId or fileId is empty")
+            LLogger.log(TAG, "buildDownload failed", exception)
+            onFailure.accept(exception)
+            return
+        }
+
+        for (downloadTask in downloadRunningTaskMap.keys()) {
+            if (driveId == downloadTask.driveId && fileId == downloadTask.fileId) {
+                LLogger.log(TAG, "buildDownload get running task")
+                onSuccess.accept(downloadTask)
+                return
+            }
+        }
+
+        client.send(AliyunpanFileScope.GetFile(driveId, fileId), { fileResponse ->
+            val fileJson = fileResponse.data.asJSONObject()
+            val fileSize = fileJson.optLong("size")
+            val fileName = fileJson.optString("name")
+            val fileType = fileJson.optString("type")
+            val fileContentHash = fileJson.optString("content_hash")
+
+            if (SUPPORT_FILE_TYPE != fileType) {
+                onFailure.accept(AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("no support download type"))
+                return@send
+            }
+
+            if (fileSize <= 0) {
+                onFailure.accept(AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("file size is 0"))
+                return@send
+            }
+
+            if (fileName.isEmpty()) {
+                onFailure.accept(AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("file name is empty"))
+                return@send
+            }
+
+            LLogger.log(TAG, "buildDownload build task")
+            onSuccess.accept(
+                DownloadTask(
+                    driveId,
+                    fileId,
+                    expireSec,
+                    this,
+                    fileContentHash,
+                    fileName,
+                    fileSize
+                )
+            )
+        }, onFailure)
+    }
+
+    private fun download(downloadTask: DownloadTask): Boolean {
+        if (downloadRunningTaskMap.containsKey(downloadTask)) {
+            return false
+        }
+        postWaiting(downloadTask)
+        downloadRunningTaskMap[downloadTask] = downloadLoop(downloadTask, null, null)
+        LLogger.log(TAG, "downloadLoop")
+        return true
+    }
+
+    private fun downloadLoop(
+        downloadTask: DownloadTask,
+        lastAllChunkList: List<TaskChunk>?,
+        lastDoneChunkSet: Set<TaskChunk>?,
+    ): Future<*> {
+        return downloadGroupExecutor.submit {
+
+            if (downloadTask.isCancel.get()) {
+                postAbort(downloadTask)
+                return@submit
+            }
+
+            val preDownloadFile = try {
+                checkFileExists(downloadTask)
+            } catch (e: Exception) {
+                postFailed(downloadTask, e)
+                return@submit
+            }
+
+            if (preDownloadFile != null) {
+                postCompleted(downloadTask, preDownloadFile.path)
+                return@submit
+            }
+
+            val downloadUrl = if (downloadTask.downloadUrlValid()) {
+                LLogger.log(TAG, "download url valid")
+                downloadTask.getDownloadUrl()
+            } else {
+                val url = try {
+                    fetchDownloadUrl(downloadTask)
+                } catch (e: Exception) {
+                    postFailed(downloadTask, e)
+                    return@submit
+                }
+
+                if (url.isEmpty()) {
+                    postFailed(
+                        downloadTask,
+                        AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("download fetch url is empty")
+                    )
+                    return@submit
+                }
+                downloadTask.recordDownload(url)
+                url
+            }
+
+            // 创建下载临时文件
+            val downloadTempFile = createDownloadTempFile(downloadTask)
+            // 计算分片
+            val allChunkList = lastAllChunkList ?: buildChunkList(downloadTask.fileSize)
+
+            // 计算未完成分片
+            val unDoneChunkList = if (lastDoneChunkSet.isNullOrEmpty()) {
+                allChunkList
+            } else {
+                allChunkList.filterNot { lastDoneChunkSet.contains(it) }
+            }
+
+            postRunning(downloadTask, lastDoneChunkSet?.size ?: 0, allChunkList.size)
+
+            val doneChunkSet = mutableSetOf<TaskChunk>()
+
+            if (lastDoneChunkSet != null) {
+                doneChunkSet.addAll(lastDoneChunkSet)
+            }
+
+            // 构造本次 下载分片任务集合
+            val tasks = unDoneChunkList.map { DownloadRecursiveTask(downloadUrl, it, downloadTempFile) }
+
+            val chunkStep = ceil(allChunkList.size.toFloat() / DEFAULT_MAX_CHUNK_STEP).toInt()
+
+            val chunkedTasks = tasks.chunked(chunkStep)
+
+            for (chunkedTask in chunkedTasks) {
+                val invokeAll = downloadSubForkJoinPool.invokeAll(chunkedTask)
+
+                try {
+                    for (taskChunkFuture in invokeAll) {
+                        val doneChunk = taskChunkFuture.get()
+                        doneChunkSet.add(doneChunk)
+                    }
+                } catch (e: ExecutionException) {
+                    postNext(downloadTask, allChunkList, doneChunkSet)
+                    return@submit
+                }
+
+                if (downloadTask.isCancel.get()) {
+                    postAbort(downloadTask)
+                    return@submit
+                }
+
+                // 完成一组chunk 通知一次进度
+                postRunning(downloadTask, doneChunkSet.size, allChunkList.size)
+            }
+
+            // 比对分片任务 和完成任务集合
+            if (allChunkList.size == doneChunkSet.size) {
+                val doneDownloadFile = try {
+                    doneDownloadFile(downloadTask, downloadTempFile)
+                } catch (e: Exception) {
+                    postFailed(downloadTask, e)
+                    return@submit
+                }
+                postCompleted(downloadTask, doneDownloadFile.path)
+            } else {
+                postNext(downloadTask, allChunkList, doneChunkSet)
+            }
+        }
+    }
+
+    private fun fetchDownloadUrl(downloadTask: DownloadTask): String {
+        val resultResponse =
+            client.sendSync(
+                AliyunpanFileScope.GetFileGetDownloadUrl(
+                    downloadTask.driveId,
+                    downloadTask.fileId,
+                    downloadTask.expireSec
+                )
+            )
+        val downloadJson = resultResponse.data.asJSONObject()
+        return downloadJson.optString("url")
+    }
+
+    private fun postNext(
+        downloadTask: DownloadTask,
+        chunkList: List<TaskChunk>,
+        doneChunkSet: MutableSet<TaskChunk>
+    ) {
+        handler.post {
+            downloadRunningTaskMap[downloadTask] = downloadLoop(downloadTask, chunkList, doneChunkSet)
+            LLogger.log(TAG, "downloadLoop next")
+        }
+    }
+
+    private fun postRunning(downloadTask: DownloadTask, completedChunkSize: Int, totalChunkSize: Int) {
+        handler.post {
+            for (consumer in downloadTask.stateChangeList) {
+                consumer.accept(BaseTask.TaskState.Running(completedChunkSize, totalChunkSize))
+            }
+        }
+    }
+
+    private fun postWaiting(downloadTask: DownloadTask) {
+        handler.post {
+            for (consumer in downloadTask.stateChangeList) {
+                consumer.accept(BaseTask.TaskState.Waiting)
+            }
+        }
+    }
+
+    private fun postFailed(downloadTask: DownloadTask, e: Exception) {
+        handler.post {
+            for (consumer in downloadTask.stateChangeList) {
+                consumer.accept(BaseTask.TaskState.Failed(e))
+            }
+            downloadRunningTaskMap.remove(downloadTask)
+        }
+    }
+
+    private fun postCompleted(downloadTask: DownloadTask, path: String) {
+        handler.post {
+            for (consumer in downloadTask.stateChangeList) {
+                consumer.accept(BaseTask.TaskState.Completed(path))
+            }
+            downloadRunningTaskMap.remove(downloadTask)
+        }
+    }
+
+    private fun postAbort(downloadTask: DownloadTask) {
+        handler.post {
+            for (consumer in downloadTask.stateChangeList) {
+                consumer.accept(BaseTask.TaskState.Abort)
+            }
+            downloadRunningTaskMap.remove(downloadTask)
+        }
+    }
+
+    private fun cancel(downloadTask: DownloadTask) {
+        downloadTask.isCancel.set(true)
+    }
+
+    private fun createDownloadTempFile(downloadTask: DownloadTask): File {
+        val downloadFolder = File(downloadFolderPath)
+        if (!downloadFolder.exists()) {
+            downloadFolder.mkdirs()
+        }
+
+        val file = File(downloadFolder, downloadTask.fileName + ".download")
+        if (!file.exists()) {
+            file.createNewFile()
+        }
+
+        if (file.exists() && file.isDirectory) {
+            file.delete()
+        }
+
+        return file
+    }
+
+    @Throws(AliyunpanException::class)
+    private fun doneDownloadFile(downloadTask: DownloadTask, downloadTempFile: File): File {
+        val file = File(downloadFolderPath, downloadTask.fileName)
+        if (downloadTempFile.renameTo(file)) {
+            return file
+        } else {
+            throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("doneDownloadFile failed")
+        }
+    }
+
+    @Throws(AliyunpanException::class)
+    private fun checkFileExists(downloadTask: DownloadTask): File? {
+        val file = File(downloadFolderPath, downloadTask.fileName)
+
+        if (file.exists()) {
+            if (file.isFile) {
+                return file
+            } else {
+                throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError("exit same folder")
+            }
+        }
+
+        return null
+    }
+
+    inner class DownloadRecursiveTask(
+        private val url: String,
+        private val taskChunk: TaskChunk,
+        private val downloadTempFile: File
+    ) : Callable<TaskChunk> {
+
+        override fun call(): TaskChunk {
+            client.getOkHttpInstance()
+                .download(
+                    url,
+                    taskChunk.chunkStart,
+                    taskChunk.chunkStart + taskChunk.chunkSize,
+                    downloadTempFile,
+                    null
+                )
+            return taskChunk
+        }
+    }
+
+    data class TaskChunk(
+        val chunkIndex: Int,
+        val chunkStart: Long,
+        val chunkSize: Long,
+    )
+
+    class DownloadTask(
+        override val driveId: String,
+        override val fileId: String,
+        val expireSec: Int? = null,
+        private val downloader: AliyunpanDownloader,
+        val fileHashPath: String,
+        val fileName: String,
+        val fileSize: Long
+    ) : BaseTask(driveId, fileId) {
+
+        val isCancel = AtomicBoolean(false)
+
+        private var downloadUrl: String? = null
+        private var expireSeconds: Long? = null
+
+        internal val stateChangeList = CopyOnWriteArrayList<Consumer<TaskState>>()
+
+        override fun start(): Boolean {
+            return downloader.download(this)
+        }
+
+        override fun cancel() {
+            downloader.cancel(this)
+        }
+
+        override fun addStateChange(onChange: Consumer<TaskState>) {
+            stateChangeList.add(onChange)
+        }
+
+        override fun removeStateChange(onChange: Consumer<TaskState>) {
+            stateChangeList.remove(onChange)
+        }
+
+        internal fun recordDownload(url: String) {
+            downloadUrl = url
+            expireSeconds = (System.currentTimeMillis() / 1000) + (expireSec ?: DEFAULT_EXPIRE_SECONDS)
+        }
+
+        internal fun getDownloadUrl(): String = downloadUrl ?: ""
+        internal fun downloadUrlValid(): Boolean {
+            if (downloadUrl.isNullOrEmpty()) {
+                return false
+            }
+
+            return expireSeconds?.let { (System.currentTimeMillis() / 1000) < it } ?: false
+        }
+
+        override fun equals(other: Any?): Boolean {
+            if (this === other) return true
+            if (javaClass != other?.javaClass) return false
+
+            other as DownloadTask
+
+            if (driveId != other.driveId) return false
+            return fileId == other.fileId
+        }
+
+        override fun hashCode(): Int {
+            var result = driveId.hashCode()
+            result = 31 * result + fileId.hashCode()
+            return result
+        }
+
+        companion object {
+
+            private const val DEFAULT_EXPIRE_SECONDS = 900
+        }
+    }
+
+    companion object {
+
+        private const val TAG = "AliyunpanDownloader"
+
+        private const val SUPPORT_FILE_TYPE = "file"
+
+        private const val DEFAULT_MAX_DOWNLOAD_TASK_RUNNING_SIZE = 2
+
+        private const val DEFAULT_MAX_DOWNLOAD_CHUNK_RUNNING_SIZE = 8
+
+        /**
+         * Default Max Chunk Size
+         * 分片size 最大值
+         */
+        internal const val DEFAULT_MAX_CHUNK_SIZE = 1024 * 100L
+
+        /**
+         * Default Max Chunk Step
+         * 最多切100步
+         */
+        private const val DEFAULT_MAX_CHUNK_STEP = 100
+
+        internal fun buildChunkList(size: Long): List<TaskChunk> {
+            if (size <= DEFAULT_MAX_CHUNK_SIZE) {
+                return listOf(TaskChunk(0, 0, size))
+            }
+            val taskChunks = arrayListOf<TaskChunk>()
+            val index = (size / DEFAULT_MAX_CHUNK_SIZE).toInt()
+            repeat(index) {
+                taskChunks.add(TaskChunk(it, it * DEFAULT_MAX_CHUNK_SIZE, DEFAULT_MAX_CHUNK_SIZE))
+            }
+
+            val endSize = size % DEFAULT_MAX_CHUNK_SIZE
+            if (endSize > 0) {
+                taskChunks.add(TaskChunk(index, index * DEFAULT_MAX_CHUNK_SIZE, endSize))
+            }
+
+            return taskChunks
+        }
+    }
+}
+
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BaseTask.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BaseTask.kt
new file mode 100644
index 0000000..8e665ab
--- /dev/null
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BaseTask.kt
@@ -0,0 +1,73 @@
+package com.alicloud.databox.opensdk.io
+
+import com.alicloud.databox.opensdk.Consumer
+
+abstract class BaseTask(
+    internal open val driveId: String,
+    internal open val fileId: String,
+) {
+
+    /**
+     * Start
+     *
+     * @return 正在运行中返回false 否则返回true
+     */
+    abstract fun start(): Boolean
+
+    /**
+     * Cancel
+     * 取消任务
+     */
+    abstract fun cancel()
+
+    abstract fun addStateChange(onChange: Consumer<TaskState>)
+
+    abstract fun removeStateChange(onChange: Consumer<TaskState>)
+
+    /**
+     * Task state
+     * 密封类封装各运行状态 和关联数据
+     * @constructor Create empty Task state
+     */
+    sealed class TaskState {
+
+        /**
+         * 等待
+         */
+        object Waiting : TaskState()
+
+        /**
+         * 正在运行
+         */
+        class Running(val completedChunkSize: Int, val totalChunkSize: Int) : TaskState() {
+            /**
+             * Get progress
+             *
+             * @return 返回值范围 带小数点 0.0..1.0
+             */
+            fun getProgress(): Float {
+                return completedChunkSize.toFloat() / totalChunkSize
+            }
+        }
+
+//        /**
+//         * 暂停
+//         */
+//        object Paused : TaskState()
+
+        /**
+         * 已完成
+         */
+        class Completed(val filePath: String) : TaskState()
+
+        /**
+         * 失败
+         */
+        class Failed(val exception: Exception) : TaskState()
+
+        /**
+         * 取消
+         */
+        object Abort : TaskState()
+    }
+}
\ No newline at end of file
diff --git a/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BufferRandomAccessFile.kt b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BufferRandomAccessFile.kt
new file mode 100644
index 0000000..e1cc2fb
--- /dev/null
+++ b/opensdk/src/main/java/com/alicloud/databox/opensdk/io/BufferRandomAccessFile.kt
@@ -0,0 +1,54 @@
+package com.alicloud.databox.opensdk.io
+
+import com.alicloud.databox.opensdk.AliyunpanException
+import com.alicloud.databox.opensdk.AliyunpanException.Companion.buildError
+import java.io.BufferedOutputStream
+import java.io.File
+import java.io.FileDescriptor
+import java.io.FileOutputStream
+import java.io.IOException
+import java.io.RandomAccessFile
+
+/**
+ * The BufferedOutputStream implemented using [RandomAccessFile].
+ * 用于下载场景文件内容保存
+ *
+ * @author dengxian.ldx
+ */
+class BufferRandomAccessFile(file: File) {
+
+    private var out: BufferedOutputStream? = null
+    private var fd: FileDescriptor? = null
+    private var randomAccess = RandomAccessFile(file, "rw")
+
+    init {
+        try {
+            fd = randomAccess.fd
+            out = BufferedOutputStream(FileOutputStream(randomAccess.fd))
+        } catch (e: IOException) {
+            throw AliyunpanException.CODE_DOWNLOAD_ERROR.buildError(e.message ?: "BufferRandomAccessFile init")
+        }
+    }
+
+    @Throws(IOException::class)
+    fun write(b: ByteArray?, off: Int, len: Int) {
+        out?.write(b, off, len)
+    }
+
+    @Throws(IOException::class)
+    fun flushAndSync() {
+        out?.flush()
+        fd?.sync()
+    }
+
+    @Throws(IOException::class)
+    fun close() {
+        out?.close()
+        randomAccess?.close()
+    }
+
+    @Throws(IOException::class)
+    fun seek(offset: Long) {
+        randomAccess?.seek(offset)
+    }
+}
diff --git a/opensdk/src/test/java/com/alicloud/databox/opensdk/io/AliyunpanDownloaderTest.kt b/opensdk/src/test/java/com/alicloud/databox/opensdk/io/AliyunpanDownloaderTest.kt
new file mode 100644
index 0000000..1cbecd8
--- /dev/null
+++ b/opensdk/src/test/java/com/alicloud/databox/opensdk/io/AliyunpanDownloaderTest.kt
@@ -0,0 +1,29 @@
+package com.alicloud.databox.opensdk.io
+
+import org.junit.Assert
+import org.junit.Test
+
+class AliyunpanDownloaderTest {
+
+    @Test
+    fun testBuildChunkListLess() {
+        val buildChunkList = AliyunpanDownloader.buildChunkList(DEFAULT_CHUNK_SIZE - 100)
+        Assert.assertEquals(1, buildChunkList.size)
+    }
+
+    @Test
+    fun testBuildChunkListExactly() {
+        val buildChunkList = AliyunpanDownloader.buildChunkList(DEFAULT_CHUNK_SIZE * 2)
+        Assert.assertEquals(2, buildChunkList.size)
+    }
+
+    @Test
+    fun testBuildChunkListMore() {
+        val buildChunkList = AliyunpanDownloader.buildChunkList(DEFAULT_CHUNK_SIZE * 2 + 100)
+        Assert.assertEquals(3, buildChunkList.size)
+    }
+
+    companion object {
+        private const val DEFAULT_CHUNK_SIZE = AliyunpanDownloader.DEFAULT_MAX_CHUNK_SIZE
+    }
+}
\ No newline at end of file