Sidekiq/Active Job报错回滚数据库致邮件重复发送问题求助

我完全懂你的困扰——Active Job默认的事务回滚机制确实是为了保证任务原子性，但碰到邮件这种非幂等操作时，就会踩重复发送的坑。下面给你几个实用的解决方案：

方案一：手动控制事务范围，邮件发送放在事务提交后 #

核心思路是把需要持久化的数据库操作单独包裹在事务里，等事务成功提交后再发送邮件。这样哪怕后续任务抛出异常，数据库的状态已经保存下来了，重试时就能通过这个状态判断是否已经处理过，避免重复发邮件。

示例代码：

class ProcessPaymentJob < ApplicationJob
  queue_as :default

  def perform(payment_id)
    payment = Payment.find(payment_id)

    # 先做幂等性检查，已经处理过就直接跳过
    return if payment.processed?

    # 只把数据库变更逻辑放在事务内
    ActiveRecord::Base.transaction do
      payment.update!(processed: true, processed_at: Time.current)
    end

    # 事务提交成功后再执行邮件发送
    UserMailer.payment_confirmation(payment.user).deliver_now
  rescue StandardError => e
    # 这里可以加自定义日志或告警逻辑
    raise e # 抛出异常让Sidekiq重试，此时数据库状态已保存，不会重复发邮件
  end
end

这种方式逻辑清晰，完全掌握了事务边界，确保邮件只在业务状态持久化后发送。

方案二：拆分任务，解耦数据库操作与邮件发送 #

把原任务拆成两个独立的Job：一个负责处理数据库变更，另一个专门发送邮件。只有当数据库操作成功完成，事务提交后，才触发邮件任务。

示例代码：

# 负责业务数据处理的主任务
class ProcessPaymentJob < ApplicationJob
  queue_as :default

  def perform(payment_id)
    payment = Payment.find(payment_id)

    ActiveRecord::Base.transaction do
      payment.mark_as_processed!
      # 事务提交成功后，才将邮件任务加入队列
      SendPaymentConfirmationJob.perform_later(payment.user.id)
    end
  end
end

# 专门负责发送邮件的子任务
class SendPaymentConfirmationJob < ApplicationJob
  queue_as :mailers

  def perform(user_id)
    user = User.find(user_id)
    # 可选：这里也可以加邮件发送状态检查，进一步保证幂等
    UserMailer.payment_confirmation(user).deliver_now
  end
end

这个方案的优势是职责分离，邮件任务只专注发送逻辑，主任务聚焦业务数据处理。如果主任务失败，事务回滚，邮件任务根本不会入队，从根源避免无效发送。

关键注意事项 #

• 幂等性检查优先：不管用哪种方案，都要在任务最开头加幂等判断（比如检查processed?状态），这是避免重复操作的第一道防线。
• 绝对别在事务内发邮件：如果邮件发送在事务里，一旦事务回滚，邮件已经发出去了，反而会出现“邮件已发但数据库状态没更新”的不一致问题，这比重复发送更难处理。
• 异常处理要谨慎：别轻易捕获异常却不重新抛出，否则Sidekiq不会重试任务；但可以在捕获时添加日志或告警，方便排查问题。

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