mqtt python使用

### 使用Python中的MQTT

#### 安装Paho-MQTT库
为了在Python中使用MQTT，需要先安装`paho-mqtt`库。可以通过pip工具来完成这一操作[^3]。

pip3 install -i https://pypi.doubanio.com/simple paho-mqtt

#### 创建简单的发布者(Publisher)

下面是一个基本的例子展示如何创建一个简单的MQTT消息发布者：

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")
    
client = mqtt.Client()
client.on_connect = on_connect

broker_address="test.mosquitto.org"
client.connect(broker_address, 1883, 60)

topic = "my/test/topic"
message = "Hello MQTT"

client.loop_start()  
client.publish(topic,message)
client.loop_stop()

此脚本定义了一个连接回调函数，在成功建立到代理服务器的连接之后会触发该函数并打印出连接状态码[^1]。

#### 订阅主题(Subscriber)

对于想要接收特定话题下所有更新的应用程序来说，则可以设置订阅者如下所示:

import paho.mqtt.client as mqtt

def on_message(client, userdata, msg):
    print(f"{msg.topic} {msg.payload}")

client = mqtt.Client()

broker_address="test.mosquitto.org"
client.connect(broker_address, 1883, 60)

client.subscribe("my/test/topic")
client.on_message = on_message 

client.loop_forever()

这段代码设置了当接收到新消息时调用的方法，并持续监听来自指定主题的消息直到手动终止程序运行。

#### 发送文件作为字节流

如果目标是在两个设备间通过MQTT传输文件，那么一种方法就是将文件转换成字节数组并通过网络发送这些数据包[^5]。

with open('example.txt', 'rb') as f:
    byte_array = f.read()

client.publish("file_transfer",byte_array,qos=1,retain=False)

以上展示了打开本地文件读取其内容为二进制形式，随后将其作为一个整体一次性上传至名为`file_transfer`的主题上。