我尝试了下面的例子(从this页):
nc = NATS()
await nc.connect(servers=["nats://demo.nats.io:4222"])
future = asyncio.Future()
async def cb(msg):
nonlocal future
future.set_result(msg)
await nc.subscribe("updates", cb=cb)
await nc.publish("updates", b'All is Well')
await nc.flush()
# Wait for message to come in
msg = await asyncio.wait_for(future, 1)
但这似乎只对接收一条消息有用。我如何订阅并继续接收消息
我也看过the package example,但它似乎只是扮演对话的双方,然后退出
我对python了解不多,但看起来您只是在等待一条消息,程序就结束了。您应该看看订户示例here。如您所见,有一个循环要永远等待或等待SIGTERM信号
您还可以找到一个长期运行的服务示例:https://github.com/nats-io/nats.py/blob/master/examples/service.py
相关问题 更多 >
编程相关推荐