KOA API服务器 - 等待处理之前的请求，然后处理新请求

Question

我正在使用KOA建立一个API，该API使用另一个API处理一些信息。我的API来自客户端，我的API向另一个API提出了一些不同的请求。问题是，另一个API易碎且缓慢，因此为了确保数据完整性，我必须在开始新的过程之前检查是否处理过以前的传入请求。我的第一个想法是使用承诺和全球布尔值来检查是否进行了正在进行的处理并等待该过程完成。不知何故，这可以防止并发请求，但是即使在此过程中出现了3-4个请求，也只完成了第一个请求，就是这样。为什么其余的传入请求被遗忘了？

编辑：作为附带说明，我不需要响应带有处理的信息的传入请求。收到请求后，我可以立即发送响应。我需要使用第三方API进行操作。

到目前为止，我的解决方案： 入口点：

  router.get('/update', (ctx, next) => {
    ctx.body = 'Updating...';
    update();
    next();
  });

和更新功能：

let updateInProgress = false;

const update = async () => {
  const updateProcess = () => {
    return new Promise((resolve, reject) => {
      if (!updateInProgress) {
        return resolve();
      } else {
        setTimeout(updateProcess, 5000);
      }
    });
  };
  await updateProcess();
  updateInProgress = true;
  // Process the request
  updateInProgress = false
}

Answer 1

好吧，我找到了一个工作解决方案，不确定它有多优雅...
我猜这个问题是，超时功能是创造了新的诺言，另一个是一个，另一个直到解决了一个诺言。这并不能解决第一个承诺艰难的诺言，并且代码被卡住了。解决方案是创建一个间隔，该间隔检查是否满足条件，然后解决承诺。如果有人聪明可以发表评论，我将不胜感激。

let updateInProgress = false;

const update = async () => {
  const updateProcess = () => {
    return new Promise((resolve, reject) => {
      if (!updateInProgress) {
        return resolve();
      } else {
        const processCheck = setInterval(() => {
          if (!updateInProgress) {
            clearInterval(processCheck);
            return resolve();
          }
        }, 5000);
      }
    });
  };
  await updateProcess();
  updateInProgress = true;
  // Process the request
  updateInProgress = false
}