yumoqing/apppublic
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-02 20:04:46 +08:00
parent 2db7195c2c
commit ecfb4d1746
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
appPublic/zmqapi.py
View File

@ -55,8 +55,11 @@ async def zmq_subcribe(special_key: str, callback=None):
try: try:
while True: while True:
# 接收消息（multipart 格式，第一部分是 key，第二部分是内容） # 接收消息（multipart 格式，第一部分是 key，第二部分是内容）
debug('## RECEIVING message on {special_key}') if callback:
debug(f'## RECEIVING message on {special_key}')
msg = await sock.recv_multipart() msg = await sock.recv_multipart()
if callback:
debug(f'## RECEIVED message on {special_key}:{msg}')
key = msg[0].decode() key = msg[0].decode()
content = msg[1].decode() content = msg[1].decode()
# print(f"【服务端】匹配成功！Key: {key}, 内容: {content}") # print(f"【服务端】匹配成功！Key: {key}, 内容: {content}")