python mqtt sub 소스
페이지 정보
본문
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("connected OK")
else:
print("Bad connection Returned code=", rc)
def on_disconnect(client, userdata, flags, rc=0):
print(str(rc))
def on_subscribe(client, userdata, mid, granted_qos):
print("subscribed: " + str(mid) + " " + str(granted_qos))
def on_message(client, userdata, msg):
print(str(msg.payload.decode("utf-8")))
# 새로운 클라이언트 생성
client = mqtt.Client()
# 콜백 함수 설정 on_connect(브로커에 접속), on_disconnect(브로커에 접속중료), on_subscribe(topic 구독),
# on_message(발행된 메세지가 들어왔을 때)
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_subscribe = on_subscribe
client.on_message = on_message
# address : localhost, port: 1883 에 연결
client.username_pw_set("mqtt아이디", "mqtt비번")
client.connect('mqtt서버', 1883)
# common topic 으로 메세지 발행
client.subscribe('python/#', 1)
client.loop_forever()
- 이전글mqtt pub 소스 22.06.28
- 다음글다음지도 api - 주소로 표시하기 22.05.13
댓글목록
등록된 댓글이 없습니다.