RabbitMQ/Bunny：线程内subscribe代码块无法执行问题排查

嘿，我之前踩过类似的RubyBunny线程订阅的坑，一下子就能get到你的困惑——明明单线程示例跑的好好的，一挪到线程里就完全没反应，对吧？咱们来捋清楚你忽略的核心点：

问题根源：RubyBunny的Reactor线程绑定特性 #

RubyBunny的异步订阅依赖事件循环（Reactor），而这个Reactor是和初始化连接的线程绑定的。简单说：

• 主线程创建的连接，它的Reactor只会在主线程里处理事件
• 你把订阅代码放到子线程里，但子线程没有自己的Reactor在运行，订阅的回调自然触发不了
• 另外，主线程如果过早退出，子线程会被直接终止，连初始化订阅的机会都没有

具体解决方案 #

1. 在线程内独立初始化连接与通道 #

别在主线程创建连接再传到子线程，子线程要自己初始化连接，这样Reactor会绑定到这个子线程，才能处理订阅事件。

2. 维持线程内的Reactor运行 #

订阅默认是非阻塞的（block: false），如果线程里没有阻塞逻辑维持Reactor，线程会直接跑完退出。你可以二选一：

• 用 subscribe(block: true) 让订阅阻塞线程，自动维持Reactor
• 手动调用 conn.run 启动Reactor的事件循环

3. 让主线程不要过早退出 #

主线程如果直接结束，所有子线程都会被强制终止，所以要给主线程加个等待逻辑，比如监听退出信号或者循环sleep。

修正后的示例代码 #

require 'bunny'

# 子线程内独立处理连接和订阅
Thread.new do
  # 在线程内初始化连接
  conn = Bunny.new
  conn.start

  ch = conn.create_channel
  x = ch.fanout('test.fanout')
  q = ch.queue('', exclusive: true).bind(x)

  puts "子线程已启动订阅..."
  # 用block: true阻塞线程，维持Reactor运行，处理消息回调
  q.subscribe(block: true) do |delivery_info, properties, payload|
    puts "线程内收到消息: #{payload}"
  end
end

# 主线程保持存活，等待退出信号
trap('INT') do
  puts "\n正在退出..."
  exit
end

loop { sleep 1 }

额外注意点 #

• 不要在多个线程之间共享Bunny的连接或通道对象，它们不是线程安全的，每个线程最好用自己的连接实例
• 如果需要非阻塞的订阅（比如线程还要做其他事），可以在订阅后调用 conn.run，但要注意如果后续需要停止Reactor，得用 conn.stop

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