如何在Ruby on Rails中确保Sidekiq Worker顺序执行（后任务待前完成）

针对你的需求，这里提供几个低耦合、兼容Sidekiq 6.5.8的实现方案，按解耦程度和复杂度排序：

方案一：事件驱动模式（最优解，完全解耦） #

利用Rails内置的Active Support事件系统，让第一个Worker完成后发布事件，第二个Worker通过订阅事件触发，两个Worker之间无直接依赖。

1. 定义事件订阅
   在config/initializers/sidekiq_events.rb中添加事件订阅逻辑：

# 订阅客户更新完成事件，触发通知Worker
ActiveSupport::Notifications.subscribe('customer.updated') do |_name, _start, _finish, _id, payload|
  SendNotificationWorker.perform_async(payload[:customer_id])
end

2. 在第一个Worker中发布事件

class UpdateCustomerWorker
  include Sidekiq::Worker

  def perform(customer_id)
    customer = Customer.find(customer_id)
    # 执行客户信息更新逻辑
    customer.update!(status: :updated, ...)
    # 发布更新完成事件
    ActiveSupport::Notifications.instrument('customer.updated', customer_id: customer_id)
  end
end

3. 触发逻辑
   在你的更新服务中，只需调用第一个Worker即可：

class CustomerUpdateService
  def call(customer_id)
    UpdateCustomerWorker.perform_async(customer_id)
  end
end

这个方案的优势是完全解耦两个Worker，后续如果需要添加其他后续任务（比如同步到第三方系统），只需新增事件订阅即可，无需修改UpdateCustomerWorker。

方案二：Redis状态标记（简单易实现） #

借助Sidekiq已使用的Redis，存储第一个任务的完成状态，第二个Worker通过检查状态决定是否执行，未完成则自动重试。

1. 第一个Worker标记完成状态

class UpdateCustomerWorker
  include Sidekiq::Worker

  def perform(customer_id)
    customer = Customer.find(customer_id)
    customer.update!(...)
    # 在Redis中标记任务完成，设置1小时过期（避免冗余数据）
    Redis.current.setex("customer_update_done:#{customer_id}", 3600, 'true')
  end
end

2. 第二个Worker检查状态并执行

class SendNotificationWorker
  include Sidekiq::Worker
  # 设置重试次数和间隔，根据实际需求调整
  sidekiq_options retry: 5, retry_in: ->(count) { 5 * (count + 1) }

  def perform(customer_id)
    if Redis.current.get("customer_update_done:#{customer_id}") == 'true'
      # 发送通知邮件
      UserMailer.customer_updated_notification(customer_id).deliver_later
      # 执行完成后删除Redis标记
      Redis.current.del("customer_update_done:#{customer_id}")
    else
      # 任务未完成，抛出异常触发Sidekiq重试
      raise "Customer update not finished for ID: #{customer_id}"
    end
  end
end

3. 触发逻辑
   在更新服务中同时调用两个Worker：

class CustomerUpdateService
  def call(customer_id)
    UpdateCustomerWorker.perform_async(customer_id)
    SendNotificationWorker.perform_async(customer_id)
  end
end

这个方案无需额外依赖，实现简单，适合小型项目或对解耦要求不极致的场景。需要注意调整重试参数，避免过度重试或重试间隔不合理。

方案三：使用Sidekiq Pro的Batch功能（适合复杂工作流） #

如果你的项目使用了Sidekiq Pro，可以利用其Batch功能来编排顺序任务，Batch会自动在所有前置任务完成后触发后续任务。示例代码如下：

class CustomerUpdateService
  def call(customer_id)
    batch = Sidekiq::Batch.new
    batch.on(:complete, SendNotificationWorker, customer_id: customer_id)
    batch.jobs do
      UpdateCustomerWorker.perform_async(customer_id)
    end
  end
end

这个方案适合多步骤的复杂工作流，但需要Sidekiq Pro授权。

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