Basic aiozmq sender-receiver

receive.py

import asyncio
import itertools

import aiozmq
import zmq


async def main():
    router = await aiozmq.create_zmq_stream(zmq.ROUTER, bind="tcp://127.0.0.1:5555")

    for i in itertools.count():
        ident, data = await router.read()
        print("Received", i)
        # router.write((ident, b""))


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

send.py

import asyncio
import itertools

import aiozmq
import zmq


async def main():
    dealer = await aiozmq.create_zmq_stream(zmq.DEALER)
    dealer.transport.setsockopt(zmq.IDENTITY, b"1234")
    await dealer.transport.connect("tcp://127.0.0.1:5555")

    for i in itertools.count():
        print("Sending", i)
        dealer.write([b""])
        # await dealer.read()


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())