# mqtt_publisher_simple.py
import paho.mqtt.client as mqtt
import time

# MQTT代理服务器地址
BROKER = "test.mosquitto.org"
PORT = 1883
# 客户端ID，需要唯一。如果为None，库会自动生成一个。
CLIENT_ID = "MyFirstPublisher_Python"
# 要发布消息的主题
TOPIC = "python/mqtt/firsthello"
# 要发送的消息内容
MESSAGE = "Hello, MQTT World from Python!"
# 服务质量等级 (0: 最多一次， 1: 至少一次， 2: 仅一次)
QOS = 1

# 连接成功回调函数
def on_connect(client, userdata, flags, rc):
    """
    当客户端收到来自服务器的CONNACK响应（连接结果）时被调用。
    rc参数决定了连接是否成功。
    """
    if rc == 0:
        print(f"[连接成功] 已连接到代理: {BROKER}:{PORT}")
        # 连接成功后，可以在这里订阅主题（对于发布者不是必须的）
    else:
        print(f"[连接失败] 错误码: {rc}")

# 发布消息回调函数（当消息从客户端发出时触发）
def on_publish(client, userdata, mid):
    """
    当一条消息完成发送到代理后（对于QoS 0），或者代理确认收到后（对于QoS 1,2）被调用。
    mid是消息ID。
    """
    print(f"[发布确认] 消息ID {mid} 已发送。")

# 创建客户端实例
client = mqtt.Client(client_id=CLIENT_ID, protocol=mqtt.MQTTv311)

# 将回调函数赋值给客户端
client.on_connect = on_connect
client.on_publish = on_publish

try:
    # 1. 连接到代理
    print(f"[正在连接] 尝试连接到 {BROKER}:{PORT} ...")
    client.connect(BROKER, PORT, keepalive=60) # keepalive: 心跳间隔，单位秒

    # 启动网络循环线程，在后台处理消息收发和心跳
    client.loop_start()

    # 等待连接建立（简单处理，生产环境应用更健壮的逻辑）
    time.sleep(2)

    # 2. 发布消息
    print(f"[准备发布] 主题: {TOPIC}, 消息: {MESSAGE}, QoS: {QOS}")
    # publish() 方法会返回一个消息ID (mid) 和结果码 (rc)
    result = client.publish(topic=TOPIC, payload=MESSAGE, qos=QOS, retain=False)
    
    # result是一个元组 (rc, mid)
    status = result[0]
    if status == 0:
        print(f"[发布成功] 消息已加入发送队列。")
    else:
        print(f"[发布失败] 状态码: {status}")

    # 等待一下，确保发布回调被触发
    time.sleep(2)

except Exception as e:
    print(f"[发生异常] {e}")
finally:
    # 3. 断开连接并清理
    print("[清理] 正在断开连接...")
    client.loop_stop() # 停止网络循环
    client.disconnect() # 发送DISCONNECT包
    print("[完成] 程序结束。")

# mqtt_publisher_sensor.py
import paho.mqtt.client as mqtt
import time
import json
import random

BROKER = "test.mosquitto.org"
PORT = 1883
CLIENT_ID = "PythonTempSensor"
TOPIC = "home/livingroom/sensor/temperature"
QOS = 1

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print(f"传感器已上线，开始上报数据...")
    else:
        print(f"连接失败，代码: {rc}")

def on_publish(client, userdata, mid):
    # 可以在这里记录日志，这里简单打印
    # print(f"消息 {mid} 确认送达")
    pass

client = mqtt.Client(client_id=CLIENT_ID)
client.on_connect = on_connect
client.on_publish = on_publish

try:
    client.connect(BROKER, PORT, 60)
    client.loop_start()
    time.sleep(1) # 等待连接

    sensor_id = "sensor_001"
    print(f"模拟传感器 ID: {sensor_id}")
    print(f"发布主题: {TOPIC}")
    print("按 Ctrl+C 停止...\n")

    while True:
        # 模拟生成温度数据 (18.0 - 25.0 度之间)
        temperature = round(18.0 + random.random() * 7, 2)
        # 构造一个结构化的JSON消息，比纯文本更通用
        payload = {
            "sensor_id": sensor_id,
            "timestamp": int(time.time()),
            "value": temperature,
            "unit": "°C"
        }
        message = json.dumps(payload) # 将字典转换为JSON字符串

        print(f"[{time.strftime('%H:%M:%S')}] 发布: {message}")
        client.publish(TOPIC, message, qos=QOS)

        time.sleep(5) # 等待5秒

except KeyboardInterrupt:
    print("\n用户中断，正在关闭...")
except Exception as e:
    print(f"错误: {e}")
finally:
    client.loop_stop()
    client.disconnect()
    print("传感器已离线。")