Android 文件分段上传和下载方案

一、背景

Android 中的大文件下载必要使用分段下载，下载通常是在线程中举行的，如果有5段，那同时5个线程去实行下载，请求http返回文件流后，必要将多个文件流同时写进同一个文件，这里用到

1. RandomAccessFile。

复制代码

分段上传的话，只必要根据每段文件阀值，例如,50M为一段，将文件按照设置的阀值，分段上传即可

二、相关代码

2.1 分段上传关键代码

忽略网络请求和状态码，每个人接口界说的的请求参数和返回code不一样

1.        private val DEFAULT_BLOCK_SIZE: Long = 50 * 1024 * 1024 //50MB
2.         val blockSize=DEFAULT_BLOCK_SIZE
4.         val randomAccessFile = RandomAccessFile(filePath, "r")
5.         val fileLen = randomAccessFile.length()
7.         //超过设定的单个文件大小,需要分块上传
8.             val blockFileNum = Math.ceil((fileLen / blockSize.toDouble())).toInt()
9.             XLogUtil.d("${TAG}blockFileNum:$blockFileNum,,,,fileLen:$fileLen,,,blockSize:$blockSize,,,requestId:$requestId")
11.             var offSet = 0L
12.             var successNum = 0
13.             var isSendResult = true
15.             for (i in 0 until blockFileNum) {
16.                 val startOffset = i * blockSize
17.                 val blockFileLen = Math.min(blockSize, fileLen - startOffset)
18.                 val fileData = getFileData(filePath, offSet, blockFileLen.toInt())
20.                 // 创建文件名请求体
21.                 val requestBody = RequestBody.create(null, fileData)
23.                 val call = RetrofitClient.getUploadFileService(
24.                     token,
25.                     requestId,
26.                     offSet.toString(),
27.                     uploadType
28.                 ).uploadFile(file.name, requestBody)
29.                 XLogUtil.d("${TAG}upload 第${i + 1}块 block file,offSet:$offSet,,,blockFileLen:$blockFileLen,,,blockFileNum:$blockFileNum,,,fileLen:$fileLen,,,filePath:$filePath,,,fileData size:${fileData?.size},,,requestId:$requestId")
31.                 offSet += blockFileLen
32.                 call.enqueue(object : Callback<ResponseBody?> {
33.                     override fun onResponse(
34.                         call: Call<ResponseBody?>,
35.                         response: Response<ResponseBody?>
36.                     ) {
37.                         val code = response.code()
38.                         XLogUtil.d("${TAG}upload 第${i + 1}块 block file result code:$code,,,requestId:$requestId")
39.                         if (code == 201) {
40.                             //处理成功响应
41.                             successNum++
42.                             if (successNum == blockFileNum) {
43.                                 XLogUtil.d("${TAG}upload all block file success,blockFileNum:$blockFileNum,,,requestId:$requestId")
44.                                 listener?.apply {
45.                                     onSuccess(Constant.SUCCESS, requestId)
46.                                 }
48.                                 //上传完
49.                            
50.                             }
51.                         } else {
52.                             //处理失败响应
53.          
54.                         }
55.                     }
57.                     override fun onFailure(call: Call<ResponseBody?>, t: Throwable) {
58.                         // 处理请求失败
59.                         XLogUtil.d("${TAG}upload 第${i + 1}块 block file onFailure message:${t.printStackTrace()}")
60.       
61.                     }
62.                 })
63.             }
75.     /**
76.      * 根据偏移量获取分块文件数据
77.      */
78.     fun getFileData(filePath: String, offset: Long, length: Int): ByteArray? {
79.         // 使用RandomAccessFile随机访问文件
80.         var randomAccessFile: RandomAccessFile? = null
81.         try {
82.             randomAccessFile = RandomAccessFile(filePath, "r")
83.             val fileChannel = randomAccessFile.channel
84.             // 将文件的部分区域映射为内存区域
85.             val mappedByteBuffer =
86.                 fileChannel.map(FileChannel.MapMode.READ_ONLY, offset, length.toLong())
87.             val data = ByteArray(length)
88.             // 从映射区域中读取数据
89.             mappedByteBuffer[data]
90.             return data
91.         } catch (e: Exception) {
92.             e.printStackTrace()
93.             return null
94.         } finally {
95.             if (randomAccessFile != null) {
96.                 try {
97.                     randomAccessFile.close()
98.                 } catch (e: Exception) {
99.                     e.printStackTrace()
100.                 }
101.             }
102.         }
103.     }

复制代码

2.2、分段下载关键代码

1.                 val folder = File(DOWNLOAD_FOLDER_PATH)
2.                             if (!folder.exists()) {
3.                                 folder.mkdirs()
4.                             }
6.                             val fileName = getFileNameWithPath(filePath)
7.                             val downFile = File(DOWNLOAD_FOLDER_PATH + File.separator + fileName)
8.                             if (!downFile.exists()) {
9.                                 downFile.createNewFile()
10.                             }
13.                             // 使用输入流保存响应体到文件,这里通常是通过http请求，返回的文件流，替换即可
14.                             val inputStream = body.byteStream()
16.                             val rw = RandomAccessFile(downFile, "rw")
17.                             rw.seek(startPosition)//文件写入的初始位置
18.                             var hasReads = 0
19.                             var readLenght: Long = 0
21.                             val bytes = ByteArray(4096)
22.                             while ((inputStream.read(bytes).also { hasReads = it }) > 0) {
23.                                 rw.write(bytes, 0, hasReads)
24.                                 readLenght += hasReads
25.                                 // val l = (readLenght * 100 / contentLength) as Int 单块文件写入进度
26.                             }
29.                             // 关闭文件输出流和输入流
30.                             inputStream.close()
31.                             rw.close()
39.     /**
40.      * 根据文件路径获取文件名
41.      */
42.     fun getFileNameWithPath(path: String): String {
43.         if (TextUtils.isEmpty(path)) {
44.             return ""
45.         }
46.         val start = path.lastIndexOf("/")
47.         return if (start != -1) {
48.             path.substring(start + 1)
49.         } else {
50.             "DEFAULT_NAME"
51.         }
52.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。