Publisher：topic名="Topic1"に "test1"というメッセージを送信する
Subscriber ：topic名="Topic1"のメッセージを受け取る

# -*- coding: utf-8 -*-

import paho.mqtt.client as mqtt  # ライブラリのimport

# MQTT Broker
MQTT_HOST = "MQTT_broker"       # brokerのアドレス
MQTT_PORT = 1883                # brokerのport
MQTT_KEEP_ALIVE = 60            # keep alive

# broker接続時
def on_connect(mqttc, obj, flags, rc):
    print("rc: " + str(rc))             # 接続結果表示

mqttc = mqtt.Client()    #clientオブジェクト作成
mqttc.on_connect = on_connect  # 接続時に実行するコールバック関数設定

mqttc.connect(MQTT_HOST, MQTT_PORT, MQTT_KEEP_ALIVE)  # MQTT broker接続

mqttc.loop_start() # 処理開始

mqttc.publish("topic1", "test1")  # topic名="Topic1"に "test1"というメッセージを送信

import paho.mqtt.client as mqtt

# MQTT Broker
MQTT_HOST = "MQTT_broker"       # brokerのアドレス
MQTT_PORT = 1883                # brokerのport
MQTT_KEEP_ALIVE = 60            # keep alive

# broker接続時
def on_connect(mqttc, obj, flags, rc):
    print("rc: " + str(rc))

#メッセージ受信時
def on_message(mqttc, obj, msg):
    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))

mqttc = mqtt.Client()
mqttc.on_message = on_message  # メッセージ受信時に実行するコールバック関数設定
mqttc.on_connect = on_connect
mqttc.connect(MQTT_HOST, MQTT_PORT, MQTT_KEEP_ALIVE)

mqttc.subscribe("topic1")  # Topic名："topic1"を購読

mqttc.loop_forever()  # 永久ループ

# python pub_test1.py
rc: 0

# python sub_test1.py
rc: 0
topic1 0 b'test1'

Publisher：topic名="Topic1"に "test1"というメッセージを送信する
Subscriber ：topic名="Topic1"のメッセージを受け取ったらフラグ有効化し、ループを抜ける

# -*- coding: utf-8 -*-

import paho.mqtt.client as mqtt
import time

# MQTT Broker
MQTT_HOST = "MQTT_broker"       # brokerのアドレス
MQTT_PORT = 1883                # brokerのport
MQTT_KEEP_ALIVE = 60            # keep alive

# broker接続時
def on_connect(mqttc, obj, flags, rc):
    print("rc: " + str(rc))

#メッセージ受信時
def on_message(mqttc, obj, msg):
    global on_message_Flag         # メインループと共有するグローバル変数
    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
    on_message_Flag=True          # flagを有効化

mqttc = mqtt.Client()
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.connect(MQTT_HOST, MQTT_PORT, MQTT_KEEP_ALIVE)

mqttc.subscribe("topic1")
mqttc.loop_start()
on_message_Flag=False                # 共有するグローバル変数
i=0
while True:
    print(i)
    i+=1
    time.sleep(1)
    if on_message_Flag:              # フラグがTrueになるとループEND
        print("END!")
        break

# python pub_test1.py
rc: 0

# python sub_test2.py
0
rc: 0
1
2
3
4
5
topic1 0 b'test1'
END!

関連記事

• Python Tkinter のダイアログボックスをカスタマイズしてみた
• Pythonとデータフレームについて
• 社会人版-勉強の仕方

一緒に開発しませんか？

サンビット株式会社では、開発技術者を募集しています！
興味のある方はぜひお問い合わせください。

• サンビット株式会社　採用サイト