前端性能优化之控制请求并发数

  • 前端性能优化之控制请求并发数已关闭评论
  • 15 次浏览
  • A+
所属分类:Web前端
摘要

  在我们平时开发中,经常会遇到页面数据初始化时,频繁调同一个接口的情况。比如echarts项目中,一个页面可能会有几十张图表,如果一个接口返回所有图表数据的话,会造成用户过长的等待时间,再者过多图表同时渲染,也会给页面增加压力,造成卡顿的现象。

  在我们平时开发中,经常会遇到页面数据初始化时,频繁调同一个接口的情况。比如echarts项目中,一个页面可能会有几十张图表,如果一个接口返回所有图表数据的话,会造成用户过长的等待时间,再者过多图表同时渲染,也会给页面增加压力,造成卡顿的现象。

  我们通常会让每个图表单独调一个接口,入参不同,这样更有利于页面快速渲染图表,单个图表请求到数据,立即渲染,不需要等待其他图表。可理想很丰满,现实很骨感,当服务器配置过低,或者后端代码性能较弱,会难以处理这些并发请求,接口调用越多,等待处理的时间可能就越长,甚至超过一次性返回所有数据的间。。。为了解决这种问题,缓解后端压力,本篇将介绍前端来控制请求的并发数:

  先分析一波,假设我们需要重复调用30次接口,并联调用接口,服务端压力较大,可能会造成响应时间过长。逐渐减少并发数,假设并发数为5的时候,服务器处理速度最快,几乎不受并发影响。

  针对这种情况,我们可以封装接口请求方法,控制每次接口请求的并发数,将30次分解成:并发数为5,分6次请求。这样的话,服务器每次处理5次请求,资源释放出来继续处理下一批请求,从而解决并发拥堵问题~

初步构思:

class TaskQueue {   constructor(max) {     this.max = max;     this.taskList = [];   }    addTask(task) {     this.taskList.push(task);   } }  function createTask(i) {   return () => {     return new Promise((resolve, reject) => {       setTimeout(() => {         if (i == 4 || i == 15) {           reject("出错啦~");         } else {           resolve("成功呀~" + i);         }       }, 2000);     });   }; }  const taskQueue = new TaskQueue(5);  for (let i = 0; i < 30; i++) {   const task = createTask(i);   taskQueue.addTask(task); }

for循环调用函数createTask()返回30个promise的异步任务,任务队列TaskQueue类返回一个实例,控制这30个异步任务的并发,构造器中传入并发数5。
接下来用TaskQueue实现控制并发:
class TaskQueue {   constructor(max) {     this.max = max; // 并发数     this.min = 0;     this.taskList = []; // 全部任务     Promise.resolve().then(() => this.run()) // 等同步代码(addTask)全部执行完成,再执行run   }    // 增加任务   addTask(task) {     this.taskList.push(task);   }    // 执行任务   async run() {     if (!this.taskList.length) return;     const AsyncTasks = [];     this.min = Math.min(this.max, this.taskList.length) // 当传入的并发数大于任务数,取任务数, 反之取并发数     // 根据并发数分组     for(let i = 0; i < this.min; i++) {        AsyncTasks.push(this.taskList.shift());     }     await this.handleTask(AsyncTasks); // 通过下面递归,这里将会有6个异步任务串联执行      this.run(); // 递归   }    async handleTask(tasks) {     // 返回promise处理异步任务组     return new Promise(resolve => {       // 遍历任务组,5个异步任务并联执行       tasks.forEach(async (task, index) => {         await task().then(res => {           console.log(res);         }).catch((err) => {           console.log(err);         }).finally(() => {           index + 1 === this.min && console.log('===============================');           index + 1 === this.min && resolve() // 最后一个任务resolve(),promise完成         })       })     })   } }  function createTask(i) {   return () => {     return new Promise((resolve, reject) => {       setTimeout(() => {         if (i == 4 || i == 15) {  // 测试捕捉错误           reject("出错啦~");         } else {           resolve("成功呀~" + i);         }       }, 2000);     });   }; }  const taskQueue = new TaskQueue(5);  for (let i = 0; i < 30; i++) {   const task = createTask(i);   taskQueue.addTask(task); }

试试效果:

前端性能优化之控制请求并发数

 

 nice,至此,30次异步任务,分6次完成,每次处理5个,大家可以在此基础上拓展请求接口,并增加一些处理逻辑,欢迎留言探讨~

 

脚踏实地行,海阔天空飞~

 

搜索

复制