Flutter如何通过isolate实现文件分片上传

在Flutter中，如何通过isolate实现文件分片上传？具体需要哪些步骤？能否提供一个完整的代码示例？另外，如何确保分片上传的效率和稳定性，以及如何处理可能出现的错误和重试机制？

2 回复

Flutter通过Isolate.spawn创建独立线程，将文件分片后传入isolate处理。使用SendPort传递分片数据，在isolate内执行上传逻辑，避免阻塞UI线程。完成后通过ReceivePort返回结果。

更多关于Flutter如何通过isolate实现文件分片上传的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html


在Flutter中，可以使用Isolate实现文件分片上传，避免阻塞UI线程。以下是实现步骤和示例代码：

实现步骤：

  1. 读取文件并分片：使用dart:io读取文件，按指定大小分片。
  2. 创建Isolate处理上传：将分片数据传入Isolate，执行上传逻辑。
  3. 上传分片：在Isolate中使用HTTP请求上传每个分片。
  4. 合并分片（服务端）：服务端接收分片后按顺序合并。

示例代码：

import 'dart:io';
import 'dart:isolate';
import 'dart:convert';

// Isolate入口函数
void uploadIsolate(SendPort sendPort) async {
  final receivePort = ReceivePort();
  sendPort.send(receivePort.sendPort);

  receivePort.listen((message) async {
    if (message is List) {
      String filePath = message[0];
      int chunkSize = message[1];
      String uploadUrl = message[2];
      
      File file = File(filePath);
      List<int> bytes = await file.readAsBytes();
      
      int totalChunks = (bytes.length / chunkSize).ceil();
      for (int i = 0; i < totalChunks; i++) {
        int start = i * chunkSize;
        int end = (i + 1) * chunkSize;
        if (end > bytes.length) end = bytes.length;
        
        List<int> chunk = bytes.sublist(start, end);
        
        // 上传分片
        var request = await HttpClient().postUrl(Uri.parse(uploadUrl));
        request.headers.set('Content-Type', 'application/octet-stream');
        request.headers.set('chunk-index', i.toString());
        request.add(chunk);
        var response = await request.close();
        
        if (response.statusCode != 200) {
          sendPort.send('Upload failed for chunk $i');
          return;
        }
      }
      sendPort.send('Upload complete');
    }
  });
}

// 启动Isolate并上传文件
void startFileUpload(String filePath, int chunkSize, String uploadUrl) async {
  ReceivePort receivePort = ReceivePort();
  Isolate isolate = await Isolate.spawn(uploadIsolate, receivePort.sendPort);
  
  receivePort.listen((message) {
    print(message); // 处理上传结果
    if (message == 'Upload complete') {
      receivePort.close();
      isolate.kill();
    }
  });
  
  // 发送文件信息到Isolate
  SendPort? sendPort = await receivePort.first;
  sendPort.send([filePath, chunkSize, uploadUrl]);
}

// 使用示例
void main() {
  startFileUpload('/path/to/file.txt', 1024 * 1024, 'https://api.example.com/upload');
}

说明：

  • 分片大小：根据需求调整chunkSize（例如1MB）。
  • 服务端：需支持分片上传，接收chunk-index头并存储分片，最后合并。
  • 错误处理：可扩展为支持重试、进度回调等。

此方法利用Isolate在后台处理上传，保持UI流畅。

回到顶部