Rails und MQTT: Thema im Hintergrund beim Serverstart abonnieren?

Question

Ich möchte ein mqtt-Thema in meiner Rails-App abonnieren, wenn der Server startet und das Abonnement immer aktiv und aktiv hält.

Ich verwende dieses MQTT Juwel für MQTT Kommunikation: https://github.com/njh/ruby-mqtt

Hier ist, was ich jetzt haben:

in application.rb:

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

BackgroundMQTT Klasse:

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 

Also im Grunde die mqtt subscr перед составший на к after_initialize Methode und so weit ich weiß, stoppt nicht automatisch?

Auch Wie Sie sehen können, führe ich das Abonnement in einem Thread, sonst würde meine Rails-Anwendung aufhören, etwas anderes als das mqtt Abonnement zu hören.

Dies scheint zumindest für die ersten paar Minuten zu funktionieren.

Ich bin mir nicht sicher, ob dies eine empfohlene Art zu tun ist, was ich tun möchte. Könnte dies zu Problemen führen, die ich nicht berücksichtigt habe? Was wäre ein empfehlender Weg dies zu tun?

Answer 1

Zwei interessante Hinweise, die helfen können. Ich sehe, dass die MQTT-Bibliothek bereits Threads verwendet und keine lokale Verwendung benötigt.

Zweitens, wenn Sie einen Block übergeben, gibt es ein anderes Verhalten als wenn Sie dies nicht tun. Der entsprechende Code für dieses Verhalten ist https://github.com/njh/ruby-mqtt/blob/master/lib/mqtt/client.rb#L292-L308.

Ich sehe auch, dass Sie eine BackgroundMQTT Klasse instanziieren und nicht die MQTTSubscriber, die Sie in der Frage auflisten. Ich nehme an, das ist nur ein Tippfehler.

Zuletzt beeinflussen Rails und der Rack-Server, wie all dies ausgeführt wird. Wenn Sie sicherstellen möchten, dass Ihr Threading ordnungsgemäß funktioniert, würde ich dies außerhalb von Rails ausführen und sicherstellen, dass Sie das richtige Verhalten erhalten, bevor Sie es in Ihre Anwendung einfügen. Wenn Sie sicher sind, dass dies nicht mit Ihrer Implementierung zusammenhängt, kann ich einige Tests durchführen, wie langlebige Threads in einer Rails-App funktionieren. Versuchen Sie, Ihre Implementierung bis auf puts ohne die Verbindung zu reduzieren und sehen Sie, wie gut sich das verhält.