Python在windows下搭建MQTT服务器并实现通信

秦羽 2020-11-09 PM 980℃ 0条

## 注意

MQTT协议中有三种身份：发布者（Publish）、代理（Broker）（服务器）、订阅者（Subscribe）。
首先必须要需要搭建MQTT服务器，才能进行后续发布和订阅代码操作。

## 搭建MQTT服务器

ActiveMQ 5 下载地址：http://activemq.apache.org/index.html
下载后进入`apache-activemq-5.16.0-bin\apache-activemq-5.16.0\bin\win64`，在cmd里运行`activemq.bat`即可启动MQTT服务器。
进入`http://127.0.0.1:8161/admin/` 账号密码均为`admin`，若能成功进入则代表启动成功。

## 发布者和订阅者代码

- 发布者（客户端）Python代码

```python
#!/usr/bin/env python  
# encoding: utf-8  
""" 
@version: v1.0 
@author: W_H_J 
@license: Apache Licence  
@contact: 415900617@qq.com 
@software: PyCharm 
@file: clicentMqttTest.py 
@time: 2019/2/22 14:19 
@describe: mqtt客户端
"""
import json
import sys
import os
import paho.mqtt.client as mqtt
import time
 
sys.path.append(os.path.abspath(os.path.dirname(__file__) + '/' + '..'))
sys.path.append("..")
 
TASK_TOPIC = 'test'  # 客户端发布消息主题
 
client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
"""
client_id是连接到代理。如果client_id的长度为零或为零，则行为为由使用的协议版本定义。如果使用MQTT v3.1.1，
那么一个零长度的客户机id将被发送到代理，代理将被发送为客户端生成一个随机变量。如果使用MQTT v3.1，那么id将是
随机生成的。在这两种情况下，clean_session都必须为True。如果这在这种情况下不会产生ValueError。
注意：一般情况下如果客户端服务端启用两个监听那么客户端client_id 不能与服务器相同，如这里用时间"20190222142358"作为它的id，
如果与服务器id相同，则无法接收到消息
"""
client = mqtt.Client(client_id, transport='tcp')
 
client.connect("127.0.0.1", 1883, 60)  # 此处端口默认为1883，通信端口期keepalive默认60
client.loop_start()
 
 
def clicent_main(message: str):
    """
    客户端发布消息
    :param message: 消息主体
    :return:
    """
    time_now = time.strftime('%Y-%m-%d %H-%M-%S', time.localtime(time.time()))
    payload = {"msg": "%s" % message, "data": "%s" % time_now}
    # publish(主题：Topic; 消息内容)
    client.publish(TASK_TOPIC, json.dumps(payload, ensure_ascii=False))
    print("Successful send message!")
    return True
 
 
if __name__ == '__main__':
    msg = "我是一条测试数据！"
    clicent_main(msg)
```

- 订阅者（服务端）Python代码

```python
#!/usr/bin/env python  
# encoding: utf-8  
""" 
@version: v1.0 
@author: W_H_J 
@license: Apache Licence  
@contact: 415900617@qq.com 
@software: PyCharm 
@file: serverMqttTest.py 
@time: 2019/2/22 14:35 
@describe: mqtt 服务端
"""
import json
import sys
import os
import time
import paho.mqtt.client as mqtt
sys.path.append(os.path.abspath(os.path.dirname(__file__) + '/' + '..'))
sys.path.append("..")
 
REPORT_TOPIC = 'test'  # 主题
 
 
def on_connect(client, userdata, flags, rc):
    print('connected to mqtt with resurt code ', rc)
    client.subscribe(REPORT_TOPIC)  # 订阅主题
 
 
def on_message(client, userdata, msg):
    """
    接收客户端发送的消息
    :param client: 连接信息
    :param userdata: 
    :param msg: 客户端返回的消息
    :return: 
    """
    print("Start server!")
    payload = json.loads(msg.payload.decode('utf-8'))
    print(payload)
 
 
def server_conenet(client):
    client.on_connect = on_connect  # 启用订阅模式
    client.on_message = on_message  # 接收消息
    client.connect("127.0.0.1", 1883, 60)  # 链接
    # client.loop_start()   # 以start方式运行，需要启动一个守护线程，让服务端运行，否则会随主线程死亡
    client.loop_forever()   # 以forever方式阻塞运行。
 
 
def server_stop(client):
    client.loop_stop()  # 停止服务端
    sys.exit(0)
 
 
def server_main():
    client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
    client = mqtt.Client(client_id, transport='tcp')
    server_conenet(client)
 
 
if __name__ == '__main__':
    # 启动监听
    server_main()
```

参考文章
[https://blog.csdn.net/sinat_32651363/article/details/87876978](https://blog.csdn.net/sinat_32651363/article/details/87876978)
[https://blog.csdn.net/huanhuanq1209/article/details/79885224](https://blog.csdn.net/huanhuanq1209/article/details/79885224)

标签: MQTT, 发布订阅

非特殊说明，本博所有文章均为博主原创。

如若转载，请注明出处：https://www.qinyu.cc/archives/81.html

上一篇 uWSGI process 7388 got Segmentation Fault

下一篇 vue拦截器里多个错误提示只显示第一个

Python在windows下搭建MQTT服务器并实现通信

评论啦~

栏目分类

标签云

友情链接申请

Python在windows下搭建MQTT服务器并实现通信

 评论啦~

 栏目分类

标签云

友情链接申请

评论啦~

栏目分类

标签云

友情链接申请