zmq async client server
2020.03.12 21:39
번호 | 제목 | 글쓴이 | 날짜 | 조회 수 |
---|---|---|---|---|
1686 | Mediainfo 를 이용해서 날짜 알아내기 | WHRIA | 2012.12.20 | 10405 |
1685 | 마음이 편해지는 그림 | WHRIA | 2007.02.18 | 10356 |
1684 | 마음의 결정이 끝났습니다. | WHRIA | 2009.11.20 | 10334 |
1683 | 애드센스 수입금 - 48만원 | WHRIA | 2010.12.28 | 10277 |
1682 | MedicalPhoto moved to http://medicalphoto.org | WHRIA | 2008.06.20 | 10104 |
1681 | rAthena [1] | WHRIA | 2016.06.26 | 10074 |
1680 | 어려운 결정 | WHRIA | 2008.10.11 | 10019 |
1679 | 피얼룩 지우기 | WHRIA | 2012.05.26 | 9956 |
1678 | Trader | WHRIA | 2009.11.17 | 9882 |
1677 | 승석이 홈페이지입니다. | 한승석 | 2000.05.29 | 9874 |
1676 | 피부과 홈페이지 제작중 | WHRIA | 2009.11.11 | 9712 |
1675 | 일본으로 workshop 초청이 왔는데 못가게 되었다. [1] | WHRIA | 2009.11.23 | 9632 |
1674 | 간판 제작 업체 | WHRIA | 2009.10.31 | 9558 |
1673 | 인플레이션인가 디플레이션인가 | WHRIA | 2009.06.21 | 9546 |
1672 | 돌사진 | WHRIA | 2011.03.21 | 9446 |
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))