文件下载增加协程方式

catchpig · catchpig · commit 40ffd55372e8 · 2022-04-19T22:12:40.000+08:00
diff --git a/CHANGE_lOG.md b/CHANGE_lOG.md
@@ -1,4 +1,8 @@
 # CHANGE LOG
+### v0.4.2(2022.4.19)
+
++ 文件下载增加协程方式
+
 ### v0.4.1(2022.1.14)
 
 + 多文件下载增加进度回调接口
diff --git a/app/src/main/java/com/catchpig/kmvvm/apk/viewmodel/InstallApkViewModel.kt b/app/src/main/java/com/catchpig/kmvvm/apk/viewmodel/InstallApkViewModel.kt
@@ -1,9 +1,13 @@
 package com.catchpig.kmvvm.apk.viewmodel
 
 import androidx.lifecycle.MutableLiveData
+import androidx.lifecycle.viewModelScope
 import com.catchpig.mvvm.base.viewmodel.BaseViewModel
 import com.catchpig.mvvm.entity.DownloadProgress
-import com.catchpig.mvvm.network.manager.DownloadManager
+import com.catchpig.mvvm.network.manager.CoroutinesDownloadManager
+import com.catchpig.mvvm.network.manager.RxJavaDownloadManager
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 
 /**
  *
@@ -17,18 +21,33 @@ class InstallApkViewModel : BaseViewModel() {
 
     fun download() {
         val downloadUrlpng = "http://a.xzfile.com/apk4/apkwjql_v1.1_downcc.com.apk"
-        val downloadUrlpng1 = "http://a.xzfile.com/apk4/apkpure_v3.17.32_downcc.com.apk"
+        val downloadUrlpng1 =
+            "https://imtt.dd.qq.com/16891/myapp/channel_102497291_1165285_b0e7c10e19b54b31dfaf1fd4c0150e44.apk?hsr=5848"
         val downloadUrl = "https://wanandroid.com/blogimgs/2d120094-e1ee-47fb-a155-6eb4ca49d01f.apk"
-        DownloadManager.download(downloadUrlpng, {
+        viewModelScope.launch(Dispatchers.Main) {
+//            RxJavaDownloadManager.download(downloadUrlpng, {
+//
+//            }, { downloadProgress ->
+//                progressLiveData.value = downloadProgress
+//            })
+//
+//            RxJavaDownloadManager.multiDownload(listOf(downloadUrl, downloadUrlpng1), {
+//
+//            }, { downloadProgress ->
+//                progressLiveData1.value = downloadProgress
+//            })
+            CoroutinesDownloadManager.download(downloadUrlpng, {
 
-        }, { downloadProgress ->
-            progressLiveData.value = downloadProgress
-        })
+            }, { downloadProgress ->
+                progressLiveData.value = downloadProgress
+            })
 
-        DownloadManager.multiDownload(listOf(downloadUrl, downloadUrlpng1), {
+            CoroutinesDownloadManager.multiDownload(listOf(downloadUrl, downloadUrlpng1), {
+
+            }, { downloadProgress ->
+                progressLiveData1.value = downloadProgress
+            })
+        }
 
-        }, { downloadProgress ->
-            progressLiveData1.value = downloadProgress
-        })
     }
 }
diff --git a/app/src/main/java/com/catchpig/kmvvm/child/ChildActivity.kt b/app/src/main/java/com/catchpig/kmvvm/child/ChildActivity.kt
@@ -12,25 +12,25 @@ class ChildActivity : BaseVMActivity<ActivityChildBinding, ChildViewModel>() {
     @OnClickFirstDrawable(R.drawable.more)
     fun clickFirstDrawable(v: View) {
         snackBar("第一个图标按钮点击生效")
-        updateTitle("nihao")
+        updateTitle("第一图标")
     }
 
     @OnClickFirstText(R.string.more)
     fun clickFirstText() {
         snackBar("第一个文字按钮点击生效")
-        updateTitle("12354")
+        updateTitle("第一文字")
     }
 
     @OnClickSecondDrawable(R.drawable.more)
     fun clickSecondDrawable(v: View) {
         snackBar("第二个图标按钮点击生效")
-        updateTitle("nihao")
+        updateTitle("第二图标")
     }
 
     @OnClickSecondText(R.string.more)
     fun clickSecondText() {
         snackBar("第二个文字按钮点击生效")
-        updateTitle("12354")
+        updateTitle("第二文字")
     }
 
     override fun initParam() {
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/api/CoroutinesDownloadService.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/api/CoroutinesDownloadService.kt
@@ -1,21 +1,21 @@
 package com.catchpig.mvvm.network.api
 
-import io.reactivex.rxjava3.core.Flowable
 import okhttp3.ResponseBody
 import retrofit2.http.GET
 import retrofit2.http.Streaming
 import retrofit2.http.Url
+
 /**
  * 下载网络接口服务
   * @author catchpig
  * @date 2020/11/20 10:25
  */
-interface DownloadService {
+interface CoroutinesDownloadService {
     /**
      * 可以断点续传
      * @param url 下载地址
      */
     @Streaming
     @GET
-    fun download(@Url url:String):Flowable<ResponseBody>
+    suspend fun download(@Url url:String):ResponseBody
 }
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/api/RxJavaDownloadService.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/api/RxJavaDownloadService.kt
@@ -0,0 +1,23 @@
+package com.catchpig.mvvm.network.api
+
+import io.reactivex.rxjava3.core.Flowable
+import kotlinx.coroutines.flow.Flow
+import okhttp3.ResponseBody
+import retrofit2.http.GET
+import retrofit2.http.Streaming
+import retrofit2.http.Url
+
+/**
+ * 下载网络接口服务
+ * @author catchpig
+ * @date 2020/11/20 10:25
+ */
+interface RxJavaDownloadService {
+    /**
+     * 可以断点续传
+     * @param url 下载地址
+     */
+    @Streaming
+    @GET
+    fun download(@Url url: String): Flowable<ResponseBody>
+}
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/download/DownloadSubscriber.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/download/DownloadSubscriber.kt
@@ -20,35 +20,42 @@ class DownloadSubscriber(private val downloadCallback: DownloadCallback) :
         const val TAG = "DownloadSubscriber"
     }
 
-    override fun onStart() {
+    public override fun onStart() {
         super.onStart()
+        "onStart".logd(TAG)
         downloadCallback.onStart()
     }
 
     override fun onNext(t: String) {
+        "onNext($t)".logd(TAG)
         downloadCallback.onSuccess(t)
     }
 
     override fun onError(t: Throwable?) {
         t?.let {
+            if (t is Exception) {
+                t.printStackTrace()
+            }
+            "onError(${it})".logd(TAG)
             downloadCallback.onError(it)
         }
     }
 
     override fun onComplete() {
+        "onComplete".logd(TAG)
         downloadCallback.onComplete()
     }
 
     override fun update(read: Long, count: Long, done: Boolean) {
-        Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe(Consumer {
+        Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe {
             val downloadProgress = if (done) {
                 DownloadProgress(read, count, 1, 1)
             } else {
                 DownloadProgress(read, count, 0, 1)
             }
-            "progress:$downloadProgress".logd(TAG)
+            "update($read,$count,$done)".logd(TAG)
             downloadCallback.onProgress(downloadProgress)
-        })
+        }
 
     }
 }
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/download/MultiDownloadSubscriber.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/download/MultiDownloadSubscriber.kt
@@ -6,7 +6,6 @@ import com.catchpig.mvvm.listener.MultiDownloadCallback
 import com.catchpig.utils.ext.logd
 import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers
 import io.reactivex.rxjava3.core.Flowable
-import io.reactivex.rxjava3.functions.Consumer
 import io.reactivex.rxjava3.subscribers.ResourceSubscriber
 
 /**
@@ -23,36 +22,43 @@ class MultiDownloadSubscriber(
     }
 
     private var paths = arrayListOf<String>()
-    override fun onStart() {
+    public override fun onStart() {
         super.onStart()
+        "onStart".logd(TAG)
         multiDownloadCallback.onStart()
     }
 
     override fun onNext(t: String) {
+        "onNext($t)".logd(TAG)
         paths.add(t)
     }
 
     override fun onError(t: Throwable?) {
         t?.let {
+            if (t is Exception) {
+                t.printStackTrace()
+            }
+            "onError($t)".logd(TAG)
             multiDownloadCallback.onError(it)
         }
     }
 
     override fun onComplete() {
+        "onComplete($paths)".logd(TAG)
         multiDownloadCallback.onSuccess(paths)
         multiDownloadCallback.onComplete()
     }
 
     override fun update(read: Long, count: Long, done: Boolean) {
-        Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe(Consumer {
+        Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe {
             val completeCount = paths.size
             val downloadProgress = if (done && (completeCount + 1) == totalCount) {
                 DownloadProgress(read, count, totalCount, totalCount)
             } else {
                 DownloadProgress(read, count, completeCount, totalCount)
             }
-            "progress:$downloadProgress".logd(TAG)
+            "update($read,$count,$done)".logd(TAG)
             multiDownloadCallback.onProgress(downloadProgress)
-        })
+        }
     }
 }
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/manager/BaseDownloadManager.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/manager/BaseDownloadManager.kt
@@ -0,0 +1,118 @@
+package com.catchpig.mvvm.network.manager
+
+import android.os.Environment
+import com.catchpig.mvvm.manager.ContextManager
+import com.catchpig.mvvm.network.interceptor.DownloadInterceptor
+import okhttp3.OkHttpClient
+import okhttp3.ResponseBody
+import okhttp3.logging.HttpLoggingInterceptor
+import java.io.File
+import java.io.IOException
+import java.io.RandomAccessFile
+import java.nio.channels.FileChannel
+import java.util.concurrent.TimeUnit
+
+open class BaseDownloadManager {
+    companion object {
+        /**
+         * 连接超时时间(秒)
+         */
+        private const val CONNECT_TIMEOUT = 5L
+
+        /**
+         * 读取数据超时时间(分钟)
+         */
+        private const val READ_TIMEOUT = 10L
+    }
+
+
+    private val logInterceptor by lazy {
+        val httpLoggingInterceptor = HttpLoggingInterceptor()
+        httpLoggingInterceptor.level = HttpLoggingInterceptor.Level.BODY
+        httpLoggingInterceptor
+    }
+
+    protected val downloadInterceptor by lazy {
+        DownloadInterceptor()
+    }
+
+    private var okHttpClient: OkHttpClient? = null
+
+    protected fun getOkHttpClient(): OkHttpClient {
+        if (okHttpClient == null) {
+            okHttpClient = OkHttpClient
+                .Builder()
+                /**
+                 * 连接超时时间5秒
+                 */
+                .connectTimeout(CONNECT_TIMEOUT, TimeUnit.SECONDS)
+                /**
+                 * 读取数据超时时间10分钟
+                 */
+                .readTimeout(READ_TIMEOUT, TimeUnit.MINUTES)
+                .addInterceptor(logInterceptor)
+                .addInterceptor(downloadInterceptor)
+                .build()
+        }
+        return okHttpClient!!
+    }
+
+    /**
+     * 生成文件的地址
+     * @param downloadUrl String
+     * @return String
+     */
+    protected fun localFileName(downloadUrl: String): String {
+        val fileName = downloadUrl.replace("/", "").replace("\\", "")
+        var cashDir = getDownloadFilePath()
+        return "$cashDir/download/$fileName"
+    }
+
+    private fun getDownloadFilePath(): String {
+        return if (Environment.MEDIA_MOUNTED == Environment.getExternalStorageState()) {
+            //有SD卡,拿到SD卡的/storage/sdcard0/Android/data/包名/cash目录
+            ContextManager.context.externalCacheDir!!.absolutePath
+        } else {
+            //没有SD卡的,拿到/data/data/包名/cash目录
+            ContextManager.context.cacheDir.absolutePath
+        }
+    }
+
+    /**
+     * 将下载的数据写入本地缓存
+     * @param responseBody ResponseBody 下载的文件数据
+     * @param fileName String 文件名称
+     * @return String 本地路径
+     * @throws IOException
+     */
+    @Throws(IOException::class)
+    protected fun writeCache(responseBody: ResponseBody, fileName: String): String {
+        var file = File(fileName)
+        if (!file.parentFile.exists()) {
+            file.parentFile.mkdirs()
+        } else if (file.exists()) {
+            if (file.length() == responseBody.contentLength()) {
+                return fileName
+            } else {
+                file.delete()
+            }
+        }
+        var randomAccessFile = RandomAccessFile(file, "rwd")
+        var fileChannel = randomAccessFile.channel
+        var mappedByteBuffer =
+            fileChannel.map(FileChannel.MapMode.READ_WRITE, 0, responseBody.contentLength())
+        var buffer = ByteArray(1024 * 8)
+        var len: Int
+        while (true) {
+            len = responseBody.byteStream().read(buffer)
+            if (len == -1) {
+                break
+            }
+            mappedByteBuffer.put(buffer, 0, len)
+        }
+        responseBody.byteStream().close()
+        fileChannel?.close()
+        randomAccessFile?.close()
+        return fileName
+    }
+}
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/manager/CoroutinesDownloadManager.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/manager/CoroutinesDownloadManager.kt
diff --git a/mvvm/src/main/java/com/catchpig/mvvm/network/manager/RxJavaDownloadManager.kt b/mvvm/src/main/java/com/catchpig/mvvm/network/manager/RxJavaDownloadManager.kt

Original file line number	Diff line number	Diff line change
`@@ -20,35 +20,42 @@ class DownloadSubscriber(private val downloadCallback: DownloadCallback) :`
`20`	`20`	`const val TAG = "DownloadSubscriber"`
`21`	`21`	`}`
`22`	`22`
`23`		`- override fun onStart() {`
	`23`	`+ public override fun onStart() {`
`24`	`24`	`super.onStart()`
	`25`	`+ "onStart".logd(TAG)`
`25`	`26`	`downloadCallback.onStart()`
`26`	`27`	`}`
`27`	`28`
`28`	`29`	`override fun onNext(t: String) {`
	`30`	`+ "onNext($t)".logd(TAG)`
`29`	`31`	`downloadCallback.onSuccess(t)`
`30`	`32`	`}`
`31`	`33`
`32`	`34`	`override fun onError(t: Throwable?) {`
`33`	`35`	`t?.let {`
	`36`	`+ if (t is Exception) {`
	`37`	`+ t.printStackTrace()`
	`38`	`+ }`
	`39`	`+ "onError(${it})".logd(TAG)`
`34`	`40`	`downloadCallback.onError(it)`
`35`	`41`	`}`
`36`	`42`	`}`
`37`	`43`
`38`	`44`	`override fun onComplete() {`
	`45`	`+ "onComplete".logd(TAG)`
`39`	`46`	`downloadCallback.onComplete()`
`40`	`47`	`}`
`41`	`48`
`42`	`49`	`override fun update(read: Long, count: Long, done: Boolean) {`
`43`		`- Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe(Consumer {`
	`50`	`+ Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe {`
`44`	`51`	`val downloadProgress = if (done) {`
`45`	`52`	`DownloadProgress(read, count, 1, 1)`
`46`	`53`	`} else {`
`47`	`54`	`DownloadProgress(read, count, 0, 1)`
`48`	`55`	`}`
`49`		`- "progress:$downloadProgress".logd(TAG)`
	`56`	`+ "update($read,$count,$done)".logd(TAG)`
`50`	`57`	`downloadCallback.onProgress(downloadProgress)`
`51`		`- })`
	`58`	`+ }`
`52`	`59`
`53`	`60`	`}`
`54`	`61`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,6 @@ import com.catchpig.mvvm.listener.MultiDownloadCallback`
`6`	`6`	`import com.catchpig.utils.ext.logd`
`7`	`7`	`import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers`
`8`	`8`	`import io.reactivex.rxjava3.core.Flowable`
`9`		`-import io.reactivex.rxjava3.functions.Consumer`
`10`	`9`	`import io.reactivex.rxjava3.subscribers.ResourceSubscriber`
`11`	`10`
`12`	`11`	`/**`
`@@ -23,36 +22,43 @@ class MultiDownloadSubscriber(`
`23`	`22`	`}`
`24`	`23`
`25`	`24`	`private var paths = arrayListOf<String>()`
`26`		`- override fun onStart() {`
	`25`	`+ public override fun onStart() {`
`27`	`26`	`super.onStart()`
	`27`	`+ "onStart".logd(TAG)`
`28`	`28`	`multiDownloadCallback.onStart()`
`29`	`29`	`}`
`30`	`30`
`31`	`31`	`override fun onNext(t: String) {`
	`32`	`+ "onNext($t)".logd(TAG)`
`32`	`33`	`paths.add(t)`
`33`	`34`	`}`
`34`	`35`
`35`	`36`	`override fun onError(t: Throwable?) {`
`36`	`37`	`t?.let {`
	`38`	`+ if (t is Exception) {`
	`39`	`+ t.printStackTrace()`
	`40`	`+ }`
	`41`	`+ "onError($t)".logd(TAG)`
`37`	`42`	`multiDownloadCallback.onError(it)`
`38`	`43`	`}`
`39`	`44`	`}`
`40`	`45`
`41`	`46`	`override fun onComplete() {`
	`47`	`+ "onComplete($paths)".logd(TAG)`
`42`	`48`	`multiDownloadCallback.onSuccess(paths)`
`43`	`49`	`multiDownloadCallback.onComplete()`
`44`	`50`	`}`
`45`	`51`
`46`	`52`	`override fun update(read: Long, count: Long, done: Boolean) {`
`47`		`- Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe(Consumer {`
	`53`	`+ Flowable.just(done).subscribeOn(AndroidSchedulers.mainThread()).subscribe {`
`48`	`54`	`val completeCount = paths.size`
`49`	`55`	`val downloadProgress = if (done && (completeCount + 1) == totalCount) {`
`50`	`56`	`DownloadProgress(read, count, totalCount, totalCount)`
`51`	`57`	`} else {`
`52`	`58`	`DownloadProgress(read, count, completeCount, totalCount)`
`53`	`59`	`}`
`54`		`- "progress:$downloadProgress".logd(TAG)`
	`60`	`+ "update($read,$count,$done)".logd(TAG)`
`55`	`61`	`multiDownloadCallback.onProgress(downloadProgress)`
`56`		`- })`
	`62`	`+ }`
`57`	`63`	`}`
`58`	`64`	`}`