Docker安装Emqx

dockerpullemqx/emqx

dockerrun-dit--nameemqx-p18083:18083-p1883:1883-p8083:8083-p8084:8084emqx/emqx:latest

dockerexec-itemqx/bin/sh

# python 3.6importrandomimporttimefrompaho.mqttimportclientasmqtt_clientbroker='127.0.0.1'port=1883topic="林中静月下仙"# generate client ID with pub prefix randomlyclient_id=f'python-mqtt-{random.randint(0, 1000)}'defconnect_mqtt():
defon_connect(client, userdata, flags, rc):
ifrc==0:
print("Connected to MQTT Broker!")
else:
print("Failed to connect, return code %d\n", rc)
client=mqtt_client.Client(client_id)
client.on_connect=on_connectclient.connect(broker, port)
returnclientdefpublish(client):
msg_count=0whileTrue:
time.sleep(1)
msg=f"messages: {msg_count}"result=client.publish(topic, msg)
# result: [0, 1]status=result[0]
ifstatus==0:
print(f"Send `{msg}` to topic `{topic}`")
else:
print(f"Failed to send message to topic {topic}")
msg_count+=1defrun():
client=connect_mqtt()
client.loop_start()
publish(client)
if__name__=='__main__':
run()

ConnectedtoMQTTBroker!Send `messages: 0` totopic `林中静月下仙`
Send `messages: 1` totopic `林中静月下仙`
Send `messages: 2` totopic `林中静月下仙`
Send `messages: 3` totopic `林中静月下仙`

# python3.6importrandomfrompaho.mqttimportclientasmqtt_clientbroker='127.0.0.1'port=1883topic="林中静月下仙"# generate client ID with pub prefix randomlyclient_id=f'python-mqtt-{random.randint(0, 100)}'defconnect_mqtt() ->mqtt_client:
defon_connect(client, userdata, flags, rc):
ifrc==0:
print("Connected to MQTT Broker!")
else:
print("Failed to connect, return code %d\n", rc)
client=mqtt_client.Client(client_id)
client.on_connect=on_connectclient.connect(broker, port)
returnclientdefsubscribe(client: mqtt_client):
defon_message(client, userdata, msg):
print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
client.subscribe(topic)
client.on_message=on_messagedefrun():
client=connect_mqtt()
subscribe(client)
client.loop_forever()
if__name__=='__main__':
run()

ConnectedtoMQTTBroker!Received `messages: 12` from `林中静月下仙` topicReceived `messages: 13` from `林中静月下仙` topicReceived `messages: 14` from `林中静月下仙` topicReceived `messages: 15` from `林中静月下仙` topic