提交 1bc8bf65 authored 作者: 陈泽健's avatar 陈泽健

补充富创项目的MQTT消息监听,监听到消息后,会通过日志输出消息体内容,可用于富创项目测试替代第三方工具使用。

上级 4a13f2f6
......@@ -101,4 +101,5 @@
- 输出富创项目的MQTT会议推送相关代码处理。
- 输出富创项目的MQTT人脸签到订阅测试脚本,输出富创项目两个MQTT相关服务的README文档。
29. 2024-12-13
- 补充MQTT的消息监听,监听到消息后,会通过日志输出消息体内容,可用于所有预定项目测试使用。
\ No newline at end of file
- 补充MQTT的消息监听,监听到消息后,会通过日志输出消息体内容,可用于所有预定项目测试使用。
- 补充富创项目的MQTT消息监听,监听到消息后,会通过日志输出消息体内容,可用于富创项目测试替代第三方工具使用。
\ No newline at end of file
......@@ -7,15 +7,17 @@ logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(
# MQTT 客户端回调函数
def on_connect(client, userdata, flags, rc):
logging.info("已连接到MQTT服务器")
client.subscribe(topic)
# 订阅多个主题
topics = ["/androidPanel/", "/meeting/sign/result", "/meeting/message/sync"]
for t in topics:
client.subscribe(t)
def on_message(client, userdata, msg):
logging.info(f"接收到消息: {msg.payload.decode()}")
logging.info(f"接收到消息: 主题={msg.topic}, 消息体={msg.payload.decode()}")
if __name__ == "__main__":
broker_address = "192.168.5.218"
port = 1883
topic = "/androidPanel/" # 替换为你需要订阅的主题
# 创建 MQTT 客户端实例
mqtt_client = mqtt.Client()
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论