1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
"""Example showing ZMQ with asyncio and tornadoweb integration."""
# Copyright (c) PyZMQ Developers.
# This example is in the public domain (CC-0)
import asyncio
import zmq.asyncio
from tornado.ioloop import IOLoop
from tornado.platform.asyncio import AsyncIOMainLoop
# Tell tornado to use asyncio
AsyncIOMainLoop().install()
# This must be instantiated after the installing the IOLoop
queue = asyncio.Queue()
ctx = zmq.asyncio.Context()
async def pushing():
server = ctx.socket(zmq.PUSH)
server.bind('tcp://*:9000')
while True:
await server.send(b"Hello")
await asyncio.sleep(1)
async def pulling():
client = ctx.socket(zmq.PULL)
client.connect('tcp://127.0.0.1:9000')
while True:
greeting = await client.recv()
print(greeting)
def zmq_tornado_loop():
loop = IOLoop.current()
loop.spawn_callback(pushing)
loop.spawn_callback(pulling)
loop.start()
if __name__ == '__main__':
zmq_tornado_loop()
|
