0

我有两个 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 行为中有何变化？
4

1 回答 1

2

在开发过程中，Rails 5 有效地限制了您一次只能完成一项工作，即使使用多个线程也是如此。这种全局“执行者”锁允许 Rails 著名的开发重载。

在生产中，作业将按照您的预期同时执行。

于 2018-06-21T23:27:29.060 回答