脱离redis, 基于内存, 批量上传文件到远程服务器,按照设置大小设置每次请求的包的大小和并发数量限制
8ab6b2e: 这是版本V 0.2.0 该本版支持调用者实现上传逻辑和接收回调
初始化任务队列
Upload.init({
base_url: 'http://127.0.0.1:3008/', // 远程目标服务器地址
check_path: 'check_file', // 文件校验接口
upload_path: 'file', // 上传接口
});
添加任务
var file_arr = [ 'D:/files/a.test', 'D:/files/b.test' ];
Upload.createJob(file_arr);
执行任务
Upload.process(upload, callback); //about upload and callback detail please Reference ./test demo
查询当前任务状态
const status = await Upload.status();
console.log(status);
[
{
"ext": ".png",
"contentType": "image/png"
},
{
"ext": ".jpeg",
"contentType": "image/jpeg"
},
{
"ext": "jpg",
"contentType": "image/jpeg"
},
{
"ext": ".txt",
"contentType": "text/plain"
}
]
第三方库:bagpipe 需要修改源码./lib/bagpipe.js 148行为:method.apply(this, args);