Tutorial zur Installation und Verwendung von Docker MQTT

docker run -d --hostname mein-Kaninchen --name irgendein-Kaninchen -p 15672:15672 -p 5672:5672 -p 1883:1883 -p 15675:15675 daocloud.io/library/rabbitmq:3.7.4

docker exec <Container-ID> rabbitmq-plugins aktivieren rabbitmq_management
docker exec <Container-ID> rabbitmq-plugins aktivieren rabbitmq_mqtt
docker exec <Container-ID> rabbitmq-plugins aktivieren rabbitmq_web_mqtt

/usr/sbin/rabbitmq-plugins aktivieren rabbitmq_management
/usr/sbin/rabbitmq-plugins aktivieren rabbitmq_mqtt
/usr/sbin/rabbitmq-plugins aktivieren rabbitmq_web_mqtt

Firewall-Befehl --zone=public --add-port=15672/tcp --permanent
Firewall-Befehl --zone=public --add-port=5672/tcp --permanent
Firewall-Befehl --zone=public --add-port=1883/tcp --permanent
Firewall-Befehl --zone=public --add-port=15675/tcp --permanent
Firewall-Befehl --reload

# Vor der Verwendung müssen Sie Hbase und den Thrift-Server starten. # Starten Sie Hbase mit cd /usr/local/hbase bin/start-hbase.sh. Der Standardport ist 60000.
# Starten Sie den Thrift-Server cd /usr/local/hbase/bin execute ./hbase-daemon.sh start thrift Der Standardport ist 9090
System importieren
Betriebssystem importieren
dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../'
sys.path.append(dir_common) # Fügen Sie das Stammverzeichnis zum Systemverzeichnis hinzu, um normalerweise auf den gemeinsamen Ordner zu verweisen. importiere argparse #
Importprotokollierung
Importzeit, Datum/Uhrzeit
von common.py_log importiere init_logger,init_console_logger
aus common.config importieren *
von common.py_hbase importiere PyHbase
Importzeit, JSON
von common.py_rabbit importiere Rabbit_Consumer
importiere paho.mqtt.client als mqtt
Importzeit
HOST = "192.168.2.46"
PORT = 1883
def client_loop():
  client_id = Zeit.strftime('%Y%m%d%H%M%S',Zeit.localtime(Zeit.Zeit()))
  client = mqtt.Client(client_id) # ClientId kann nicht wiederholt werden, verwenden Sie also die aktuelle Zeit client.username_pw_set("guest", "guest") # Muss festgelegt werden, sonst wird "Verbunden mit Ergebniscode 4" zurückgegeben
  client.on_connect = bei_Verbindung
  client.on_message = bei_Nachricht
  client.connect(HOST, PORT, 60)
  client.loop_forever()
def on_connect(Client, Benutzerdaten, Flags, rc):
  print("Verbunden mit Ergebniscode "+str(rc))
  client.subscribe("test")
def on_message(Client, Benutzerdaten, Nachricht):
  drucken(msg.topic+" "+msg.payload.decode("utf-8"))
wenn __name__ == '__main__':
  client_loop()

System importieren
Betriebssystem importieren
dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../'
sys.path.append(dir_common) # Fügen Sie das Stammverzeichnis zum Systemverzeichnis hinzu, um auf den gemeinsamen Ordner zu verweisen. Importieren Sie normalerweise paho.mqtt.client als mqtt
Importzeit
HOST = "192.168.2.46"
PORT = 1883
def client_loop():
  client_id = Zeit.strftime('%Y%m%d%H%M%S',Zeit.localtime(Zeit.Zeit()))
  client = mqtt.Client(client_id) # ClientId kann nicht wiederholt werden, verwenden Sie also die aktuelle Zeit client.username_pw_set("guest", "guest") # Muss festgelegt werden, sonst wird "Verbunden mit Ergebniscode 4" zurückgegeben
  client.on_connect = bei_Verbindung
  client.on_message = bei_Nachricht
  client.connect(HOST, PORT, 60)
  client.loop_forever()
def on_connect(Client, Benutzerdaten, Flags, rc):
  print("Verbunden mit Ergebniscode "+str(rc))
  client.subscribe("test")
def on_message(Client, Benutzerdaten, Nachricht):
  drucken(msg.topic+" "+msg.payload.decode("utf-8"))
wenn __name__ == '__main__':
  client_loop()

# importiere paho.mqtt.client als mqtt
importiere paho.mqtt.publish als publish
Importzeit
HOST = "192.168.2.46"
PORT = 1883
def on_connect(Client, Benutzerdaten, Flags, rc):
  print("Verbunden mit Ergebniscode "+str(rc))
  client.subscribe("test")
def on_message(Client, Benutzerdaten, Nachricht):
  drucken(msg.topic+" "+msg.payload.decode("utf-8"))
wenn __name__ == '__main__':
  client_id = Zeit.strftime('%Y%m%d%H%M%S',Zeit.localtime(Zeit.Zeit()))
  # client = mqtt.Client(client_id) # ClientId kann nicht wiederholt werden, verwenden Sie also die aktuelle Zeit# client.username_pw_set("guest", "guest") # Muss festgelegt werden, sonst wird „Verbunden mit Ergebniscode 4“ zurückgegeben
  # client.on_connect = bei_Verbindung
  # client.on_message = bei_Nachricht
  # Client.Verbinden(HOST, PORT, 60)
  # client.publish("test", "Hello MQTT", qos=0, retain=False) # Nachricht veröffentlichen publish.single("test", "Hello MQTT", qos = 1, hostname=HOST, port=PORT, client_id=client