zmq async client server
2020.03.12 21:39
번호 | 제목 | 글쓴이 | 날짜 | 조회 수 |
---|---|---|---|---|
1686 | ubuntu cuda nvidia-smi | WHRIA | 2020.08.29 | 849 |
1685 | concat network [3] | WHRIA | 2020.08.27 | 147 |
1684 | GPT2 [1] | WHRIA | 2020.08.03 | 250 |
1683 | scopus [1] | WHRIA | 2020.08.02 | 344 |
1682 | melafind | WHRIA | 2020.08.01 | 771 |
1681 | nvidia dali [1] | WHRIA | 2020.08.01 | 265 |
1680 | pytorch optimize | WHRIA | 2020.08.01 | 126 |
1679 | startup , 미국 | WHRIA | 2020.07.30 | 134 |
1678 | consort , stard | WHRIA | 2020.07.30 | 81 |
1677 | model split [1] | WHRIA | 2020.07.30 | 142 |
1676 | FTC [1] | WHRIA | 2020.07.28 | 238 |
1675 | 암호화 | WHRIA | 2020.07.26 | 1000 |
1674 | raid 6 | WHRIA | 2020.07.23 | 43 |
1673 | asyncio | WHRIA | 2020.07.23 | 286 |
1672 | amp distributed pytorch [1] | WHRIA | 2020.07.14 | 51 |
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))