推荐使用ActiveJob::Retry - 灵活的主动作业重试库

在开发高可用性和容错性的应用程序时，我们经常遇到需要处理失败任务的情况。这就是ActiveJob::Retry库大显身手的地方。这个Alpha阶段的库正在积极发展中，为你的ActiveJob提供自动重试机制。

项目介绍

ActiveJob::Retry是一个简洁且强大的工具，它允许你在ActiveJob的工作类中轻松地引入重试策略。只需简单地include ActiveJob::Retry.new(strategy: something, **options)，就可以在任务执行失败时进行重试，从而提高了任务完成的成功率。

项目技术分析

ActiveJob::Retry提供了三种内置策略：

1. 常量延迟（Constant）：在每次尝试之间保持恒定的时间间隔。
2. 指数级延迟（Exponential）：随着尝试次数的增加，延迟时间呈指数级增长。
3. 可变延迟（Variable）：在预定义的一系列延迟时间中随机选择。

此外，你还可以自定义回退策略，只需要创建一个响应should_retry?(attempt, exception)和retry_delay(attempt, exception)方法的对象，并将其传递给retry_with。

应用场景

对于那些可能因临时性问题（如网络错误、超时等）而失败的任务来说，这是一个理想的选择，例如：

• 处理Webhook
• 数据抓取或同步
• 邮件发送
• 第三方API调用

通过ActiveJob::Retry，你可以确保这些任务能够在后续尝试中成功执行，而不会因为一次失败就完全中断。

项目特点

• 灵活的重试策略：支持常量、指数和可变延迟，以及自定义回退策略。
• 回调功能：在每个重试之前可以运行回调，检查条件并决定是否继续重试。
• 兼容多种队列适配器：任何支持延迟调度的队列适配器都可以与之配合，但可能需要调整配置以防止适配器自身的自动重试。
• 控制异常处理：可以选择哪些异常类型应该被重试，哪些应视为致命错误，直接记录到错误服务。

常量选项配置

• limit: 最大重试次数，默认为1。
• unlimited_retries: 是否无限次重试，需谨慎设置。
• delay: 两次尝试之间的延迟秒数，默认为0。
• retryable_exceptions: 只有当抛出的异常在这份白名单上时才会重试。
• fatal_exceptions: 黑名单中的异常将不被重试。

指数和可变选项与常量类似，但有自己的特定配置项。

使用方法示例

class ProcessWebhook < ActiveJob::Base
  include ActiveJob::Retry.new(strategy: :constant,
                               limit: 3,
                               delay: 5.minutes,
                               retryable_exceptions: [TimeoutError, NetworkError])
  
  # 或者，使用指数级延迟...
  # include ActiveJob::Retry.new(strategy: :exponential, limit: 25)

  # 或者，使用可变延迟...
  # include ActiveJob::Retry.new(strategy: :variable, delays: [1.minute, 5.minutes, 10.minutes, 30.minutes])

  def perform(webhook)
    webhook.process!
  end
end

总之，ActiveJob::Retry是一个强大的工具，它可以提高你的ActiveJob任务的可靠性和健壮性。尽管仍处于alpha阶段，但其丰富的特性已经使其成为处理可能失败任务的首选解决方案。赶快试试看吧！