python - ZMQ经销商未收到带有asyncio的消息

我正在使用pyzmq经销商套接字和提供的asyncio功能为Hyperledger Sawtooth事件设置侦听器。当前，即使消息已发送到套接字，也将返回期货，但有时仅会完成。

奇怪的是，这适用于连接消息（仅当如下所示在其之前休眠时），而不适用于事件消息。我已经用JavaScript实现了它，并且可以正常工作。看来问题不在于Sawtooth，而在于pyzmq的asyncio功能实现或我的代码中。

class EventListener:
    def __init__(self):
        ...
        ctx = Context.instance()
        self._socket = ctx.socket(zmq.DEALER)
        self._socket.connect("tcp://127.0.0.1:4004")

    async def subscribe(self):
        ...
        await self._socket.send_multipart([connection_msg])

    async def receive(self):
        # Necessary wait otherwise the future is never finished
        await asyncio.sleep(0.1)
        resp = await self._socket.recv_multipart()
        handle_response(resp)

    async def listen(self):
        while True:
            # here sleep is not helping
            # await asyncio.sleep(0.1)

            # follwing await is never finished
            resp = await self._socket.recv_multipart()
            handle_response(resp)

...
listener = listener.EventListener()
await asyncio.gather(
    listener.receive(), listener.subscribe())
await asyncio.create_task(listener.listen())
...

调试显示，返回的Future对象从未从待处理状态更改为完成状态。那么，我的代码是否正确，是否需要以其他方式等待消息，或者pyzmq的asyncio功能是否有问题？另外，为什么我需要睡在receive()中，这不是为什么我们会有asyncio吗？

最佳答案

查询太多，此答案可能无法解决所有问题。希望至少这将有助于其他人寻找一种设置事件侦听器的方法。

Hyperledger Sawtooth python SDK为客户端提供了订阅事件的选项。可以在https://github.com/hyperledger/sawtooth-sdk-python/blob/master/sawtooth_sdk/messaging/stream.py中找到执行您要执行的操作的代码的SDK部分

可以在此处找到将Hyperledger Sawtooth python SDK用于事件订阅的示例代码。