实现指数退避函数时如何处理错误？

Question

我使用 backoff 方法的概念在发生内部服务器错误时重试请求。我的意思不是 401、403 或类似的。我的目标是在服务器未响应时重试请求 and/or 发送响应的时间太长，例如 pending 状态。我确实为此定义了超时限制（在服务中）。

我的问题是 retryWhen 函数在所有 cases/errors 中被调用，包括 401.

我认为我可能必须重组我的 function/code 才能使其正常工作。我正在努力解决这个问题，但就是无法让它按预期工作。

retryWhen 函数 returns 一个指示何时重试的可观察流，因此它不能在我的代码中正常工作。

public userLogin(userName, userPass: string) {
    this.theService.login(userName, userPass)
        .retryWhen(attempts => Observable.range(1, 3)
            .zip(attempts, i => i)
            .mergeMap(i => {
                console.log("delay retry by " + i + " second(s)");
                // Show a message to user to wait
                if ( i === 3 ) {
                    // Show Server doesn't respond... try later
                }
                return Observable.timer(i * 3000);
            })
        ).subscribe(
        res => {
            // handle and show response result
        },
        err => {
            console.log(err);
            if ( err === 401 ) {
                // handle 401 error
            } else {
                // handle other error
            }
        }
    );
}

下面的也是一种处理同样问题的方法，我尝试使用mergeMap(error => {...})的提示，但对我没有用。

知道我应该如何重组我的代码以重试请求以防内部服务器错误或某种错误吗？正如我提到的，没有 401、403 或类似内容。

Answer 1

您可以重新抛出 retryWhen 运算符中的黑名单错误，如下所示：

/**
 * Performs a retry on an exponential backoff with an upper bounds.
 * Will rethrow the error if it is in the blacklist or the retry
 * attempts have exceeded the maximum.
 * @param {number} initialDelay
 * @param {number} maxRetry - maximum number of times to retry
 * @param {number[]} errorWhiteList - whitelist of errors to retry on (non-transient)
 */
function expontentialRetry(
  initialDelay,
  maxRetry,
  errorWhiteList
) {
  return (errors) => errors.scan((retryAttempts, error) => {
      if(!errorWhiteList.includes(error.status) || retryAttempts > maxRetry) {
        throw error;
      }
      return retryAttempts + 1;
    }, 0).switchMap((retryAttempts) => {
        // calculate exponential backoff
        let delay = Math.pow(2, retryAttempts - 1) * initialDelay;
        console.log(`Retry attempt #${retryAttempts} in ${delay}ms`);
        return Rx.Observable.timer(delay);
    });
}

let count = 0;
const fakeApiCall = Rx.Observable.create((o) => {
  if (count < 5) {
    o.error({ status: 504 });
  } else {
    o.error({ status: 500 });
  }
  count++;
});

fakeApiCall.retryWhen(expontentialRetry(100, 10, [504]))
.subscribe(
  (x) => { console.log('next', x); },
  (error) => { console.log('error', error); },
  () => { console.log('complete'); }
);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.5.10/Rx.min.js"></script>

实现指数退避函数时如何处理错误？

How to handle error when implementing Exponential backoff function?

observable

rxjs

angular-http

angular