如何在ActiveJob+DelayedJob中处理任务重试失败后的操作

针对你遇到的ActiveJob + DelayedJob场景下，需要在任务3次重试后最终失败时执行特定操作的需求，我整理了几个实用的解决方案，你可以根据自己的项目情况选择：

方案一：利用DelayedJob的数据库模型回调 #

虽然ActiveJob没有直接暴露DelayedJob的failure钩子，但我们可以直接对DelayedJob的底层模型添加回调，判断任务是否达到最终失败状态，再触发自定义逻辑。

首先，在项目中创建一个初始化文件，比如config/initializers/delayed_job_final_failure.rb，写入以下代码：

Delayed::Job.class_eval do
  # 当任务被标记为失败，且尝试次数等于最大允许次数时触发
  after_save :run_final_failure_action, if: -> { failed? && attempts == max_attempts }

  private

  def run_final_failure_action
    # 解析DelayedJob存储的handler，获取对应的ActiveJob实例
    job_wrapper = YAML.load(self.handler)
    return unless job_wrapper.is_a?(ActiveJob::QueueAdapters::DelayedJobAdapter::JobWrapper)

    active_job = job_wrapper.job
    # 如果任务类定义了最终失败处理方法，就调用它
    active_job.handle_final_failure if active_job.respond_to?(:handle_final_failure)
  end
end

然后在你的ActiveJob任务类中，定义对应的处理方法：

class UserNotificationJob < ApplicationJob
  queue_as :default

  def perform(user_id)
    # 你的核心任务逻辑，比如发送通知
    user = User.find(user_id)
    UserMailer.alert_email(user).deliver_now
  end

  # 最终失败时执行的操作
  def handle_final_failure
    user_id = arguments.first
    Rails.logger.error "【任务最终失败】UserNotificationJob 处理用户ID: #{user_id} 失败，已耗尽所有重试次数"
    # 这里可以添加告警逻辑，比如给管理员发邮件、推送告警到Slack等
    # AdminAlertMailer.job_failure_alert(self.class.name, user_id).deliver_later
  end
end

这个方案的好处是逻辑集中在DelayedJob层面，所有任务都可以通过定义handle_final_failure方法来实现自定义失败处理，无需重复写重试判断逻辑。

方案二：在ActiveJob内部结合rescue_from判断重试次数 #

如果你更倾向于把逻辑封装在ActiveJob任务类内部，可以利用rescue_from捕获异常，同时通过executions和max_attempts判断是否是最后一次失败：

class DataSyncJob < ApplicationJob
  queue_as :sync
  # 设置最大重试次数为3次
  retry_on StandardError, attempts: 3

  rescue_from StandardError do |exception|
    # executions返回当前已执行的次数（包括本次），当等于max_attempts时说明是最后一次尝试
    if executions == max_attempts
      handle_final_failure(exception)
    end
    # 必须重新抛出异常，让DelayedJob正确标记任务为失败
    raise exception
  end

  def perform(data_id)
    # 你的数据同步逻辑
    DataSyncService.process(data_id)
  end

  private

  def handle_final_failure(exception)
    data_id = arguments.first
    Rails.logger.error "【任务最终失败】DataSyncJob 处理数据ID: #{data_id} 失败，错误信息: #{exception.message}"
    # 执行你的特定操作，比如记录到失败任务表、触发告警等
  end
end

这个方案的优势是每个任务的失败逻辑完全内聚在自身类中，适合不同任务有不同失败处理逻辑的场景。

方案三：编写DelayedJob自定义插件 #

如果你的项目有多个任务需要统一处理最终失败逻辑，推荐用DelayedJob的插件机制来封装，这样更优雅且易于维护：

首先，在lib/delayed_job/failure_handler_plugin.rb中编写插件：

module Delayed
  module Plugins
    class FailureHandlerPlugin < Plugin
      callbacks do |lifecycle|
        # 环绕任务执行的回调
        lifecycle.around(:invoke_job) do |job, *args, &block|
          begin
            block.call
          rescue Exception => e
            # 检查是否是最后一次尝试（attempts是已经尝试的次数，+1后等于max_attempts则是最后一次）
            if job.attempts + 1 >= job.max_attempts
              notify_final_failure(job, e)
            end
            # 继续抛出异常，让DelayedJob处理失败状态
            raise e
          end
        end
      end

      private

      def self.notify_final_failure(job, exception)
        job_wrapper = YAML.load(job.handler)
        return unless job_wrapper.is_a?(ActiveJob::QueueAdapters::DelayedJobAdapter::JobWrapper)

        active_job = job_wrapper.job
        # 调用任务类的自定义失败方法
        active_job.handle_final_failure(exception) if active_job.respond_to?(:handle_final_failure)
      end
    end
  end
end

# 注册插件到DelayedJob Worker
Delayed::Worker.plugins << Delayed::Plugins::FailureHandlerPlugin

然后在config/initializers/delayed_job_plugins.rb中引入这个插件：

require Rails.root.join('lib/delayed_job/failure_handler_plugin')

之后，你只需要在ActiveJob任务类中定义handle_final_failure方法，插件就会自动在任务最终失败时触发它。

注意事项 #

• 解析handler时，如果担心YAML安全问题，可以使用YAML.safe_load并指定允许的类，比如：

  job_wrapper = YAML.safe_load(self.handler, permitted_classes: [ActiveJob::QueueAdapters::DelayedJobAdapter::JobWrapper, UserNotificationJob])
  

• 确保你的DelayedJob版本支持这些回调和插件机制，建议使用较新的稳定版本。

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