Flutter Web 多部分表单数据文件上传进度条

如何解决Flutter Web 多部分表单数据文件上传进度条

我使用 Flutter web 和 Strapi headless cms 作为后端。我能够成功发送文件,但想要它的进度指示。后端限制:文件上传必须是多部分表单数据,无论是缓冲区还是流。前端限制:Flutter web 无权访问系统文件目录;文件必须加载到内存中并使用其字节发送。

我可以使用 flutter 的 http 包或 Dio 包上传文件,但是在尝试以某种方式访问​​上传进度时遇到以下问题:

Http 示例代码:

http.StreamedResponse response;

final uri = Uri.parse(url);
final request = MultipartRequest(
  'POST',uri,);
request.headers['authorization'] = 'Bearer $_token';
request.files.add(http.MultipartFile.fromBytes(
  'files',_fileToUpload.bytes,filename: _fileToUpload.name,));

response = await request.send();

var resStream = await response.stream.bytesToString();
var resData = json.decode(resStream);

我的尝试: 当访问 onData 的 response.stream 时,它仅在服务器发送完成的请求时响应(即使方法声明它应该获得一些进度指示)。

Dio 封装代码

Response response = await dio.post(url,data: formData,options: Options(
      headers: {
        'authorization': 'Bearer $_token',},),onSendProgress: (int sent,int total) {
  setState(() {
    pm.progress = (sent / total) * 100;
  });

问题:

似乎该包能够获得一些进度指示,但是用于 Flutter web 的 Dio 包有一个尚未修复的错误:请求会阻止 ui,并且应用程序在上传完成之前会冻结。

解决方法

您好,可以使用universal_html/html.dart包来做进度条,步骤如下:

  1. 导入通用包
import 'package:universal_html/html.dart' as html;
  1. 从 html 输入元素中选择文件,而不是使用文件选择器包
 _selectFile() {
    html.FileUploadInputElement uploadInput = html.FileUploadInputElement();
    uploadInput.multiple = false;
    uploadInput.accept = '.png,.jpg,.glb';
    uploadInput.click();

    uploadInput.onChange.listen((e) {
      _file = uploadInput.files.first;
    });
 }
  1. 将upload_worker.js创建到web文件夹中,我的例子是上传到S3 post presigned url
self.addEventListener('message',async (event) => {
    var file = event.data.file;
    var url = event.data.url;
    var postData = event.data.postData;
    uploadFile(file,url,postData);
});

function uploadFile(file,presignedPostData) {

    var xhr = new XMLHttpRequest();
    var formData = new FormData();

    Object.keys(presignedPostData).forEach((key) => {
        formData.append(key,presignedPostData[key]);
    });
    formData.append('Content-Type',file.type);
    // var uploadPercent;
    formData.append('file',file);

    xhr.upload.addEventListener("progress",function (e) {
        if (e.lengthComputable) {
            console.log(e.loaded + "/" + e.total);
            // pass progress bar status to flutter widget
            postMessage(e.loaded/e.total);
        }
    });

    xhr.onreadystatechange = function () {
        if (xhr.readyState == XMLHttpRequest.DONE) {
            // postMessage("done");
        }
    }
    xhr.onerror = function () {
        console.log('Request failed');
        // only triggers if the request couldn't be made at all
        // postMessage("Request failed");
    };

    xhr.open('POST',true);
    xhr.send(formData);
}
  1. Flutter web call upload worker 上传和监听进度条状态
class Upload extends StatefulWidget {
  @override
  _UploadState createState() => _UploadState();
}

class _UploadState extends State<Upload> {
  html.Worker myWorker;
  html.File file;

  _uploadFile() async {
    String _uri = "/upload";
    final postData = {};

    myWorker.postMessage({"file": file,"uri": _uri,postData: postData});
  }

  _selectFile() {
    html.InputElement uploadInput = html.FileUploadInputElement();
    uploadInput.multiple = false;
    uploadInput.click();

    uploadInput.onChange.listen((e) {
      file = uploadInput.files.first;
    });
  }

  @override
  void initState() {
    myWorker = new html.Worker('upload_worker.js');
    myWorker.onMessage.listen((e) {
      setState(() {
        //progressbar,...
      });
    });

    super.initState();
  }

  @override
  Widget build(BuildContext context) {
    return Column(
      children: [
        RaisedButton(
          onPressed: _selectFile,child: Text("Select File"),),RaisedButton(
          onPressed: _uploadFile,child: Text("Upload"),],);
  }
}

就是这样,希望能帮到你。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


依赖报错 idea导入项目后依赖报错,解决方案:https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错:更换其他版本 无法下载依赖可参考:https://blog.csdn.net/weixin_42628809/a
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
错误1:gradle项目控制台输出为乱码 # 解决方案:https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
错误还原:在查询的过程中,传入的workType为0时,该条件不起作用 &lt;select id=&quot;xxx&quot;&gt; SELECT di.id, di.name, di.work_type, di.updated... &lt;where&gt; &lt;if test=&qu
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
解决方案1 1、改项目中.idea/workspace.xml配置文件,增加dynamic.classpath参数 2、搜索PropertiesComponent,添加如下 &lt;property name=&quot;dynamic.classpath&quot; value=&quot;tru
删除根组件app.vue中的默认代码后报错:Module Error (from ./node_modules/eslint-loader/index.js): 解决方案:关闭ESlint代码检测,在项目根目录创建vue.config.js,在文件中添加 module.exports = { lin
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-