ZeroMQ：Pythonでの高性能メッセージングライブラリ

pip install pyzmq

import zmq

# ZeroMQコンテキストを作成
context = zmq.Context()

# REPソケットを作成し、ポート5555でバインド
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")

print("Server is listening on port 5555...")

while True:
    # クライアントからのリクエストを受け取る
    message = socket.recv()
    print(f"Received request: {message}")

    # クライアントに応答を送信
    socket.send(b"World")

import zmq

# ZeroMQコンテキストを作成
context = zmq.Context()

# REQソケットを作成し、ポート5555のサーバに接続
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")

# サーバにリクエストを送信
print("Sending request: Hello")
socket.send(b"Hello")

# サーバからの応答を受け取る
message = socket.recv()
print(f"Received reply: {message}")

python zmq_server.py

python zmq_client.py

import zmq
import time

# ZeroMQコンテキストを作成
context = zmq.Context()

# PUBソケットを作成し、ポート5556でバインド
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5556")

print("Publisher is listening on port 5556...")

while True:
    # トピックとメッセージを送信
    topic = "Topic1"
    message = "Hello, World!"
    print(f"Sending message on {topic}: {message}")
    socket.send_string(f"{topic} {message}")
    time.sleep(1)

import zmq

# ZeroMQコンテキストを作成
context = zmq.Context()

# SUBソケットを作成し、ポート5556のパブリッシャに接続
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5556")

# "Topic1"のメッセージを購読
topic = "Topic1"
socket.setsockopt_string(zmq.SUBSCRIBE, topic)

print(f"Subscribed to {topic}")

while True:
    # メッセージを受信
    message = socket.recv_string()
    print(f"Received message: {message}")

python zmq_publisher.py

python zmq_subscriber.py