zmq async client server
2020.03.12 21:39
번호 | 제목 | 글쓴이 | 날짜 | 조회 수 |
---|---|---|---|---|
199 | lvm 축소 확장 [4] | WHRIA | 2020.01.13 | 81 |
198 | nvidia docker | WHRIA | 2020.01.15 | 53 |
197 | exif remove | WHRIA | 2020.01.28 | 49 |
196 | batch normalize | WHRIA | 2020.02.06 | 51 |
195 | airplane | WHRIA | 2020.02.10 | 200 |
194 | sql 중복제거 | WHRIA | 2020.02.10 | 50 |
193 | sql replication 성공 [1] | WHRIA | 2020.02.20 | 51 |
192 | calendar javascript dropdown | WHRIA | 2020.03.01 | 41 |
191 | multiple NIC ubuntu [6] | WHRIA | 2020.03.10 | 55 |
190 | CIDR 표기법 [1] | WHRIA | 2020.03.12 | 75 |
» | zmq async client server [1] | WHRIA | 2020.03.12 | 69 |
188 | plum | WHRIA | 2020.04.03 | 77 |
187 | kernel load | WHRIA | 2020.04.03 | 48 |
186 | chatbot | WHRIA | 2020.04.03 | 56 |
185 | fcitx | WHRIA | 2020.04.05 | 77 |
REP 서버
import sys import asyncio import zmq import zmq.asyncio import random ctx = zmq.asyncio.Context() async def run_server(*ports): sock = ctx.socket(zmq.REP) for port in ports: sock.bind(f'tcp://*:{port}') while True: request = await sock.recv_string() print(f'RECEIVED:\t{request}') print(f'PROCESSING...') await asyncio.sleep(random.randrange(5,30) / 10) print(f'SENDING:\t{request}') await sock.send_string(request) if __name__ == '__main__': ports = sys.argv[1:] if len(sys.argv) > 1 else (5556,) asyncio.run(run_server(*ports))
REQ 클라이언트
import sys import asyncio import zmq import zmq.asyncio ctx = zmq.asyncio.Context() async def run_client(*ports): sock = ctx.socket(zmq.REQ) for port in ports: sock.connect(f'tcp://localhost:{port}') while True: line = input('>>') print(f'SENDING:\t{line}') await sock.send_string(line) reply = await sock.recv_string() print(f'RECEIVED:\t{reply}') if line == 'bye': break if __name__ == '__main__': ports = sys.argv[1:] if len(sys.argv) > 1 else (5556,) asyncio.run(run_client(*ports))