python mqtt 설치 및 세팅 요령

IoT 장비를 한참 만질 때 많이 사용했다.

참 편하게 잘되어있다.

 

펌웨어 개발할 때 역시 참 편하다.

python이 아니더라도 mqtt를 사용하는 방법은 다양하다.

 

pip install paho-mqtt

https://pypi.org/project/paho-mqtt/

paho-mqtt

 

함수에 대한 자세한 설명은 생략하고

 

기존에 mqtt통신하는 서버는 있다고 가정한 후 

 

명령만 보내는 구조이다.

 

이후로 붙이기 나름

client = mqtt.Client()
client_pub = mqtt.Client()
client_pub.connect(mqtt_ip, 1883)
self.client.subscribe({세팅한 주소}, {0, 1, 2})
client_pub.loop_start()

랜선으로 잡으면 상관이 없지만 IoT 장비일 수록 작고 무선으로 통신을 많이해서

 

끊어지는 것도 고려해야한다.

 

def on_message(self, client, userdata, msg):
    if str(msg.payload.decode("utf-8")) == '어떤 명령어':
        client.loop_stop()
        client.unsubscribe({세팅한 주소})
        client.disconnect()

 

연결하고 명령을 보내고 끊어주고

 

이런 식으로 하면 편하고 그게아니라면 수시로 연결이 끊어지면 붙여주거나 하면 된다.

 

mqtt 브로커끼리 브릿지해서 쓸 수 도 있고 방법은 무궁무진하다.