这里思考比较少,不过因为事情本身比较简单,就简单处理了。毕竟我这种菜鸟,高大上的东西是从未停止过仰望的。备注下是因为如果有机会再用到类似的逻辑,可以拿来重新思考一下,另外,我还觉得有点儿TCP里”滑动窗口“的感觉喔,哈哈哈,毕竟场景类似,控制流量嘛
/**
* 代码块说明: 小并发串行调用接口处理大批量数据
* 依赖变量: data (原始数据)
*/
var chunks = [], // 数据切割存储
size = 50, // 数据分片大小
concurrence = 4; // 并发量
/* 按数据分片大小切割原始数据 */
while (data.length > 0){
chunks.push(data.splice(0, size));
}
var batchLength = chunks.length; // 切割后数据块数量
var steps = 0; // 游标,用于滑动读取切割后的数据块
/**
* 核心函数
* 变量说明: _i (游标, 用于定位分片数据)
* cData (切割后的数据块数组)
* len (切割后数据块数量)
* c (发送请求的并发量)
*/
var batchPush = function(_i, cData, len, c){
if (_i < len) {
var _pulling = true; // 标识位
var _j = 0; // 临时变量,定位并发数据块位置
//分批请求
while (_pulling){
if (cData[_j + _i]){
$.ajax({
method: 'POST',
url: 'xxx',
data: JSON.stringify(cData[_j + _i]),
dataType: 'json',
success: function(rData){
// 接口返回码校验(此略)
++steps;
// 并发都处理完后, 触发下一次并发(串行)
if (steps % c === 0) {
// 缓冲一秒
setTimeout(function(){
batchPush(steps, cData, len, c);
}, 1000);
}
// 数据处理(此略)
},
error: function(){
// 异常处理(此略)
}
});
}
_j++;
if (_j >= c){
_pulling = false;
}
}
} else {
// 全部发送完毕
steps = 0;
}
};
// 触发调用
batchPush(steps, chunks, batchLength, concurrence);
Anyway, it works. 有机会读一读”滑动窗口”的处理逻辑, 哈哈.