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

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

そろそろ通常運転の状態に戻さないといけないな〜と思いながら、初詣に行ってきました。

流石に5日ともなると、どの神社もガラガラの状態で、安心してお参りすることができました。

正月三が日の人出は少なかったとはいえ、今日に比べるとコミコミの状態だったと思いますが、きちんと自粛した方が多い一方、例年と変わらない年末年始を過ごした人も多いんでしょうね。

緊急事態宣言を出すとか出さないとかいう話が出ていますが、1週間後には確実に感染者の数が増えているんでしょうね。

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

昨日の復習

昨日は、キューイングシステムについて学習しました。

キューにジョブを預けることでシステムの負荷を考えてジョブを割り振ることができるのがキューイングシステムで、ブローカーなしとブローカありがあって、それぞれにメリット・デメリットがあることを学習しました。

くわしくは、昨日の記事をごらんください。

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

2021.01.04

【Python】キューイングシステムとは

https://udemyfun.com/python-queueing-system

Python学習【365日チャレンジ！】328日目のマスターU（@Udemy11）です。2日に体重が5kgも増えたという報告をしましたが、さらに2kg追加して、年末から年始にかけて、7kgも体重が増えてしまいました。7kgも増えると動くのがめちゃくちゃしんどくて、常に膨満感を感じている状態なので、これからは食べる量をきちんとセーブして、徐々に体重を減らしていこうと思います。釣りにも行ってなかったので、年始の釣り初めにも行きたいのですが、朝は寒さでなかなか布団から出られず、夜はお腹いっぱいで出かける気になれない状態から抜け出せ...

今日は、ブローカーなしキューイングシステムのZeroMQのPUSHとPULLの使い方について学習します。

ZeroMQのインストール

まずはpipでZeroMQをインストールします。

pip install pyzmq

ターミナルから上記コマンドでZeroMQをインストールしたら、サーバー、クライアントのコードを書いていきます。

server.py

サーバー側でクライアントの要求を受けて値を返すコードを書いていきます。

import time
import zmq

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

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

必要なライブラリをインポートしたあと、contextというオブジェクトを作ります。

次に、zmqのPUSHであるsocketオブジェクトをsockとして作成します。

6行目でTCPでIPアドレスとポート番号を指定して、ソケットをバインドします。

8行目でidを0にして、whileループで回して1を足して、ソケットでidをsendした状態にして、クライアントがPULLで取りに来たら、print出力でSent:IDを出力して、最終行のsleepで1秒待ってループを繰り返します。

client.py

クライアント側は、サーバーと同じように、コンテキストを作成して、zmqは、PULLでサーバー側からメッセージを受け取りに行きます。

import zmq

context = zmq.Context()
sock = context.socket(zmq.PULL)
sock.connect("tcp://127.0.0.1:5555")

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

3行目までは、timeのインポートがないだけで、サーバー側と同じですね。

4行目は、PUSHではなく、PULLにして、5行目はbindではなく、connectにしています。

7行目からはwhileループで、socketに入っているidを取得してmessageに入れて、9行目でprint出力でReceived:IDと出力します。