zmq async client server
2020.03.12 21:39
번호 | 제목 | 글쓴이 | 날짜 | 조회 수 |
---|---|---|---|---|
1641 | 죄송합니다. 하이텔에서 [그냥 드립니다.]에서 | 오영택 | 2000.08.23 | 4014 |
1640 | 영세 축하합니다 | 안소정 | 2000.08.23 | 4568 |
1639 | 재미있는 핸드폰 문자 모음. | 한승석 | 2000.08.25 | 3295 |
1638 | 승석아 안녕? | 김지현 | 2000.08.26 | 3535 |
1637 | 승석아 | 재호 | 2000.08.26 | 3813 |
1636 | Re: 승석아 | 한승석 | 2000.08.26 | 3355 |
1635 | ◆ 어느 여학생의 비밀 | 한승석 | 2000.08.26 | 3764 |
1634 | 이 게시판에 쉽게 오려면 http://han.oo.co.kr 로~ | 한승석 | 2000.08.26 | 3422 |
1633 | 아 그리고 축하해 | 김지현 | 2000.08.26 | 3649 |
1632 | 질문 | 채영광 | 2000.08.27 | 3646 |
1631 | Celebrate you to the world of God! | 채영광 | 2000.08.27 | 4641 |
1630 | 승석아 너를 위한 63개의 글귀야. 선물! | 채영광 | 2000.08.27 | 2240 |
1629 | 여자와 남자의 사랑이야기 | 한승석 | 2000.08.28 | 3076 |
1628 | ◆돈 고 | 한승석 | 2000.08.29 | 2779 |
1627 | 또하나의 주소 http://newtype.pe.ky | 한승석 | 2000.08.29 | 3102 |
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))