【Python】ZeroMQのPUBとSUBの使い方 | Udemyのセールを活用してほしかったあのスキルを手に入れよう！【非公式】

Python学習【365日チャレンジ！】330日目のマスターU（@Udemy11）です。

ハリウッドの大物プロデューサーの性的暴行を暴いたジャーナリストの調査報道奇跡を記した【その名を暴け（SHE SAID）】を読みました。

＃Me Too運動によって、次々と社会的立場の高い経営者などが告発されて、その地位を失ったり、犯罪者となったりしましたが、その裏付けを取る調査内容がすべて書き記されているノンフィクション・ドキュメンタリーです。

内容的には、この世の中がどれだけ男性社会であるのかということ、権力者が性欲に支配されて、その地位を利用して女性の性を搾取しているのかがよく分かる内容です。

しかも、映画で表現されるような性的搾取が、暗黙の了解として、長年女性がその状況に甘んじるしかない状態になってしまっていたことが白昼にさらされてなお、そのことに目をつぶる人がどれだけ多いのかということにショックを受けました。

＃Me Too運動によって世の中は変わったとはいえ、実際には日本にもこのような性的搾取を行っている権力者がいるのかもしれません。

それでは今日も、Python学習を始めましょう。

昨日の復習

昨日は、キューイングシステムのZeroMQのPUSHとPULLの使い方について学習しました。

socket通信は、以前にも学習しましたが、同じようにサーバーとクライアントのやり取りを行うことができるのが、キューイングシステムで、ZeroMQは、ジョブをやり取りするブローカーを置かないシステムで、サーバーがPUSHの状態で、クライアントのPULLを受け取ることで値を受け渡しました。

詳細について、昨日の記事をごらんください。

Udemyのセールを活用してほしかったあのスキルを手に入れよう！【非公式】

2021.01.05

【Python】ZeroMQのPUSHとPULL

https://udemyfun.com/python-zeromq-push-pull

Python学習【365日チャレンジ！】329日目のマスターU（@Udemy11）です。そろそろ通常運転の状態に戻さないといけないな〜と思いながら、初詣に行ってきました。流石に5日ともなると、どの神社もガラガラの状態で、安心してお参りすることができました。正月三が日の人出は少なかったとはいえ、今日に比べるとコミコミの状態だったと思いますが、きちんと自粛した方が多い一方、例年と変わらない年末年始を過ごした人も多いんでしょうね。緊急事態宣言を出すとか出さないとかいう話が出ていますが、1週間後には確実に感染者の数が増えて...

今日は、ZeroMQのPUBとSUBの使い方について学習します。

server.py

昨日のPUSHのコードとほぼ同じで、PUBに変更しているだけです。

import time
import zmq

context = zmq.Context()
sock = context.socket(zmq.PUB)
sock.bind("tcp://127.0.0.1:5555")

id = 0
while True:
    id += 1
    sock.send(('sub1:' + str(id)).encode())
    print("Sent: {}".format(id))
    time.sleep(1)

コードは最初に説明したように、5行目のPUSHをPUBに変更しているだけですが、11行目のクライアントに渡すデータにsub1:を付け足しています。

client.py

クライアント側は、PULLをSUBに変えてその後に1行付け加えています。

import zmq

context = zmq.Context()
sock = context.socket(zmq.SUB)
sock.setsockopt(zmq.SUBSCRIBE, b'sub1:')
sock.connect("tcp://127.0.0.1:5555")

while True:
    message = sock.recv()
    print("Received: {}".format(message.decode()))

5行目が付け加えたコードですが、setsockoptで、サーバー側で追加したsub1:を指定しています。

あとのコードは、PULLのときと同じです。