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:09:25 +08:00
parent ecfb4d1746
commit 2cc7746abc
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
appPublic/zmqapi.py
View File

@ -17,10 +17,12 @@ async def run_proxy():
subscribe_url = config.subscribe_url or 'tcp://127.0.0.1:5556' subscribe_url = config.subscribe_url or 'tcp://127.0.0.1:5556'
publish_url = config.publish_url or 'tcp://127.0.0.1:5555' publish_url = config.publish_url or 'tcp://127.0.0.1:5555'
ctx = zmq.asyncio.Context() ctx = zmq.asyncio.Context()
debug(f"【Proxy】启动：Pub 连 {publish_url}，Sub 连 {subscribe_url}")
# 1. 面对 Publisher 的前端 (XSUB) # 1. 面对 Publisher 的前端 (XSUB)
frontend = ctx.socket(zmq.XSUB) frontend = ctx.socket(zmq.XSUB)
frontend.bind(publish_url) # 发布者往这里 connect frontend.bind(publish_url) # 发布者往这里 connect
debug(f"【Proxy】启动：Pub 连 {publish_url}，Sub 连 {subscribe_url}")
# 2. 面对 Subscriber 的后端 (XPUB) # 2. 面对 Subscriber 的后端 (XPUB)
backend = ctx.socket(zmq.XPUB) backend = ctx.socket(zmq.XPUB)