【发布时间】:2026-01-04 23:30:01
【问题描述】:
所以我需要能够为每个 Sidekiq 线程创建一个 RabbitMQ 连接和通道,因为如果我不这样做,我会用完 RabbitMQ 连接,而且docs 建议这样做。文档展示了如何使用Unicorn:
before_fork do |server, worker|
$rabbitmq_connection.close if $rabbitmq_connection
end
after_fork do |server, worker|
# the following is *required* for Rails + "preload_app true",
defined?(ActiveRecord::Base) and
ActiveRecord::Base.establish_connection
$rabbitmq_connection = Bunny.new
$rabbitmq_connection.start
$rabbitmq_channel = $rabbitmq_connection.create_channel
end
end
是否可以为 Sidekiq 线程做类似的事情? Sidekiq.server_configure 有什么我可以做的吗?看起来this 是 Sidekiq 启动线程的地方,但我看不到要挂接到启动/停止?
【问题讨论】:
标签: multithreading rabbitmq unicorn sidekiq bunny