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))