<div id="readability-page-1" class="page"><div>
 <div id="SE-771770ee-095c-4031-9d1e-adb22e849c34">
 우분투(Ubuntu) MQTT 브로커(서버) 만들기 링크<a href="https://blog.naver.com/chandong83/224225398438" data-linktype="text" data-linkdata="{&quot;id&quot;: &quot;SE-2c5d051b-935c-4569-a914-b797594c38b4&quot;, &quot;link&quot;: &quot;https://blog.naver.com/chandong83/224225398438&quot;}" target="_blank">https://blog.naver.com/chandong83/224225398438</a>지난번에 우분투에 MQTT 브로커를 설치하는 방법을 다뤄봤다.​이번에는 파이썬(Python)에서 MQTT 사용하는 방법을 알아보자.​여기서는 paho-mqtt 라는 라이브러리를 이용할 것이다.​1. paho-mqtt 설치하기
 </div> <div id="SE-3f6a71df-0252-4c41-b0be-07ea3edb429a">
 파이썬 라이브러리(패키지) 관리 도구인 pip를 이용해 paho-mqtt를 설치한다.​​2. Publisher 예제아래의 코드는 2초 간격으로 메시지를 전송(발행) 하는 코드이다.코드에 대한 설명은 코드가 복잡하지 않아 주석으로 대체한다.
 </div> <div id="SE-e21ad47e-f402-483b-8249-67c0fe9fceb9">
 import paho.mqtt.client as mqtt
import time

BROKER = "192.168.1.2" # MQTT 브로커 IP
PORT = 1883 # MQTT 포트
TOPIC = "test/topic" # 사용할 토픽

# mqtt 클라이언트 변수 선언
client = mqtt.Client() 

# 인증 사용 시, 필요 없으면 주석
client.username_pw_set("user1", "user1")

# MQTT 브로커 연결
client.connect(BROKER, PORT, 60)

'''
루프 돌면서 2초에 한번씩 "test/topic" 토픽으로 25.3이라는 메시지를 전송
'''
while True:
 msg = "25.3" 
 client.publish(TOPIC, msg, qos=1)
 print(f"Sent: {msg}")
 time.sleep(2)
 </div> <div id="SE-91d0a43c-7fc6-4062-a29c-2f1f15ebb836">
 ​3. Subscriber 예제구독(Subscribe) 관련 예제이다.발행(Publish)보다는 조금 복잡하지만 주석만으로도 설명이 될 것 같아 보인다.mqtt 브로커에 연결하고 연결이 되면 topic을 구독 등록을 하여 해당 토픽이 올 때마다 메시지를 출력하는 간단한 코드이다.
 </div> <div id="SE-d7b5586a-e623-458d-9964-a042629bd668">
 import paho.mqtt.client as mqtt

BROKER = "192.168.1.2" # MQTT 브로커 IP
PORT = 1883 # MQTT 포트
TOPIC = "test/topic" # 사용할 토픽

# 연결시 호출되는 콜백
def on_connect(client, userdata, flags, rc):
 print("Connected with result code", rc)
 client.subscribe(TOPIC) # 토픽 등록

# 구독(subscribe)된 토픽이 발행(publish)되면 호출되는 콜백
def on_message(client, userdata, msg):
 print(f"Received: {msg.topic} -&gt; {msg.payload.decode()}")

# mqtt 선언
client = mqtt.Client()

# 인증 사용 시, 불필요시 주석
client.username_pw_set("user1", "user1")

# 콜백 함수들 등록
client.on_connect = on_connect
client.on_message = on_message

# 연결
client.connect(BROKER, PORT, 60)

# 종료시까지 무한 대기
client.loop_forever()
 </div> <div id="SE-7dbe2790-2d9d-4eb6-9840-eae1d085ed35">
 ​4. 발행과 구독 동시 사용 예제아래의 코드는 위 두 가지를 하나의 프로젝트에서 사용하는 예제 코드이다.실제 해당 코드를 응용해 코드를 구성하면 간단한 어플리케이션은 가능할 것 같다.주석으로 설명은 대체한다.
 </div> <div id="SE-9f64cd05-31d5-4da5-87b2-3966aaa0bc96">
 import paho.mqtt.client as mqtt
import time

BROKER = "192.168.1.2"
PORT = 1883
SUB_TOPIC = "test/topic" # 구독용 토픽
PUB_TOPIC = "test/topic" # 발행용 토픽

# 연결이 완료되면 호출되는 함수 
def on_connect(client, userdata, flags, rc):
 print("Connected:", rc)
 client.subscribe(SUB_TOPIC) # 구독할 토픽 등록

# 연결이 해제되면 호출되는 함수
# MQTT는 네트워크 상태에 따라 연결이 끊길 수 있으므로
# 자동 재연결 처리가 필요함
def on_disconnect(client, userdata, rc):
 print("Disconnected. Reconnecting...")
 while True:
 try:
 # MQTT를 재연결
 client.reconnect()
 break
 except:
 time.sleep(2)

# 구독한 메시지 수신시 호출되는 함수
def on_message(client, userdata, msg):
 print(f"[{msg.topic}] {msg.payload.decode()}")

# MQTT 클라이언트 선언
client = mqtt.Client()

# 인증, 불필요시 주석
client.username_pw_set("user1", "user1")

# 각 콜백함수 매핑
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_message = on_message

# 연결시도
client.connect(BROKER, PORT, 60)

# 백그라운드 스레드 실행
client.loop_start()

# 메시지 주기적으로 발행(5초)
while True:
 client.publish(PUB_TOPIC, "alive", qos=1)
 time.sleep(5)
 </div> <div id="SE-075e6ca6-ac99-41f4-9052-0177f1664714">
 ​5. Json 형태의 발행 예제보통 MQTT 사용 시 json 형태로 메시지들을 주고받는다.
 </div> <div id="SE-bbd67aca-7e59-4b43-9d36-d081868a7c2d">
 import json
import paho.mqtt.client as mqtt

BROKER = "192.168.1.2" # MQTT 브로커 IP
PORT = 1883 # MQTT 포트
TOPIC = "test/topic" # 사용할 토픽

# 토픽에 보낼 메시지 형태 
# 딕셔너리 형태로 변수 선언 이후 json 을 변환되어 전송될 것이다.
data = {
 "device_id": "device1",
 "temp": 25.3,
 "status": "ok"
}

# mqtt 클라이언드 선언
client = mqtt.Client()

# 인증 사용, 불필요시 주석
client.username_pw_set("user1", "user1")

# mqtt 브로커에 연결
client.connect(BROKER, PORT, 60)

# 토픽을 json 형태로 전송
client.publish(
 TOPIC,
 json.dumps(data),
 retain=True, # 브로커에 저장해 디바이스 연결시 해당 토픽 전달
 qos=1
)
 </div> <div id="SE-e733b416-f327-43bc-8d89-574c8b7573f4">
 publish 시 json 형태로 변환하는 코드가 포함된 것을 볼 수 있을 것이다.추가로 retain 옵션을 true로 설정하면 해당 메시지는 브로커에 저장된다.​이후 동일한 토픽을 구독하는 클라이언트(장치)가 새로 연결되면, 저장된 마지막 메시지(최종 상태)가 즉시 전달된다.​따라 사 장치의 상태 값과 같이 최종 상태를 유지해야 하는 데이터라면 retain 옵션을 사용하여 전송하는 것이 효과적이다.
 </div> </div></div>

하이! 제니스

우분투(Ubuntu) MQTT 브로커(서버) 만들기 링크 https://blog.naver.com/chandong83/224225398438 지난번에 우분투에 MQTT 브로커를 설치하는 방법을 다뤄봤다. 이번에는 파이썬(Python)에서 MQTT 사용하는 방법을 알아보자. 여기서는 paho-mqtt 라는 라이브러리를 이용할 것이다. 1. paho-mqtt 설치하기 파이썬 라이브러리(패키지) 관리 도구인 pip를 이용해 paho-mqtt를 설치한다. 2. Publisher 예제 아래의 코드는 2초 간격으로 메시지를 전송(발행) 하는 코드이다. 코드에 대한 설명은 코드가 복잡하지 않아 주석으로 대체한다. 3. Subscriber 예제 구독(Subscribe) 관련 예제이다. 발행(Publish)보다는 조금 복잡하지만 주석만으로도 설명이.......

파이썬 - MQTT 사용하기 paho-mqtt

댓글