我有两个 Sidekiq 工人:
# app/workers/client_worker.rb
class ClientWorker
include Sidekiq::Worker
def perform(*args)
puts "client started\n"
end
end
和
# app/workers/server_worker.rb
class ServerWorker
include Sidekiq::Worker
def perform(*args)
i = 0
loop do
begin
i = i + 1
puts "server waiting"
sleep(2)
if i > 5
break
end
rescue => e
end
end
end
end
我有两个 Rails 应用程序,相同的 rails 版本,相同的 ruby 版本,相同的 gems 版本。
rvm use ruby-2.4.2@rails5.2
在一个新的 Rails 应用程序 上当我启动服务器工作程序时,然后立即启动客户端工作程序,我在服务器消息中得到了预期的客户端消息:
2018-06-21T22:44:19.855Z 32364 TID-gn863tph0 ServerWorker JID-7cdd1fd3d6fe63c91d99f3b0 INFO: start
server waiting
server waiting
server waiting
2018-06-21T22:44:24.356Z 32364 TID-gn865q1zk ClientWorker JID-7dc887d6824d0b789afec69d INFO: start
client started
2018-06-21T22:44:24.357Z 32364 TID-gn865q1zk ClientWorker JID-7dc887d6824d0b789afec69d INFO: done: 0.001 sec
server waiting
server waiting
server waiting
2018-06-21T22:44:31.858Z 32364 TID-gn863tph0 ServerWorker JID-7cdd1fd3d6fe63c91d99f3b0 INFO: done: 12.003 sec
在已经开发的 Rails 应用程序上
当我重复这个过程时,任务一个接一个地运行:
2018-06-21T22:41:34.250Z 32247 TID-grdaosqf3 ServerWorker JID-5a2d9917e6575d6858644474 INFO: start
server waiting
server waiting
server waiting
2018-06-21T22:41:38.402Z 32247 TID-grdamch6b ClientWorker JID-5da83582991bf284f6357046 INFO: start
server waiting
server waiting
server waiting
client started
2018-06-21T22:41:46.259Z 32247 TID-grdaosqf3 ServerWorker JID-5a2d9917e6575d6858644474 INFO: done: 12.007 sec
2018-06-21T22:41:46.259Z 32247 TID-grdamch6b ClientWorker JID-5da83582991bf284f6357046 INFO: done: 7.858 sec
我试过的
- 我已经删除了旧应用程序中所有已安装的 gem,以便旧的 Rails 应用程序 Gemfile 与新应用程序相似。我删除了所有自定义库、所有作业、所有自定义配置
我
Sidekiq.options
在这两个应用程序上进行了比较,它们是相同的:{:queues=>[], :labels=>[], :concurrency=>25, :require=>".", :environment=>nil, :timeout=>8, :poll_interval_average=>nil, :average_scheduled_poll_interval= >5, :error_handlers=>[], :death_handlers=>[], :lifecycle_events=>{:startup=>[], :quiet=>[], :shutdown=>[], :heartbeat=>[]} , :dead_max_jobs=>10000, :dead_timeout_in_seconds=>15552000, :reloader=>#}
现在我的想法不多了!谁能建议我找出问题所在的方法?
编辑 Okey,经过长时间的犹豫,我决定在旧应用程序中进行与新应用程序相同的更改,即:在新应用程序中,我注意到工人不会自动包含,所以我添加了以下初始化程序:
# config/initializers/01_extensions.rb
Dir["#{Rails.root}/app/workers/*.rb"].each { |file| require file }
在旧的应用程序中,工人是自动包含的(我真的不知道这是默认行为!),所以这个初始化程序不是必需的。
但是现在,当我决定向旧应用程序添加相同的初始化程序时,任务正在按预期异步运行。
现在我有两个问题:
- 我们是否需要明确包括 sidekiq 工作人员?(文档中未提及)
- 工人的明确包括在 sidekiq 行为中有何变化?