【python】MQTT协议基础（简介+代码）

MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅型消息传输协议，特别适用于物联网应用。它采用简洁的协议设计和低带宽消耗，能够在不可靠的网络环境下可靠地传输消息。

MQTT的基本概念包括发布者（Publisher）、订阅者（Subscriber）、代理服务器（Broker）和主题（Topic）。发布者将消息发布到特定主题上，而订阅者可以选择订阅感兴趣的主题，并接收相应的消息。

以下是使用MQTT协议的基本步骤和相关代码示例：

第一步：连接代理服务器

要使用MQTT协议，首先需要与代理服务器建立连接。连接包括指定代理服务器的IP地址和端口号，并提供客户端ID以标识自己。

以下是一个示例代码片段，用于连接到MQTT代理服务器：

import paho.mqtt.client as mqtt
# 定义回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    # 连接成功后订阅主题
    client.subscribe("topic1")
 
# 创建MQTT客户端实例
client = mqtt.Client()
 
# 设置回调函数
client.on_connect = on_connect
 
# 连接代理服务器
client.connect("broker.example.com", 1883, 60)
 
# 保持与代理服务器的连接
client.loop_forever()

第二步：发布消息

发布者可以将消息发布到特定的主题上。发布消息时，需要指定发布的主题和消息的内容。

以下是一个示例函数，用于发布消息：

import paho.mqtt.client as mqtt
 
def publish_message():
    # 创建MQTT客户端实例
    client = mqtt.Client()
    
    # 连接代理服务器
    client.connect("broker.example.com", 1883, 60)
    
    # 发布消息
    client.publish("topic1", "Hello, MQTT!")
    
    # 断开与代理服务器的连接
    client.disconnect()

第三步：订阅消息

订阅者可以选择订阅感兴趣的主题，并接收相应的消息。当代理服务器收到发布者发布的消息时，会将消息发送给所有订阅了相应主题的订阅者。

以下是一个示例代码片段，用于订阅主题并接收消息：

import paho.mqtt.client as mqtt
# 定义回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    # 连接成功后订阅主题
    client.subscribe("topic1")
 
# 定义消息接收回调函数
def on_message(client, userdata, msg):
    print("Received message: " + msg.payload.decode())
 
# 创建MQTT客户端实例
client = mqtt.Client()
 
# 设置回调函数
client.on_connect = on_connect
client.on_message = on_message
 
# 连接代理服务器
client.connect("broker.example.com", 1883, 60)
 
# 保持与代理服务器的连接
client.loop_forever()

以上是使用MQTT协议的基本步骤和代码示例。通过适当修改和扩展这些示例代码，可以实现更复杂的MQTT应用。

转载:MQTT协议基础简介（含代码） - 知乎