Nodejs Retry优雅的失败重试策略

Nodejs Retry优雅的失败重试策略

alt Retry优雅的失败重试策略

前言：

异常，在程序设计中是至关重要的，但经常会被设计的过于复杂！

有时候，我们调用一个网络访问的函数，各种原因造成访问失败，会获得一个异常。这个异常可能是请求超时，也许重连一次就好了。代码中，我们会用到try…catch…finally，当应用中异常的规则不断增加，单纯的try…catch控制的重试就显得不够用了。

retry包，可以非常简单地帮助我们封装需要“重试”的函数。

文章目录：

  • retry介绍
  • retry安装
  • retry的API介绍
  • retry使用

请查看博客文章

http://blog.fens.me/nodejs-retry/


2 回复

Nodejs Retry优雅的失败重试策略

前言：

在编写网络应用程序时，经常会遇到各种各样的错误，如网络不稳定导致的超时、服务器暂时不可达等问题。这些错误可能会导致我们的程序无法正常运行。虽然我们可以使用传统的 try...catch 机制来处理这些异常，但在实际开发中，随着业务逻辑的复杂化，单纯依靠 try...catch 来处理重试逻辑可能会变得非常繁琐。

为了解决这个问题，我们可以借助 retry 这个库来简化重试逻辑。它能够优雅地处理网络请求中的失败情况，并自动进行重试，从而减少代码的复杂性。

文章目录：

  • retry介绍
  • retry安装
  • retry的API介绍
  • retry使用

retry介绍

retry 是一个用于 Node.js 的库，它可以帮助我们轻松地实现重试逻辑。通过配置不同的重试策略，我们可以控制重试的次数、间隔时间等参数，使得我们的代码更加简洁和灵活。

retry安装

首先，我们需要安装 retry 库。可以通过 npm 安装：

npm install --save retry

retry的API介绍

retry 库提供了一些基本的 API，包括创建重试对象、执行重试操作等。主要的 API 如下：

  • retry.operation(options)：创建一个重试操作对象，可以指定重试的最大次数、间隔时间等。
  • operation.attempt(fn)：执行一次重试操作。如果函数执行成功，则返回结果；如果失败，则根据配置的策略进行重试。

retry使用

下面是一个简单的示例，展示如何使用 retry 库来实现重试逻辑：

const retry = require('retry');

// 创建一个重试操作对象，最多重试3次，每次重试间隔1秒
const operation = retry.operation({
    retries: 3,
    factor: 1,
    minTimeout: 1000,
    maxTimeout: 1000,
});

operation.attempt(() => {
    // 模拟一个可能失败的网络请求
    const request = () => {
        console.log("尝试请求...");
        if (Math.random() < 0.8) { // 80%的概率失败
            throw new Error('请求失败');
        } else {
            return '请求成功';
        }
    };

    try {
        const result = request();
        console.log(result);
    } catch (err) {
        if (operation.retry(err)) {
            console.log(`重试 ${operation.retriesLeft()} 次`);
        } else {
            console.error(`最终失败：${err.message}`);
        }
    }
});

在这个示例中，我们创建了一个重试操作对象，设置了最大重试次数为3次，每次重试间隔1秒。然后我们定义了一个模拟的网络请求函数 request，该函数有80%的概率抛出一个错误。我们使用 operation.attempt 来执行这个函数，并在捕获到错误时调用 operation.retry 方法来决定是否继续重试。如果重试次数用尽且仍然失败，则输出最终的错误信息。

通过这种方式，我们可以非常方便地将复杂的重试逻辑封装起来，使代码更加清晰和易于维护。


Node.js Retry优雅的失败重试策略

在开发过程中，处理网络请求时难免会遇到各种失败的情况。retry包可以帮助我们优雅地处理这些失败，并提供自动重试的功能。

retry介绍

retry 是一个简单的、灵活的重试库，可用于处理异步操作中的错误。它能够根据不同的策略进行重试，避免了重复编写冗余的错误处理代码。

retry安装

首先需要通过npm安装 retry 包：

npm install --save retry

retry的API介绍

retry 提供了一些核心的方法来定义重试策略：

  • operation(options): 创建一个重试操作。
  • operation.attempt(fn): 执行函数 fn 并处理重试逻辑。

retry使用

以下是一些使用示例：

  1. 基本重试

假设我们有一个需要重试的网络请求函数：

const retry = require('retry');

function makeRequest() {
    return new Promise((resolve, reject) => {
        // 模拟一个失败的请求
        setTimeout(() => {
            reject(new Error("Request failed"));
        }, 1000);
    });
}

// 定义重试策略
const operation = retry.operation({
    retries: 5,
    factor: 3,
    minTimeout: 1 * 1000,
    maxTimeout: 60 * 1000,
    randomize: true
});

// 使用重试策略执行请求
operation.attempt(async (currentAttempt) => {
    try {
        await makeRequest();
        console.log("Request succeeded on attempt", currentAttempt);
    } catch (err) {
        if (operation.retry(err)) {
            console.log("Attempt", currentAttempt, "failed, retrying...");
        } else {
            console.error("Max retries reached:", err);
        }
    }
});
  1. 高级重试策略

我们可以根据错误类型或状态码决定是否重试：

const operation = retry.operation({
    retries: 3,
    factor: 2,
    minTimeout: 1 * 1000,
    maxTimeout: 60 * 1000,
    randomize: false
});

const makeRequest = async () => {
    // 模拟一个可能失败的请求
    let statusCode;
    switch (Math.floor(Math.random() * 3)) {
        case 0:
            statusCode = 404;
            break;
        case 1:
            statusCode = 500;
            break;
        default:
            statusCode = 200;
            break;
    }

    if (statusCode >= 500) {
        throw new Error(`Server error: ${statusCode}`);
    }
    return { status: statusCode };
};

operation.attempt(async (currentAttempt) => {
    try {
        const result = await makeRequest();
        console.log("Request succeeded on attempt", currentAttempt, "with status:", result.status);
    } catch (err) {
        if (operation.retry(err)) {
            console.log("Attempt", currentAttempt, "failed, retrying...");
        } else {
            console.error("Max retries reached:", err);
        }
    }
});

以上代码展示了如何使用 retry 库来处理失败重试的情况，并且可以根据具体需求调整重试策略。

回到顶部