From ecfb4d1746d1ad7440ac76356cda0767dff6b8c0 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Mon, 2 Mar 2026 20:04:46 +0800 Subject: [PATCH] bugfix --- appPublic/zmqapi.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/appPublic/zmqapi.py b/appPublic/zmqapi.py index 43d64a9..5812cf0 100755 --- a/appPublic/zmqapi.py +++ b/appPublic/zmqapi.py @@ -55,8 +55,11 @@ async def zmq_subcribe(special_key: str, callback=None): try: while True: # 接收消息（multipart 格式，第一部分是 key，第二部分是内容） - debug('## RECEIVING message on {special_key}') + if callback: + debug(f'## RECEIVING message on {special_key}') msg = await sock.recv_multipart() + if callback: + debug(f'## RECEIVED message on {special_key}:{msg}') key = msg[0].decode() content = msg[1].decode() # print(f"【服务端】匹配成功！Key: {key}, 内容: {content}")