Python3 发布MQTT消息（模拟终端）

逃离我推掉我的手 2023-07-14 12:59 202阅读 0赞

需使用python编写程序进行测试MQTT的发布功能。也就是模拟终端（mote）、节点，也叫传感器。

MQTT部署在华为云的服务器上面，在本地编写python程序进行测试。

如果是自己写的话，需要知道：1、MQTT服务器的地址（端口默认1883）2、需要发布的主题 3、需要发送的消息（数据）

代码：

# -*- coding: utf-8 -*-
    # @Time : 2020/3/14 0014 17:10
    # @Author : Liqiju
    # @File : MQTTpublish.py
    # @Software : PyCharm
    import paho.mqtt.client as mqtt
    
    #MQTT服务器
    host = "XXX.XX.XX.XXX"
    #端口
    port = 1883
    #主题
    topic = "config/applicationID/devices/设备ID/rx"
    #发布的消息（数据）
    data = bytes([0x80,0x00,0x02,0x00,0x00,0x15,0x00,0x00,0x00,0x10,0x50,
                 0x10,0xCC,0x08,0xA1,0x23,0x0E,0x01,0x00,0x00,0xC1,0x00,0x6F])
    
    # 一旦连接成功，回调此方法
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code: " + str(rc))
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.connect(host, port, 60) #连接
    client.publish(topic, payload=data, qos=0) #发布消息
    client.loop_forever()  #保持连接状态

运行以上代码。

返回0，表示连接成功

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NzIwNjU3_size_16_color_FFFFFF_t_70][]

消息成功发出，网关已接收到。

![20200316124421296.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NzIwNjU3_size_16_color_FFFFFF_t_70]: /images/20230529/cd8d381f18254717bc56021c3d93ad4e.png
[20200316124421296.png]: /images/20230529/7b8f25f6ac7f445a8def6c69992bd938.png