如何避免Rails中Sidekiq定时Job与Worker的代码重复问题

我在控制器动作中调用了Sidekiq Worker SyncProductsWorker，相关控制器代码如下：

class ProductsController < BaseApiController
  def fetch_all
    ::Imports::FetchAllProductsWorker.perform_async

    head :ok
  end
end

同时我在sidekiq.yml中配置了作为定时任务的Sidekiq Job FetchAllProductsJob，其代码逻辑与上述Worker完全一致，sidekiq.yml配置如下：

:queues:
  - imports_fetch_all
:dynamic: true
:schedule:
  imports_fetch_all_job:
    cron: '0 0 * * *' # at midnight
    class: Imports::FetchAllProductsJob
    queue: imports_fetch_all

目前Worker与Job两个类的代码几乎完全相同，类定义代码如下：

# worker
module Imports
  class FetchAllProductsWorker
    include Sidekiq::Worker
    sidekiq_options queue: 'imports_fetch_all'

    def perform
      puts 'test'
    end
  end
end

# schedule job
module Imports
  class FetchAllProductsJob < ApplicationJob
    sidekiq_options queue: 'imports_fetch_all'

    def perform
      puts 'test'
    end
  end
end

需要找到可行的重构方式，避免维护两份相同代码导致的重复问题。

推荐方案：抽离核心业务逻辑到独立服务类 #

这是通用性最强、耦合度最低的做法，核心思路是不要把业务逻辑写在后台任务类中，不管是原生Sidekiq Worker还是Active Job，都只作为任务的入口，实际业务逻辑统一收敛到单独的服务对象中，后续所有逻辑修改只需要维护服务类一份代码。

1. 新建独立服务类存放业务逻辑，比如路径为app/services/imports/fetch_all_products.rb：

   module Imports
     class FetchAllProducts
       def call
         # 迁移原来两个perform方法中的所有业务逻辑到此处
         puts 'test'
       end
     end
   end
   

2. 精简原有Worker和Job代码，二者仅负责调用服务类，不再承载业务逻辑：

   # 原生Sidekiq Worker
   module Imports
     class FetchAllProductsWorker
       include Sidekiq::Worker
       sidekiq_options queue: 'imports_fetch_all'
   
       def perform
         Imports::FetchAllProducts.new.call
       end
     end
   end
   
   # 定时任务用Active Job
   module Imports
     class FetchAllProductsJob < ApplicationJob
       sidekiq_options queue: 'imports_fetch_all'
   
       def perform
         Imports::FetchAllProducts.new.call
       end
     end
   end
   

这种写法的额外好处是后续如果需要在控制台、Rake任务、其他业务流程里触发产品同步逻辑，直接调用服务类即可，不需要再硬套后台任务的调用方式。

可选简化方案：统一入口为Active Job #

如果你不需要同时保留原生Sidekiq Worker和Active Job两套入口，可以直接删掉冗余的Worker类，全程使用Active Job作为唯一任务入口：

• 修改控制器代码，不再调用Worker，直接触发Job：

  class ProductsController < BaseApiController
    def fetch_all
      ::Imports::FetchAllProductsJob.perform_async
      head :ok
    end
  end
  

• 保留原有sidekiq.yml的定时任务配置不变，直接指向Imports::FetchAllProductsJob即可
• 删除不再使用的FetchAllProductsWorker文件
  这种方案代码量最少，只需要维护一个Job类，前提是确认项目中Active Job的Sidekiq适配器配置正常，队列路由、重试、超时等Sidekiq特性符合预期。

不要采用类继承、或者一个任务的perform方法直接调用另一个任务perform的写法，这类写法会增加无意义的调用层级，后续排查日志、定位异常时会多出不必要的嵌套，反而提升维护成本。

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