temp_code/python/temp_test/send_emqx.py

import paho.mqtt.client as mqtt

# MQTT 服务器地址
MQTT_SERVER = "127.0.0.1"
MQTT_PORT = 1883
MQTT_TOPIC = "test/topic"

# 当客户端从服务器成功接收 CONNACK 响应时调用的回调函数
def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")
    # 订阅主题
    client.subscribe(MQTT_TOPIC)

# 当接收到订阅主题的消息时调用的回调函数
def on_message(client, userdata, msg):
    print(f"Received message: {msg.payload.decode()} on topic {msg.topic}")

# 创建 MQTT 客户端实例
client = mqtt.Client()

# 绑定回调函数
client.on_connect = on_connect
client.on_message = on_message

# 连接到 MQTT 服务器
client.connect(MQTT_SERVER, MQTT_PORT, 60)

# 开始循环处理网络事件
client.loop_start()

# 发送消息
client.publish(MQTT_TOPIC, "Hello EMQ X")

# 等待一些时间，确保消息被发送
import time
time.sleep(2)

# 停止循环
client.loop_stop()
client.disconnect()