RandomAccessFile

       private val DEFAULT_BLOCK_SIZE: Long = 50 * 1024 * 1024 //50MB
        val blockSize=DEFAULT_BLOCK_SIZE
        val randomAccessFile = RandomAccessFile(filePath, "r")
        val fileLen = randomAccessFile.length()
        //超過設(shè)定的單個文件大小,需要分塊上傳
            val blockFileNum = Math.ceil((fileLen / blockSize.toDouble())).toInt()
            XLogUtil.d("${TAG}blockFileNum:$blockFileNum,,,,fileLen:$fileLen,,,blockSize:$blockSize,,,requestId:$requestId")
            var offSet = 0L
            var successNum = 0
            var isSendResult = true
            for (i in 0 until blockFileNum) {
                val startOffset = i * blockSize
                val blockFileLen = Math.min(blockSize, fileLen - startOffset)
                val fileData = getFileData(filePath, offSet, blockFileLen.toInt())
                // 創(chuàng)建文件名請求體
                val requestBody = RequestBody.create(null, fileData)
                val call = RetrofitClient.getUploadFileService(
                    token,
                    requestId,
                    offSet.toString(),
                    uploadType
                ).uploadFile(file.name, requestBody)
                XLogUtil.d("${TAG}upload 第${i + 1}塊 block file,offSet:$offSet,,,blockFileLen:$blockFileLen,,,blockFileNum:$blockFileNum,,,fileLen:$fileLen,,,filePath:$filePath,,,fileData size:${fileData?.size},,,requestId:$requestId")
                offSet += blockFileLen
                call.enqueue(object : Callback<ResponseBody?> {
                    override fun onResponse(
                        call: Call<ResponseBody?>,
                        response: Response<ResponseBody?>
                    ) {
                        val code = response.code()
                        XLogUtil.d("${TAG}upload 第${i + 1}塊 block file result code:$code,,,requestId:$requestId")
                        if (code == 201) {
                            //處理成功響應(yīng)
                            successNum++
                            if (successNum == blockFileNum) {
                                XLogUtil.d("${TAG}upload all block file success,blockFileNum:$blockFileNum,,,requestId:$requestId")
                                listener?.apply {
                                    onSuccess(Constant.SUCCESS, requestId)
                                }
                                //上傳完
                            }
                        } else {
                            //處理失敗響應(yīng)
                        }
                    }
                    override fun onFailure(call: Call<ResponseBody?>, t: Throwable) {
                        // 處理請求失敗
                        XLogUtil.d("${TAG}upload 第${i + 1}塊 block file onFailure message:${t.printStackTrace()}")
                    }
                })
            }
    /**
     * 根據(jù)偏移量獲取分塊文件數(shù)據(jù)
     */
    fun getFileData(filePath: String, offset: Long, length: Int): ByteArray? {
        // 使用RandomAccessFile隨機(jī)訪問文件
        var randomAccessFile: RandomAccessFile? = null
        try {
            randomAccessFile = RandomAccessFile(filePath, "r")
            val fileChannel = randomAccessFile.channel
            // 將文件的部分區(qū)域映射為內(nèi)存區(qū)域
            val mappedByteBuffer =
                fileChannel.map(FileChannel.MapMode.READ_ONLY, offset, length.toLong())
            val data = ByteArray(length)
            // 從映射區(qū)域中讀取數(shù)據(jù)
            mappedByteBuffer[data]
            return data
        } catch (e: Exception) {
            e.printStackTrace()
            return null
        } finally {
            if (randomAccessFile != null) {
                try {
                    randomAccessFile.close()
                } catch (e: Exception) {
                    e.printStackTrace()
                }
            }
        }
    }

                val folder = File(DOWNLOAD_FOLDER_PATH)
                            if (!folder.exists()) {
                                folder.mkdirs()
                            }
                            val fileName = getFileNameWithPath(filePath)
                            val downFile = File(DOWNLOAD_FOLDER_PATH + File.separator + fileName)
                            if (!downFile.exists()) {
                                downFile.createNewFile()
                            }
                            // 使用輸入流保存響應(yīng)體到文件,這里通常是通過http請求，返回的文件流，替換即可
                            val inputStream = body.byteStream()
                            val rw = RandomAccessFile(downFile, "rw")
                            rw.seek(startPosition)//文件寫入的初始位置
                            var hasReads = 0
                            var readLenght: Long = 0
                            val bytes = ByteArray(4096)
                            while ((inputStream.read(bytes).also { hasReads = it }) > 0) {
                                rw.write(bytes, 0, hasReads)
                                readLenght += hasReads
                                // val l = (readLenght * 100 / contentLength) as Int 單塊文件寫入進(jìn)度
                            }
                            // 關(guān)閉文件輸出流和輸入流
                            inputStream.close()
                            rw.close()
    /**
     * 根據(jù)文件路徑獲取文件名
     */
    fun getFileNameWithPath(path: String): String {
        if (TextUtils.isEmpty(path)) {
            return ""
        }
        val start = path.lastIndexOf("/")
        return if (start != -1) {
            path.substring(start + 1)
        } else {
            "DEFAULT_NAME"
        }
    }