1_client_req.py

import zmq
PORT = '4545'
IP = '10.30.0.25'
context = zmq.Context()
print("Menghubungkan ke server...")
socket = context.socket(zmq.REQ)
socket.connect("tcp://{ip}:{port}".format(ip=IP, port=PORT))
tambah = input(
    "Terhubung dengan server, apakah anda ingin mengirim pesan ? y/n \n")
if tambah == 'y':
    socket.send(b"1")
    pesan = socket.recv()
    print("menerima pesan %s" % pesan)
request = 0
while True:
    pesanKirim = input("Client : ")
    if pesanKirim == "stop":
        socket.send(b"stop")
    else:
        socket.send(b"hello clientQ")
    print("mengirim request %s..." % request)
    request = request + 1
    pesanTerima = socket.recv()
    if pesanTerima == b'STOP':
        break
    print("menerima reply %s [%s]" % (request, pesanTerima))

1_server_rep.py

import time
import zmq
PORT = '4545'
IP = '10.30.0.39'
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://{ip}:{port}".format(ip=IP, port=PORT))
lanjut = True
jumlahClient = 0
print("Server berhasil dibuat.")
while True:
    message = socket.recv()
    pesan = list(message)
    if pesan[0] == 49:
        jumlahClient += 1
        socket.send(b'Halo clientQ')
        print("Client saat ini : %s" % jumlahClient)
        message = socket.recv()
    print("Menerima request: %s" % message)
    if message == b'stop':
        lanjut = False
    time.sleep(1)
    if lanjut:
        socket.send(b'Hello client')
    else:
        socket.send(b'STOP')
        jumlahClient = jumlahClient - 1
    if jumlahClient == 0:
        break