🐍 Python * MQTT module paho를 이용한 MQTT 통신

 

설치하기

1. Download

$ pip install paho-mqtt

2. MQTT 통신

$ sudo git clone https://github.com/eclipse/paho.mqtt.python.git
$ cd org.eclipse.paho.mqtt.python.git
$ sudo python setup.py install

- 처음 명령어를 쳤을 때 git을 설치라고 하면 설치 후 진행하셔야 합니다. ( 친절하게 명령어 가르쳐 줘요 )

- 동작 시 root 계정으로 로그인 하시고 위의 명령어를 쳐주세요.

- 그리고 저 같은 경우 위의 명령어에서 제시한 위치(org.eclipse.paho.mqtt.python.git)에 깔리지 않아 setup.py 파일이 있는 곳으로 찾아갔습니다. 그냥 현 위치에서 ls 하니까 paho.mqtt.python이 나오더라구요.

3. Download 확인

- finished processing dependencies for paho-mqtt==1.3.0 문구를 확인 해 줍니다.

 

 

 

Python Paho 모듈 사용해보기

1. Subscribe file 생성하기

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

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc) :
	print "Connected with result cod", str(rc)
	client.subscribe("HELLO/WORLD")

def on_message(client, userdata, msg) :
	print "\n", msg.topic, " ", str(msg.payload)

client = mqtt.Client()
client.on_connect = on_connect
client.on_message =  on_message # on_message callback set

client.connect("test.mosquitto.org", 1883, 60) # MQTT server connect
client.loop_forever()

2. Publish file 생성하기

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

import paho.mqtt.client as mqtt

mqttc = mqtt.Client("python_pub")
mqttc.connect("test.mosquitto.org", 1883) 
mqttc.publish("HELLO/WORLD", "hello world!!!!!!!!!!!!!!!!!!!!!!!!!!!!")

mqttc.loop(2)

3. 코드 동작 시켜보기

[ 왼쪽: Subscribe / 오른쪽: Publish ]

 

 

---

Tanks for

• 파이썬으로 만들어보는 간단한 MQTT 클라이언트
• Python Client
• [python]MQTT 프로토콜 기반 GUI 멀티쓰레드 채팅 프로그램
• 라즈베리파이 MQTT - 파이썬 라이브러리 설치