Rails ActiveJob的retry_on是否兼容delayed_job_active_record后端？

回答 #

核心结论 #

不能直接无缝使用retry_on。delayed_job（简称DJ）的重试逻辑和ActiveJob的retry_on存在底层冲突：DJ的max_attempts是基于全局/单Job的重试次数上限，而retry_on是针对特定异常的精细化重试规则，两者的重试计数、延迟计算逻辑不兼容，会导致重试行为混乱——比如DJ的自动重试会忽略retry_on的等待规则，或者retry_on触发的重试会被DJ的计数提前终止。

替代策略 #

1. 重写DJ的内置方法实现特定异常重试

直接在Job类里覆盖delayed_job的max_attempts和reschedule_at方法，针对目标异常定制重试次数和延迟：

class MyJob < ApplicationJob
  queue_as :default

  def perform(*args)
    # 你的业务逻辑代码
  end

  # 针对特定异常设置重试次数上限
  def max_attempts
    if exception.is_a?(AnotherCustomAppException)
      5 # 自定义该异常的重试次数
    else
      super # 沿用全局默认次数
    end
  end

  # 针对特定异常设置指数退避延迟
  def reschedule_at(current_time, attempts)
    if exception.is_a?(AnotherCustomAppException)
      current_time + attempts * 2.seconds
    else
      super
    end
  end
end

2. 手动捕获异常并调用retry_job

主动在perform方法里捕获目标异常，手动调用retry_job控制重试规则，同时禁用DJ的自动重试避免冲突：

class MyJob < ApplicationJob
  queue_as :default
  # 禁用DJ的自动重试，完全由自己控制
  self.max_attempts = 1

  def perform(*args)
    begin
      # 你的业务逻辑代码
    rescue AnotherCustomAppException => e
      # 获取当前已重试次数（首次执行时executions为0）
      executions = job_data['executions'].to_i
      # 自定义重试次数上限
      if executions < 5
        retry_job wait: executions * 2.seconds
      else
        # 超过重试次数后的处理：比如记录日志、丢去死信队列
        handle_failure(e)
      end
    end
  end

  private

  def handle_failure(exception)
    # 这里写失败后的收尾逻辑
    Rails.logger.error "Job最终失败，异常：#{exception.message}"
  end
end

3. 编写DJ插件实现复用性重试逻辑

如果多个Job都需要相同的特定异常重试规则，可以编写delayed_job插件来统一处理，避免重复代码：

# 创建文件 lib/delayed_job/retry_on_custom_exception.rb
module Delayed
  module Plugins
    class RetryOnCustomException < Plugin
      callbacks do |lifecycle|
        lifecycle.around(:invoke_job) do |job, *args, &block|
          begin
            block.call(job, *args)
          rescue AnotherCustomAppException => e
            attempts = job.attempts
            if attempts < 5
              # 设置延迟时间，这里用指数退避
              job.reschedule_at = Time.current + attempts * 2.seconds
              job.save!
            else
              # 超过次数标记为失败
              job.fail!
            end
          end
        end
      end
    end
  end
end

# 在初始化文件（比如 config/initializers/delayed_job.rb）注册插件
Delayed::Worker.plugins << Delayed::Plugins::RetryOnCustomException

内容的提问来源于stack exchange，提问作者Jeremy Gottfried