国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

詳解JS前端并發多個相同的請求控制為只發一個請求方式

3403771864 / 1108人閱讀

  描述如下

  我們要同時發多個相同的請求,第一個請求成功后,剩余結果都不會發出,返回結果是成果。

  假如第一個反饋失敗,第二個是成功,后面就不會發出,后面都直接反饋成功。第三個才是成功的話,后面就不會在發出,后面都反饋成功。依次如此處理,直至最后一個?! ?/p>

  并發: 一個接口請求還處于pending,短時間內就發送相同的請求

 

 async function fetchData (a) {
  const data = await fetch('//127.0.0.1:3000/test')
  const d = await data.json();
  console.log(d);
  return d;
  }
  fetchData(2) // 編號 1
  fetchData(2) // 2
  fetchData(2) // 3
  fetchData(2) // 4
  fetchData(2) // 4
  fetchData(2) // 5
  fetchData(2)
  fetchData(2)

  老版本cachedAsync

  之前講過vue的緩存函數緩存成功的請求, 實現是這樣的?,F在來說說cachedAsync只會緩存成功的請求,但假如失敗了,只有直接拉起新的請求。但是如果是上面的并發場景,相同的請求因為無法命中緩存,會出現連續發送三個請求的問題,無法處理這種并發的場景。

 

 const cachedAsync = function(fn) {
  const cache = Object.create(null);
  return async str => {
  const hit = cache[str];
  if (hit) {
  return hit;
  }
  // 只緩存成功的Promise, 失敗直接重新請求
  return (cache[str] = await fn(str));
  };
  };
  const fetch2 = cachedAsync(fetchData)
  fetch2(2);
  fetch2(2);
  fetch2(2);

  進階版本

  我們要知道緩存是必須的,因此我們只要處理怎么控制并發即可。這一個解決思路。

  每個請求都返回一個新的Promise, Promise的exector的執行時機,通過一個隊列保存。

  當隊列長度為1的時候,執行一次請求,如果請求成功,那么遍歷隊列中的exector,拿到請求的結果然后resolve。

  如果請求失敗了,那么就把這個Promise reject掉,同時出棧。然后遞歸調用next

  直到exector隊列清空為止

  const cacheAsync = (promiseGenerator, symbol) => {
  const cache = new Map();
  const never = Symbol();
  return async (params) => {
  return new Promise((resolve, reject) => {
  // 可以提供鍵值
  symbol = symbol || params;
  let cacheCfg = cache.get(symbol);
  if (!cacheCfg) {
  cacheCfg = {
  hit: never,
  exector: [{ resolve, reject }],
  };
  cache.set(symbol, cacheCfg);
  } else {
  // 命中緩存
  if (cacheCfg.hit !== never) {
  return resolve(cacheCfg.hit)
  }
  cacheCfg.exector.push({ resolve, reject });
  }
  const { exector } = cacheCfg;
  // 處理并發,在請求還處于pending過程中就發起了相同的請求
  // 拿第一個請求
  if (exector.length === 1) {
  const next = async () => {
  try {
  if (!exector.length) return;
  const response = await promiseGenerator(params);
  // 如果成功了,那么直接resolve掉剩余同樣的請求
  while (exector.length) { // 清空
  exector.shift().resolve(response);
  }
  // 緩存結果
  cacheCfg.hit = response;
  } catch (error) {
  // 如果失敗了 那么這個promise的則為reject
  const { reject } = exector.shift();
  reject(error);
  next(); // 失敗重試,降級為串行
  }
  };
  next();
  }
  });
  };
  };

  測試cacheAsync

  現在需要測試的場景,測試請求接口隨機出現成功或者失敗,假如成功預期結果,剩余的請求都不會發出,這樣失敗重試,接著發下一個請求。

  現在我們先快速搭建一個服務器


  const koa = require("koa");
  const app = new koa();
  function sleep(seconds) {
  return new Promise((resolve, reject) => {
  setTimeout(resolve, seconds);
  });
  }
  app.use(async (ctx, next) => {
  if (ctx.url === "/test") {
  await sleep(200);
  const n = Math.random();
  // 隨機掛掉接口
  if (n > 0.8) {
  ctx.body = n;
  } else {
  ctx.status = 404
  ctx.body = ''
  }
  next();
  }
  });
  app.listen(3000, "127.0.0.1", () =>
  console.log("listening on 127.0.0.1:3000")
  );

  客戶端


 

 var fetch2 = cacheAsync(fetchData, "test2");
  async function fetchData(a) {
  const data = await fetch("//127.0.0.1:3000/test");
  const d = await data.json();
  console.log(d);
  return d;
  }
  // 并發6個相同的請求
  console.log(fetch2(2));
  console.log(fetch2(2));
  console.log(fetch2(2));
  console.log(fetch2(2));
  console.log(fetch2(2));
  console.log(fetch2(2));

  看下測試結果,刷新下頁面

  第一次運氣很好,第一次接口就請求成功,只發送了一個請求

1.png

  第二次測試運氣不好,最后一個請求才成功,也是最差的場景

2.png

  第三次測試,請求第三次成功了

3.png

  測試下緩存在控制臺主動請求fetch2,成功命中。

4.png

  上面表示從測試結果來看是正確的,符合了并發和緩存的場景。但是為什么要緩存接口。簡單來說就是,當輸入關鍵字搜索,監聽的是input事件,在你增刪關鍵字的時候,就會出現請求參數一樣的情況,因此就符合防抖+前端接口緩存的方式。遇到相同關鍵字直接拉之前的緩存。

  提示

  這個緩存因為是閉包的方式,因此刷新頁面緩存也失效了。不過我認為這個是理應如此,因為大部分場景刷新頁面,就是要重置狀態,如果要持久化,還不如保存到本地存儲。

  github-demo

  歡迎大家繼續關注后續更多精彩內容。


文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/128013.html

相關文章

  • 可能是最漂亮Spring事務管理詳解

    摘要:事務隔離級別定義了一個事務可能受其他并發事務影響的程度我們先來看一下并發事務帶來的問題,然后再來介紹一下接口中定義了五個表示隔離級別的常量。 Java面試通關手冊(Java學習指南):https://github.com/Snailclimb/Java_Guide 微信閱讀地址鏈接:可能是最漂亮的Spring事務管理詳解 事務概念回顧 什么是事務? 事務是邏輯上的一組操作,要么都執行,...

    鄒立鵬 評論0 收藏0
  • 前端基本功-常見概念(一)

    摘要:前端基本功常見概念一點這里前端基本功常見概念二點這里前端基本功常見概念三點這里什么是原型鏈當一個引用類型繼承另一個引用類型的屬性和方法時候就會產生一個原型鏈。函數式編程是聲明式而不是命令式,并且應用程序狀態通過純函數流轉。 前端基本功-常見概念(一) 點這里前端基本功-常見概念(二) 點這里前端基本功-常見概念(三) 點這里 1.什么是原型鏈 當一個引用類型繼承另一個引用類型的屬性和方...

    bladefury 評論0 收藏0
  • 瀏覽器詳解

    摘要:渲染引擎也稱為呈現引擎瀏覽器內核,負責顯示請求的內容。引擎是基于事件驅動單線程執行的,引擎一直等待著任務隊列中任務的到來,然后加以處理,瀏覽器無論什么時候都只有一個線程在運行程序。 1 瀏覽器結構 showImg(https://segmentfault.com/img/bVk7AU); 瀏覽器分為以下7個部分: 用戶界面 瀏覽器引擎:在用戶界面和呈現引擎之間傳送指令。 渲染引擎:也...

    Amos 評論0 收藏0

發表評論

0條評論

3403771864

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<