Python实现MQTT客户端

pip install paho-mqtt

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):

    print("Connected with result code " + str(rc))

    client.subscribe("topic/test")

def on_message(client, userdata, msg):

    print("on_message " + msg.topic + " " + str(msg.payload))

client = mqtt.Client(client_id="client1", clean_session=True, userdata=None, protocol=mqtt.MQTTv31, transport="tcp")

client.username_pw_set("admin", "password")

client.on_connect = on_connect

client.on_message = on_message

client.connect("127.0.0.1", 61613, 60)

client.loop_forever()

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):

    print("Connected with result code " + str(rc))

    i = 1

    while i <= 1000:

        client.publish("topic/test", "测试MQTT " + str(i))

        i += 1

client = mqtt.Client(client_id="client2", clean_session=True, userdata=None, protocol=mqtt.MQTTv31, transport="tcp")

client.username_pw_set("admin", "password")

client.on_connect = on_connect

client.connect("127.0.0.1", 61613, 60)

client.loop_forever()

# import paho.mqtt.publish as publish

# HOST = "127.0.0.1"

# PORT = 61613

# i = 1

# while i <= 1000:

#     publish.single("topic/test", "测试MQTT " + str(i), qos=1, hostname=HOST, port=PORT, client_id="client3", auth={'username': "admin", 'password': "password"})

#     i += 1