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-02-12 18:16:25 +08:00
parent 7f0ed97e5a
commit 521498a18d
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
appPublic/zmqapi.py
View File

@ -7,12 +7,10 @@ import zmq
import zmq.asyncio import zmq.asyncio
import json import json
import asyncio
import zmq
from zmq.asyncio import Context from zmq.asyncio import Context
from zmq.utils.monitor import parse_monitor_message from zmq.utils.monitor import parse_monitor_message
async def zmq_subcriber(special_key: str, zmq_url='tcp://127.0.0.1:5555', callback=None): async def zmq_subcribe(special_key: str, zmq_url='tcp://127.0.0.1:5555', callback=None):
ctx = Context() ctx = Context()
sock = ctx.socket(zmq.SUB) sock = ctx.socket(zmq.SUB)
sock.connect(zmq_url) sock.connect(zmq_url)