fsblog-20170217-sub_server.py

import sys
import zmq


if (len(sys.argv) != 2):
    print("Usage: # python3 {} <channel>".format(sys.argv[0]))
    sys.exit(1)

ch = sys.argv[1]


# ZeroMQ のバックグラウンド・スレッドのコンテキスト
context = zmq.Context()

# このサーバは、ポート5556で待ちます
socket = context.socket(zmq.SUB)
socket.bind("tcp://*:5556")

# Channel をサブスクライブ
socket.setsockopt_string(zmq.SUBSCRIBE, ch)


while True:
    string = socket.recv_string()
    ch, data = string.split()

    print("Ch {0} -> {1} received".format(ch, data))