前端如何控制并发请求举例详解

更新时间：2024年09月01日 14:42:05 作者：JackChouMine

在项目中我们会遇到一次请求多个接口,当所有请求结束后进行操作,也会遇到多个请求（大量）同时进行请求资源,这篇文章主要给大家介绍了关于前端如何控制并发请求举例的相关资料,需要的朋友可以参考下

前言

什么情况需要前端控制并发请求，在需要多次才能请求完所需数据的时候。比如接口一次返回，数据很多，让浏览器渲染卡顿甚至崩溃，这时候我们可以分批同时发出6个请求，这样就可以避免卡顿或者崩溃。

那么前端如何控制并发请求呢？

前端控制并发请求的关键思路

比如有 20 个请求，需要按照 3 个一组，第一组请求完毕后再请求第二组，以此类推。

关键思路，把请求方法和请求参数使用一个数组存起来，然后每次请求3个，请求完毕后再请求下一个3个。每组请求返回后，把结果保存起来，等所有请求都返回后，再把所有结果返回。

api 设计

pControl : 并发请求控制器, 传递最大并发数;
add : 添加请求和参数;
start : 开始请求，返回promise, 请求完毕后通过 .then 获取所有结果;

代码实现

function pControl(limit) {
  const taskQueue = [] // {task: Function, params: any[]}[]
  return {
    add,
    start
  }

  function add(task, params) {
    taskQueue.push({
      task,
      params
    })
  }

  function start() {
    return runAllTasks()
  }

  function runAllTasks() {
    const allResults = []
    return new Promise((resolve) => {

      runTask()

      function runTask() {
        if (taskQueue.length === 0) {
          // 递归结束
          return resolve(allResults)
        }
        const needRunSize = Math.min(taskQueue.length, limit)
        const tasks = taskQueue.splice(0, needRunSize)
        const promises = tasks.map(({
          task,
          params
        }) => task(params))
        Promise.all(promises).then((resList) => {
          allResults.push(...resList)
          // NOTE 递归调用的位置很关键
          runTask()
        })
      }
    })
  }
}

关键代码解读

pControl: 这个函数返回一个对象，包含 add 和 start 两个方法，add 用来添加任务和参数，start 用来开始请求，是一个闭包。
runAllTasks: 返回一个promise，然后在new Promise内部递归地执行runTask, runTask 通过Promise.all 执行并发请求，在Promise.all().then() 再次调用runTask，实现一组请求返回，再执行第二组请求。

实现分组等待的关键是在 .then 中递归调用。

思考： runAllTasks 可以使用循环实现吗？

能，需要使用 async 和 for 循环 + await ：

async function runAllTasks2() {
  const allResults = []
  const groupArr = []
  let startIndex = 0
  // 划分分组
  while (startIndex < taskQueue.length) {
    const arr = taskQueue.slice(startIndex, startIndex + limit)
    groupArr.push(arr)
    startIndex += limit
  }
  for (let index = 0; index < groupArr.length; index++) {
    const pList = groupArr[index].map(({
      task,
      params
    }) => task(params))
    const res = await Promise.all(pList)
    allResults.push(...res)
  }
  return allResults
}

在 for 中循环中不能使用 .then ，否则下一次循环不会等待上一次循环。

使用 for of 迭代实现：

async function runAllTasks2() {
  const allResults = []
  const groupArr = []
  let startIndex = 0
  // 划分分组
  while (startIndex < taskQueue.length) {
    const arr = taskQueue.slice(startIndex, startIndex + limit)
    groupArr.push(arr)
    startIndex += limit
  }
  // 迭代分组
  const it = groupArr.entries()
  for (const [key, value] of it) {
    const pList = value.map(({
      task,
      params
    }) => task(params))
    const res = await Promise.all(pList)
    allResults.push(...res)
  }
  return allResults
}

循环和 Promise 结合是怎样使用的呢？

for 、 while 、 for...of 等命令式循环结构，想要在循环中实现等待效果，必须使用 async 函数包裹循环中的 await ，不能使用 .then 。

forEach 、 map 、 filter 等函数式循环结构，不支持等待效果，因为这些函数式循环结构是同步的，不支持等待。

async 和 循环 + await 结合，实现循环之间等待效果。

promise.then 和 递归 结合，实现循环之间等待效果。

完善 api，让其更加易用

设置默认参数：给pControl设置一个合适的默认值，设置为6，因为同一个域名在，浏览器的并发请求是 6 个。
start给回调：通过回调能拿到每个分组的请求结果和知道当前完成的请求数量。

这两个改进很简单。先看用法：

const asyncTaskControl = pControl() // 默认 6 
asyncTaskControl.add(task, params1)
asyncTaskControl.add(task, params2)
// ...
asyncTaskControl.add(task, params10)

asyncTaskControl.start((res, doneSize) => {
  // 获取每组请求的结果 和当前完成了多少请求
  console.log(res) // [{index:number,result:data}] 
  console.log(doneSize)
}).then(allResults => {
  // 所有请求结果
  console.log(allResults)
})

start 回调有什么作用呢？

方便使用者拿当前并发请求的结果，方便计算完成进度。

把上述功能封装成 p-control npm 包发布

npm: p-control

可通过 npm i p-control 下载使用。

小结

.then 和递归结合，实现异步任务之间等待；
for、while等循环和async + await结合使用，实现异步任务之间等待；
使用Promise.all实现多个异步任务并发执行。

到此这篇关于前端如何控制并发请求的文章就介绍到这了,更多相关前端控制并发请求内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

JS前端并发多个相同的请求控制为只发一个请求方式

JS中循环遍历数组的四种方式总结
这篇文章主要给大家总结介绍了关于JS中循环遍历数组的四种方式，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-01-01
使用Sticky组件实现带sticky效果的tab导航和滚动导航的方法
sticky组件，通常应用于导航条或者工具栏，当网页在某一区域滚动的时候，将导航条或工具栏这类元素固定在页面顶部或底部，方便用户快速进行这类元素提供的操作
2016-03-03
js+ajax实现的A*游戏路径算法整理
js+ajax实现的A*游戏路径算法整理...
2007-05-05
JavaScript制作简易计算器（不用eval）
这篇文章主要为大家详细介绍了JavaScript制作简易计算器的相关资料，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-02-02
浅析JS运动
这篇文章主要介绍了JS运动的实现原理，介绍了JS多种运动方式，希望大家仔细学习，感兴趣的小伙伴们可以参考一下
2015-12-12
js 右下角弹窗效果代码(IE only)
js 右下角弹窗效果代码,虽然IE only，但这个代码的逻辑可以参考下。了解下IE与firefox的区别，自己写个兼容的版本吧。
2010-06-06
uniapp实现注册发送获取验证码功能
随着网络的发达,总会有人恶意注册网站,而使用输入验证码功能可以有效的阻止这一类现象的发生,下面这篇文章主要给大家介绍了关于uniapp实现注册发送获取验证码功能的相关资料,需要的朋友可以参考下
2022-11-11
利用JS将图标字体渲染为图片的方法详解
在软件开发中肯定要用到图标，比如下图的 Groove 音乐中就用到了许多图标。一种获取这些图标的方法是把 Groove 音乐截个图，然后熟练地开启 Photoshop，开始抠图。这种方式很逊，效率也很低。本文将利用JS将图标字体渲染为图片，需要的可以参考一下
2022-05-05
JavaScript中window.showModalDialog()用法详解
这篇文章主要介绍了JavaScript中window.showModalDialog()用法详解,需要的朋友可以参考下
2014-12-12
replace()方法查找字符使用示例
查找字符的情况下会使用replace()方法，此方法很常见也很实用，下面有个不错的示例，感兴趣的朋友可以参考下，希望对大家有所把帮助
2013-10-10