MQTT客户端

基于PythonMQTT的模块(paho)快速搭建MQTT客户端

# mqtt模块
import paho.mqtt.client as mqtt
import json
import random
import time

# MQTT Broker
server_ip = "localhost"
topic = "t/1"

# 用于响应服务器端 CONNACK 的 callback，如果连接正常建立，rc 值为 0
def on_connect(client, userdata, flags, rc):
    print("Connection returned with result code:" + str(rc))


# 用于响应服务器端 PUBLISH 消息的 callback，打印消息主题和内容
def on_message(client, userdata, msg):
    print("Received message, topic:" + msg.topic + " payload:" + str(msg.payload))


# 在连接断开时的 callback，打印 result code
def on_disconnect(client, userdata, rc):
    print("Disconnection returned with result code:" + str(rc))

# 创建客户端
client001 = mqtt.Client("client_001")
client001.on_connect = on_connect
client001.on_disconnect = on_disconnect
client001.on_message = on_message
# 连接
client001.connect(server_ip, 1883, 60)
client001.loop_start()

if __name__ == "__main__":
    # 循环发送
    while True:
        value = random.randint(10, 100)
        msg_json = {
            "msg": "hello",
            "value": value
        }

        msg_string = json.dumps(msg_json)
        result = client001.publish(topic, payload=msg_string)
        status = result[0]
        if status == 0:
            print(f"Send `{msg_string}` to topic `{topic}`")
        else:
            print(f"Failed to send message to topic {topic}")
        time.sleep(1)

 赞  0

 赏 

感谢您的支持，我会继续努力哒!

分类标签：技术，python，mqtt
文章标题：MQTT客户端
文章链接：http://120.46.217.131:82/archives/33/
最后编辑：2022 年 9 月 16 日 16:37 By Yang
许可协议： 署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)