mqttx发布订阅消息的代码帮我写一段正确能运行的出来

以下是一段基于Python的MQTTX发布订阅消息的代码：

import paho.mqtt.client as mqtt

# 设置MQTT Broker地址和端口号
broker_address = "localhost"
broker_port = 1883

# 创建MQTT客户端对象
client = mqtt.Client()

# 连接MQTT Broker
client.connect(broker_address, broker_port)

# 订阅主题
client.subscribe("test/topic")

# 定义回调函数，处理接收到的消息
def on_message(client, userdata, message):
    print("Received message:", str(message.payload.decode("utf-8")))

# 设置回调函数
client.on_message = on_message

# 启动MQTT客户端，开始监听消息
client.loop_start()

# 发布消息
client.publish("test/topic", "Hello, MQTTX!")

# 等待5秒钟，让消息传递完成
time.sleep(5)

# 停止MQTT客户端
client.loop_stop()

注意，上述代码中需要根据实际情况修改MQTT Broker地址和端口号、订阅主题和发布的消息内容。此外，为了保证MQTT客户端能够持续运行并接收消息，需要在代码中使用`client.loop_start()`方法启动客户端，并在适当的时候使用`client.loop_stop()`方法停止客户端。