您好,登錄后才能下訂單哦!
本篇文章為大家展示了如何控制JavaScript中異步接口的并發(fā)數(shù)量,內(nèi)容簡(jiǎn)明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。
可以批量請(qǐng)求數(shù)據(jù),所有的URL地址在urls參數(shù)中
function sendRequest (urls: string[], max: number, callback: () => void) {}
fetch 函數(shù)返回的是一個(gè)promise,promise對(duì)象在實(shí)例化的時(shí)候就已經(jīng)開(kāi)始執(zhí)行了。
簡(jiǎn)易實(shí)現(xiàn)
function fetch(url) { // 模擬接口請(qǐng)求 return new Promise(resolve => { setTimeout(() => { resolve(url) }, 10000*Math.random()) }) } /** * 接口請(qǐng)求最大并發(fā)量控制 * @param { Array } urls 接口請(qǐng)求地址數(shù)組集合 * @param { Number } max 最大并發(fā)量 * @param { Function } callback 回調(diào)函數(shù) */ function maxRequestLimit(urls, max, callback) { // 如果沒(méi)有傳入urls或max則不繼續(xù)執(zhí)行 if (!urls || !max) return // 當(dāng)請(qǐng)求地址數(shù)組集合長(zhǎng)度為0,則執(zhí)行回調(diào)函數(shù)(如果有的話),并結(jié)束后續(xù)執(zhí)行 if(urls.length === 0) { if(callback) callback() return } // 使用splice方法返回當(dāng)前要使用的請(qǐng)求集合,同時(shí)刪除原有的請(qǐng)求集合 const onceMaxUrlArr = urls.splice(0, max) // 進(jìn)行map轉(zhuǎn)換,將url參數(shù)轉(zhuǎn)換為promise const onceMaxFetchArr = onceMaxUrlArr.map(url => fetch(url)) // 使用當(dāng)前這一隊(duì)列 Promise.all(onceMaxFetchArr) .then(res => { console.log(res) // 遞歸請(qǐng)求 maxRequestLimit(urls, max, callback) }) } maxRequestLimit(['url1', 'url2', 'url3', 'url4', 'url5', 'url6', 'url7', 'url8'], 3, () => {console.log('fetch end')})
上面的簡(jiǎn)易實(shí)現(xiàn)是一個(gè)隊(duì)列一個(gè)隊(duì)列進(jìn)行請(qǐng)求,實(shí)際運(yùn)行效果會(huì)存在一定的阻塞,下面通過(guò)進(jìn)一步改善來(lái)提高請(qǐng)求的效率
完善實(shí)現(xiàn)
function fetch(url) { // 模擬接口請(qǐng)求 return new Promise(resolve => { setTimeout(() => { resolve(url) }, 10000 * Math.random()) }) } /** * 接口請(qǐng)求最大并發(fā)量控制 * @param { Array } urls 接口請(qǐng)求地址數(shù)組集合 * @param { Number } max 最大并發(fā)量 * @param { Function } callback 回調(diào)函數(shù) */ function maxRequestLimit(arr, max, callback) { // 如果沒(méi)有傳入urls或max則不繼續(xù)執(zhí)行 if (!arr || !max) return // 當(dāng)請(qǐng)求地址數(shù)組集合長(zhǎng)度為0,則執(zhí)行回調(diào)函數(shù)(如果有的話),并結(jié)束后續(xù)執(zhí)行 if(arr.length === 0) { if(callback) callback() return } let fetchArr = [], // 存儲(chǔ)并發(fā)max的promise數(shù)組 i = 0; function toFetch() { // 所有的請(qǐng)求都受理,則返回一個(gè)resolve if (i === arr.length) return Promise.resolve() // 取出第i個(gè)url, 放入fetch里面 , 每取一次i++ let one = fetch(arr[i++]) //將當(dāng)前的promise存入并發(fā)數(shù)組中 fetchArr.push(one) // 當(dāng)promise執(zhí)行完畢后,從數(shù)組刪除 one.then(res => { console.log(res) fetchArr.splice(fetchArr.indexOf(one), 1) }) let p = Promise.resolve() // 當(dāng)并行數(shù)量達(dá)到最大后, 用race比較 第一個(gè)完成的, 然后再調(diào)用一下函數(shù)自身。 if (fetchArr.length >= max) p = Promise.race(fetchArr) return p.then(() => toFetch()) } // arr循環(huán)完后, 現(xiàn)在fetchArr里面剩下的promise對(duì)象, 使用all等待所有的都完成之后執(zhí)行callback toFetch() .then(() => Promise.all(fetchArr)) .then(() => callback()) } maxRequestLimit(['url1', 'url2', 'url3', 'url4', 'url5', 'url6', 'url7', 'url8'], 3, () => { console.log('fetch end') })
上述內(nèi)容就是如何控制JavaScript中異步接口的并發(fā)數(shù)量,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。