Python连接MQTT服务器订阅和发布主题-Python物联网开发

一、前言

? ? ? ? 在物联网开发中，掌握MQTT可以说是一项必备的技能，要使用Python连接MQTT服务器、订阅和发布主题，我们需要导入paho-mqtt库。

二、实现代码

? ? ? ? 在之前的文章中，我们也介绍了JAVA是如何连接MQTT服务器实现发布和订阅主题的功能的，因此此处不再赘述。

? ? ? ? 文章链接：JAVA&Android实现MQTT上位机软件功能-订阅主题与发布主题

? ? ? ? 首先，我们需要安装paho-mqtt库，安装方法可以参考：Python使用pip命令安装外部库

? ? ? ? 具体程序实现代码：

import paho.mqtt.client as mqtt
import time

# 定义MQTT服务器的地址和端口
mqtt_broker_address = "broker.emqx.io" #此处我们使用免费服务器
mqtt_broker_port = 1883

# 定义订阅和发布的主题
subscribe_topic = "westbeginer/sub"
publish_topic = "westbeginer/pub"


# 定义回调函数，处理收到的消息
def on_message(client, userdata, message):
    print(f"Received message '{message.payload.decode()}'")


# 创建MQTT客户端实例
client = mqtt.Client()

# 设置消息接收的回调函数
client.on_message = on_message

# 连接到MQTT服务器
client.connect(mqtt_broker_address, mqtt_broker_port, keepalive=60)

# 订阅主题
client.subscribe(subscribe_topic)

# 启动MQTT客户端的循环，等待接收消息
client.loop_start()

#发送Hello字符串
message_payload="hello"
client.publish(publish_topic, message_payload)

while True:
    time.sleep(1)


# 断开MQTT连接 不执行
client.loop_stop()
client.disconnect()

? ? ? ? 三、功能演示

? ? ? ? 我们使用MQTTBox工具，连接免费MQTT服务器后，订阅和发布报文测试功能。

? ? ? ? 可以看到，功能完美实现。