python使用MQTT协议发送、订阅消息

一时失言乱红尘 2022-09-11 01:25 451阅读 0赞

## python使用MQTT协议发布、订阅消息 ##

### 1、MQTT简介 ###

MQTT是一个基于**客户端-服务器**的**消息发布/订阅传输协议**。

一种数据传输协议，不怎么耗资源，适合物联网远程传数据。MQTT工作在 TCP/IP 协议族上,是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议,为此,它需要一个消息中间件 (服务器)。

比如一个传感器要发数据给电脑，那么需要开一个mqtt服务器（Broker），然后传感器作为客户端（client）通过mqtt服务器发布（publish）某个主题（topic）的消息（message），电脑也作为客户端，连接（connect）到mqtt服务器，且订阅（subscribe）该主题，就能收到消息。

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lic5pyo5pyI_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]

### 2、下载MQTT服务器 ###

[官网下载][Link 1]

#### windows下安装： ####

1.  下载[ emqx-windows-4.3.8.zip ][emqx-windows-4.3.8.zip]，解压
2.  命令行下进入解压路径，启动 emqx
    
    常用命令：
    
        进入bin目录，启动服务器
        emqx.cmd start
        
        进入bin目录，关闭服务器
        emqx.cmd stop

#### linux下Ubuntu安装： ####

1.  下载 [emqx-ubuntu18.04-4.3.8-amd64.zip][]

wget https://www.emqx.com/zh/downloads/broker/4.3.8/emqx-ubuntu18.04-4.3.8-amd64.zip

1.  安装

unzip emqx-ubuntu18.04-4.3.8-amd64.zip

1.  运行

./bin/emqx start

常用命令：

启动命令：./bin/emqttd start
    
    关闭命令：./bin/emqttd stop
    
    控制台调试模式启动，检查 EMQ 是否可正常启动
    
    ./bin/emqttd console

#### 后台管理 ####

浏览器打开`http://127.0.0.1:18083`

账号 admin
    密码 public

### 3、python使用例子 ###

#### 发布消息 ####

pub.py

import random
    import time
    
    from paho.mqtt import client as mqtt_client
    
    
    topic = 'python_mqtt' # 发布的主题，订阅时需要使用这个主题才能订阅此消息
    # 随机生成一个客户端id
    client_id = 'python-mqtt-{}'.format(random.randint(0, 1000))
    
    
    def connect_mqtt():
        #连接mqtt服务器
        def on_connect(client, userdata, flags, rc):
            if rc == 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_connect
        # broker = 'broker.emqx.io'
        # port = 1883
        # client.connect(broker, port)
        client.connect(host='127.0.0.1', port=1883)
        return client
    
    
    def publish(client):
        # 发布消息
        msg_count = 0
        while True:
            time.sleep(1)
            msg = '这是客户端发送的第{}条消息'.format(msg_count)
            result = client.publish(topic, msg)
            status = result[0]
            if status == 0:
                print('第{}条消息发送成功'.format(msg_count))
            else:
                print('第{}条消息发送失败'.format(msg_count))
            msg_count += 1
    
    
    def run():
        client = connect_mqtt()
        client.loop_start()
        publish(client)
    
    
    if __name__ == '__main__':
        run()

#### 订阅消息 ####

sub.py

import random
    
    from paho.mqtt import client as mqtt_client
    
    
    topic = "python_mqtt"
    client_id = 'python-mqtt-{}'.format(random.randint(0, 100))
    
    
    def connect_mqtt() -> mqtt_client:
        # 连接MQTT服务器
        def on_connect(client, userdata, flags, rc):
            if rc == 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_connect
        # broker = 'broker.emqx.io'
        # port = 1883
        # client.connect(broker, port)
        client.connect(host='127.0.0.1', port=1883)
        return client
    
    
    def subscribe(client: mqtt_client):
        def on_message(client, userdata, msg):
            data = msg.payload.decode()
            print('订阅【{}】的消息为：{}'.format(msg.topic, data))
    
    
        client.subscribe(topic)
        client.on_message = on_message
    
    
    def run():
        client = connect_mqtt()
        subscribe(client)
        client.loop_forever()
    
    
    if __name__ == '__main__':
        run()

可以启动多个订阅客户端，都能接收到同样的发布消息

![在这里插入图片描述][19bae7084851427e99caf716ca3137bf.png_pic_center]

## 后记 ##

【后记】为了让大家能够轻松学编程，我创建了一个公众号【轻松学编程】，里面有让你快速学会编程的文章，当然也有一些干货提高你的编程水平，也有一些编程项目适合做一些课程设计等课题。

也可加我微信【1257309054】，拉你进群，大家一起交流学习。  
如果文章对您有帮助，请我喝杯咖啡吧！

公众号

![公众号][20200317124808234.jpg]

关注我，我们一起成长~~

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lic5pyo5pyI_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]: /images/20220829/b1b6fb12e5dc467daf21a6897fbe1e02.png
[Link 1]: https://www.emqx.com/zh/downloads?product=broker
[emqx-windows-4.3.8.zip]: https://www.emqx.com/zh/downloads/broker/4.3.8/emqx-windows-4.3.8.zip
[emqx-ubuntu18.04-4.3.8-amd64.zip]: https://www.emqx.com/zh/downloads/broker/4.3.8/emqx-ubuntu18.04-4.3.8-amd64.zip
[19bae7084851427e99caf716ca3137bf.png_pic_center]: /images/20220829/ec922992921b4b599c786eeaff12c507.png
[20200317124808234.jpg]: /images/20220829/d37cd4c60c8240f086bc05a9df377c25.png