js异步接口并发数量控制的方法示例
请实现如下的函数（发请求的函数可以直接使用fetch）
- 可以批量请求数据，所有的URL地址在urls参数中
- 同时可以通过max参数控制请求的并发度
- 当所有的请求结束后，需要执行callback回调
functionsendRequest(urls:string[],max:number,callback:()=>void){}
fetch函数返回的是一个promise，promise对象在实例化的时候就已经开始执行了。
简易实现
functionfetch(url){
//模拟接口请求
returnnewPromise(resolve=>{
setTimeout(()=>{
resolve(url)
},10000*Math.random())
})
}
/**
*接口请求最大并发量控制
*@param{Array}urls接口请求地址数组集合
*@param{Number}max最大并发量
*@param{Function}callback回调函数
*/
functionmaxRequestLimit(urls,max,callback){
//如果没有传入urls或max则不继续执行
if(!urls||!max)return
//当请求地址数组集合长度为0，则执行回调函数（如果有的话），并结束后续执行
if(urls.length===0){
if(callback)callback()
return
}
//使用splice方法返回当前要使用的请求集合，同时删除原有的请求集合
constonceMaxUrlArr=urls.splice(0,max)
//进行map转换，将url参数转换为promise
constonceMaxFetchArr=onceMaxUrlArr.map(url=>fetch(url))
//使用当前这一队列
Promise.all(onceMaxFetchArr)
.then(res=>{
console.log(res)
//递归请求
maxRequestLimit(urls,max,callback)
})
}
maxRequestLimit(['url1','url2','url3','url4','url5','url6','url7','url8'],3,()=>{console.log('fetchend')})
上面的简易实现是一个队列一个队列进行请求，实际运行效果会存在一定的阻塞，下面通过进一步改善来提高请求的效率
完善实现
functionfetch(url){
//模拟接口请求
returnnewPromise(resolve=>{
setTimeout(()=>{
resolve(url)
},10000*Math.random())
})
}
/**
*接口请求最大并发量控制
*@param{Array}urls接口请求地址数组集合
*@param{Number}max最大并发量
*@param{Function}callback回调函数
*/
functionmaxRequestLimit(arr,max,callback){
//如果没有传入urls或max则不继续执行
if(!arr||!max)return
//当请求地址数组集合长度为0，则执行回调函数（如果有的话），并结束后续执行
if(arr.length===0){
if(callback)callback()
return
}
letfetchArr=[],//存储并发max的promise数组
i=0;
functiontoFetch(){
//所有的请求都受理，则返回一个resolve
if(i===arr.length)returnPromise.resolve()
//取出第i个url，放入fetch里面,每取一次i++
letone=fetch(arr[i++])
//将当前的promise存入并发数组中
fetchArr.push(one)
//当promise执行完毕后，从数组删除
one.then(res=>{
console.log(res)
fetchArr.splice(fetchArr.indexOf(one),1)
})
letp=Promise.resolve()
//当并行数量达到最大后，用race比较第一个完成的，然后再调用一下函数自身。
if(fetchArr.length>=max)p=Promise.race(fetchArr)
returnp.then(()=>toFetch())
}
//arr循环完后，现在fetchArr里面剩下的promise对象，使用all等待所有的都完成之后执行callback
toFetch()
.then(()=>Promise.all(fetchArr))
.then(()=>callback())
}
maxRequestLimit(['url1','url2','url3','url4','url5','url6','url7','url8'],3,()=>{console.log('fetchend')})
总结
到此这篇关于js异步接口并发数量控制的文章就介绍到这了,更多相关js异步接口并发数量控制内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。