fsblog-20170216-sub_client.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.connect("tcp://localhost:5556")

# チャネルの目盛りをあわせる
socket.setsockopt_string(zmq.SUBSCRIBE, ch)


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

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