python mqtt 发送接收图片

要通过 MQTT 发送和接收图片，需要将图片转换为字节流，并将其作为消息体发送到 MQTT 服务器。以下是一个使用 Python 的 Paho-MQTT 库实现发送和接收图片的示例代码：

发送图片：

import paho.mqtt.client as mqtt
import base64

# MQTT 客户端连接回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))

    # 读取图片文件并将其转换为 base64 编码的字节流
    with open("image.jpg", "rb") as image_file:
        encoded_string = base64.b64encode(image_file.read())

        # 发送图片消息
        client.publish("image_topic", encoded_string)

# 创建 MQTT 客户端并连接到服务器
client = mqtt.Client()
client.on_connect = on_connect
client.connect("mqtt_server_address", 1883, 60)

# 开始 MQTT 客户端的主循环
client.loop_forever()

在此示例代码中，我们首先创建了一个 MQTT 客户端，并设置了连接回调函数。在连接回调函数中，我们读取名为 `image.jpg` 的图片文件，并将其转换为 base64 编码的字节流。接下来，我们将图片消息发送到名为 `image_topic` 的 MQTT 主题中。最后，我们启动 MQTT 客户端的主循环，使其保持运行状态并等待新的消息到达。

接收图片：

import paho.mqtt.client as mqtt
import base64

# MQTT 客户端消息接收回调函数
def on_message(client, userdata, msg):
    if msg.topic == "image_topic":
        # 将接收到的消息转换为 base64 编码的字节流
        encoded_string = msg.payload

        # 将 base64 编码的字节流转换为图片并保存到本地文件系统
        with open("received_image.jpg", "wb") as image_file:
            image_file.write(base64.b64decode(encoded_string))

# 创建 MQTT 客户端并连接到服务器
client = mqtt.Client()
client.on_message = on_message
client.connect("mqtt_server_address", 1883, 60)

# 订阅 MQTT 主题
client.subscribe("image_topic")

# 开始 MQTT 客户端的主循环
client.loop_forever()

在此示例代码中，我们首先创建了一个 MQTT 客户端，并设置了消息接收回调函数。在消息接收回调函数中，我们判断接收到的消息是否为名为 `image_topic` 的 MQTT 主题发来的图片消息。如果是，则将接收到的消息转换为 base64 编码的字节流，并将其转换为图片并保存到本地文件系统。接下来，我们创建了一个 MQTT 订阅并订阅了名为 `image_topic` 的 MQTT 主题。最后，我们启动 MQTT 客户端的主循环，使其保持运行状态并等待新的消息到达。