并发串行调用接口

简介: 这里思考比较少,不过因为事情本身比较简单,就简单处理了。毕竟我这种菜鸟,高大上的东西是从未停止过仰望的。备注下是因为如果有机会再用到类似的逻辑,可以拿来重新思考一下,另外,我还觉得有点儿TCP里”滑动窗口“的感觉喔,哈哈哈,毕竟场景类似,控制流量嘛/** * 代码块说明: 小并发串行调用接口处理大批量数据 * 依赖变量: data (原始数据) */va

这里思考比较少,不过因为事情本身比较简单,就简单处理了。毕竟我这种菜鸟,高大上的东西是从未停止过仰望的。备注下是因为如果有机会再用到类似的逻辑,可以拿来重新思考一下,另外,我还觉得有点儿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. 有机会读一读”滑动窗口”的处理逻辑, 哈哈.

目录
相关文章
|
3月前
|
缓存 前端开发 Java
反射加缓存,解决不同的业务下调用不同的实现
反射加缓存,解决不同的业务下调用不同的实现
34 0
使用队列解决高并发下使用Client对象调用webService接口
使用队列解决高并发下使用Client对象调用webService接口
通过普通方式调用和反射方式调用以及关闭检测后,通过反射方式调用的性能对比
通过普通方式调用和反射方式调用以及关闭检测后,通过反射方式调用的性能对比
同步调用和异步调用
同步调用和异步调用
创建多线程的方式三:实现Callable接口。
创建多线程的方式三:实现Callable接口。
67 0
创建多线程的方式二:实现Runnable接口
创建多线程的方式二:实现Runnable接口
61 0
|
程序员 Scala 开发者
函数(方法)的调用机制|学习笔记
快速学习函数(方法)的调用机制。
函数(方法)的调用机制|学习笔记
|
Java
CheerpJ调用的两种方式
CheerpJ调用的两种方式
248 0
|
Java 测试技术
Java 线程池模拟用户并发请求接口代码示例
Java 线程池模拟用户并发请求接口代码示例
|
小程序
小程序调用接口不生效?
小程序调用接口不生效?
357 0