Rails 和 MQTT：在服务器启动时在后台订阅主题？

Question

我想在服务器启动时订阅我的 Rails 应用程序中的 mqtt 主题，并保持订阅始终处于活动状态和运行状态。

我正在使用这个 mqtt gem 进行 mqtt 通信： https://github.com/njh/ruby-mqtt

这是我现在拥有的：

在 application.rb 中：

config.after_initialize do
 mqttSub = BackgroundMQTT.new
 mqttSub.run
end

BackgroundMQTT 类：

class MQTTSubscriber
  def run
    Thread.new do
      MQTT::Client.connect(:host => 'localhost', :port => 1883,) do |c|
        c.get('#') do |topic,message|
          puts "#{topic}: #{message}"
          #Do things, access activerecord etc.
        end
      end
    end
  end
end

所以基本上 mqtt 订阅以after_initialize 方法开始，据我所知，不会自动停止？

此外，正如您所见，我正在线程中运行订阅，否则我的 rails 应用程序将停止执行任何其他操作，而不是监听 mqtt 订阅。

这似乎至少在前几分钟有效。

我不确定这是否是推荐的方式来做我想做的事情。这会导致我没有考虑过的任何问题吗？这样做的推荐方法是什么？

Answer 1

两个有趣的注释可能会有所帮助。我看到 MQTT 库已经使用了 Threads，不需要您在本地使用。

其次，当你通过一个障碍物时，会有与不通过的行为不同的行为。该行为的相关代码位于https://github.com/njh/ruby-mqtt/blob/master/lib/mqtt/client.rb#L292-L308。

我还看到您正在实例化 BackgroundMQTT 类，而不是您在问题中列出的 MQTTSubscriber。我假设这只是一个错字。

最后，Rails 和 Rack 服务器会影响所有这些的执行方式。如果您试图确保您的线程工作正常，我会在 Rails 之外执行此操作，并确保您在将其放入应用程序之前获得正确的行为。如果您确定这与您的实现无关，那么我可能会运行一些测试来测试长寿命线程在 Rails 应用程序中的工作方式。尝试在没有连接的情况下将您的实现减少到仅puts，看看效果如何。