山と警告文 | paho-mqttでIoTの第一歩

Publish

参考: Python で MQTT
まずはサンプルコードをのせる。

#!/usr/local/bin/python3 # いつもの
# -*- coding: utf-8 -*- # いつもの
      
from paho.mqtt import client as mqttcli Paho-mqttをインポート
      
# ブローカーに接続できたときの処理
def on_connect(client, userdata, flag, rc):
  print(f"Connected with result code {rc}")
      
# ブローカーが切断したときの処理
def on_disconnect(client, userdata, rc):
  if rc != 0:
  print("Unexpected disconnection.")
      
# publishが完了したときの処理
def on_publish(client, userdata, mid):
  print(f"publish: {mid}")
      
# メイン関数
def main():
  client = mqttcli.Client() # インスタンスの作成
  client.on_connect = on_connect # 接続時に呼ばれる関数を自分の書いた関数に紐付け
  client.on_disconnect = on_disconnect # 切断時に呼ばれる関数を自分の書いた関数に紐付け
  client.on_publish = on_publish # メッセージ送信時に呼ばれる関数を自分の書いた関数に紐付け
  client.connect("<MQTTブローカーのアドレス>", <MQTTブローカーのポート(default: 1883)>, <接続待ち時間>) # 接続先は自分自身
  client.publish("test/topic", "testmessage", qos=0, retain=True) # トピック名とメッセージを決めて送信
  # 通信処理スタート
  client.loop_start() # subはloop_forever()，pubはloop_start()で起動

      
if __name__ == '__main__': # プログラム実行時にmain()を実行
  main()

ここで、これを実際に実行するとMQTTブローカーにtest/topicというトピックで「testmessage」という文が送られる。ここらへんは適宜変える。
MQTTブローカーもプログラム実行も同じコンピューターで行う場合はMQTTブローカーのアドレスはlocalhostで良い。

送られたかどうかの確認はこのプログラムを実行する前に端末(ターミナル)を2つ用意して、片方の端末でここのSub側のコマンドを実行しておくと、このプログラムを実行したときにメッセージが表示される。

main関数内ではプログラムの前の方で書いてある関数を紐付けている。もし接続時/切断時/メッセージ送信時に付け加えたい処理がある場合は前の方の関数内にそれぞれ書く。 publish()の中の他の引数はオプションで次の意味を持つ。

qos: 0,1,2を指定できる。qosは通信の品質で数字が大きいほどよいが、その分重い。
- 0: MQTTブローカーに対してメッセージを投げっぱなし (最大1回(once at most))
- 1: MQTTブローカーに対してメッセージを投げて、MQTTブローカーから受け取ったという連絡が来るまで同じメッセージを投げる (最低1回(once at least))
- 2: MQTTブローカーに対してメッセージを投げて、MQTTブローカーから受け取ったという連絡が来るまで同じメッセージを投げ、重複して投げないように互いに確認し合う (必ず1回(exacly once))
retain: Trueで送ったメッセージをMQTTブローカーが保持する。次に同じtopicでメッセージが来ると上書きされる。

ページトップに戻る項目別の目次ページに戻る目次ページに戻る Topに戻る

参考: Python で MQTT
まずはサンプルコードをのせる。

#!/usr/local/bin/python3 # いつもの
# -*- coding: utf-8 -*- # いつもの
      
from paho.mqtt import client as mqttcli Paho-mqttをインポート
      
# ブローカーに接続できたときの処理
  def on_connect(client, userdata, flag, rc):
    print(f"Connected with result code {rc}") # 接続できた旨表示
  
      
# ブローカーが切断したときの処理
def on_disconnect(client, userdata, rc):
  if rc != 0:
  print("Unexpected disconnection.")
      
# メッセージが届いたときの処理
def on_message(client, userdata, msg):
  # msg.topicにトピック名が，msg.payloadに届いたメッセージ本文
  print(f"Received message: {bin(int(msg.payload))}, topic: {msg.topic}, QoS: {msg.qos}")
      
def main():
  client = mqttcli.Client() # インスタンスの作成
  client.on_connect = on_connect # 接続時に呼ばれる関数を自分の書いた関数に紐付け
  client.on_disconnect = on_disconnect # 切断時に呼ばれる関数を自分の書いた関数に紐付け
  client.on_message = on_message # メッセージ到着時に呼ばれる関数を自分の書いた関数に紐付け
  client.connect("localhost", 1883, 60) # 接続先が自分自身の場合
  client.subscribe(topic="test/topic", qos=0)
  client.loop_forever() # 永久ループで待ち続ける
      
      
if __name__ == '__main__': # プログラム実行時にmain()を実行
  main()

サンプルプログラムではconnect()の中身をlocalhost, 1883, 60としているが、これはPublishのconnectと同じ引数なので、各自変更する。

subscribeでもQoSを指定できるが、必ずPublish側のQoSと同じか小さくする。ここでのQoSはSubscribe側とMQTTブローカーの通信の品質。
メッセージを受け取った後の処理、例えばonというメッセージを受け取ったらLEDをつけるなどはon_connect()の中に書く。

ページトップに戻る項目別の目次ページに戻る目次ページに戻る Topに戻る

paho-mqttでIoTの第一歩

Paho-mqttの導入

Publish

Subscribe