Orange Pi ZeroからRaspberry PiにMQTTで通信する
Raspberry PiにMosquitto Brokerをインストールしたので、Orange PiからMQTTを用いてpublishし、Raspberry Piでsubscribeしてみます。今回はPythonのMQTT Python client libraryであるpaho-mqttを利用します。
Raspberry Pi (Subscriber) 側の準備
Subscriber側のコード (mqtt_subscriber.py) は以下のようになります:
#!/usr/bin/env python
import paho.mqtt.client as mqtt
host = '127.0.0.1'
port = 1883
keepalive = 60
topic = 'mqtt/test'
def on_connect(client, userdata, flags, rc):
print('Connected with result code ' + str(rc))
client.subscribe(topic)
def on_message(client, userdata, msg):
print(msg.topic + ' ' + str(msg.payload))
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(host, port, keepalive)
client.loop_forever()
on_connect
はBrokerとの接続確立時に呼ばれるコールバック関数です。また、on_message
はBrokerからメッセージを受信した際に呼ばれるコールバック関数です。
あとは、このコードを任意のディレクトリで実行します:
$ virtualenv venv
$ source venv/bin/activate
$ pip install paho-mqtt
$ python mqtt_subscriber.py
Connected with result code 0
Orange Pi (Publisher) 側の準備
Publisher側のコード (mqtt_publisher.py) は以下のようになります:
#!/usr/bin/env python
import time
import paho.mqtt.client as mqtt
host = 'xxx.xxx.xxx.xxx'
port = 1883
keepalive = 60
topic = 'mqtt/test'
client = mqtt.Client()
client.connect(host, port, keepalive)
for i in range(3):
client.publish(topic, 'hello from orangepi')
time.sleep(1)
client.disconnect()
1秒間隔で三回、"hello from orangepi"というメッセージをBrokerにpublishしています。host
にはRaspberry PiのIPアドレスを指定します。
Subscriber側が実行されていることを確認した上で、こちらのコードも実行します:
$ virtualenv venv
$ source venv/bin/activate
$ pip install paho-mqtt
$ python mqtt_publisher.py
実行結果
$ python mqtt_subscriber.py
Connected with result code 0
mqtt/test hello from orangepi
mqtt/test hello from orangepi
mqtt/test hello from orangepi
$ python mqtt_subscriber.py
Connected with result code 0
mqtt/test hello from orangepi
mqtt/test hello from orangepi
mqtt/test hello from orangepi
無事MQTTによってOrange Pi ZeroからRaspberry Piへと通信することができました
Author And Source
この問題について(Orange Pi ZeroからRaspberry PiにMQTTで通信する), 我々は、より多くの情報をここで見つけました https://qiita.com/morinokami/items/ea7afc56fad11389559d著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .