MQTT温湿度监控系统 代码

MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅消息协议，特别适合用于物联网设备之间的通信。在构建一个MQTT温湿度监控系统中，你通常会使用一个客户端（如Python的paho-mqtt库）来连接到MQTT服务器，传感器设备负责收集数据，然后将数据发布到预定义的主题（topic），而服务器则会将这些数据转发给订阅该主题的其他客户端。

以下是一个简单的Python示例，展示了一个基本的MQTT温湿度监控系统的代码结构：

import paho.mqtt.client as mqtt
import Adafruit_DHT

# 传感器类型和引脚
DHT_TYPE = Adafruit_DHT.DHT11
DHT_PIN = 4

def get_humidity_and_temperature():
    humidity, temperature = Adafruit_DHT.read_retry(DHT_TYPE, DHT_PIN)
    return humidity, temperature

# MQTT设置
MQTT_BROKER = "your_mqtt_broker_address"
MQTT_TOPIC = "sensors/temperature/humidity"

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to MQTT broker")
        client.subscribe(MQTT_TOPIC)
    else:
        print("Failed to connect, code:", rc)

def on_message(client, userdata, msg):
    humidity, temperature = get_humidity_and_temperature()
    client.publish(msg.topic + "/reading", f"Temperature: {temperature}°C, Humidity: {humidity}%")

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(MQTT_BROKER, 1883, 60)
client.loop_forever()

在这个代码里，我们首先定义了获取温度和湿度的方法，然后设置了MQTT连接信息和主题。`on_connect`回调处理连接成功或失败，`on_message`回调在接收到新消息时执行，读取传感器数据并发布新的测量值到指定主题。