Thonny mqtt 패키지 설치

Python으로 mqtt Publish하기

import paho.mqtt.client as mqtt              # paho-mqtt 패키지를 사용하고 mqtt로 명명한다.

def on_connect(client, userdata, flags, rc):        # 연결되었을때 수행 
    print("connected with result code " + str(rc))
    

client = mqtt.Client()                              # mqtt.Client() 객체를 받아온다.
client.on_connect = on_connect                      # 연결되면 on_connect를 실행한다.
client.username_pw_set("mjc", "mjc1234")            # 유저명과 비밀번호
client.connect("3.36.108.144", 1883, 60)            # public ips, 포트번호, keepalivetime
client.publish("mjc", "hello mjc")                  # 토픽과 메시지 내용

import paho.mqtt.client as mqtt              # paho-mqtt 패키지를 사용하고 mqtt로 명명한다.
import time

def on_connect(client, userdata, flags, rc):         # 연결되었을때 수행
    print("connected with result code " + str(rc))
    

client = mqtt.Client()                              # mqtt.Client() 객체를 받아온다.
client.on_connect = on_connect                      # 연결되면 on_connect를 실행한다.
client.username_pw_set("mjc", "mjc1234")            # 유저명과 비밀번호
client.connect("3.36.108.144", 1883, 60)            # public ips, 포트번호, keepalivetime
# client.publish("mjc", "hello mjc")                # 토픽과 메시지 내용
# client.loop(2)                              # Publish와 연결이 되어 있는지 계속 확인한다.

no = 1

while True:                                         # 계속 반복한다.
    client.publish("mjc", "hello" + str(no))        # publish , 토픽명, 메시지내용과 카운트
    time.sleep(3)                                   # 3초간 텀을 준다.
    no = no +1                                      # 카운트를 위해 변수 작성

Tools - Manage packages 로 이동한다.

“paho-mqtt” 를 입력하고

paho-mqtt를 누른다.

Install을 누른다.

컴파일 돌리면 connected with result code: 5 에러가 날 수 있다.

이 에러는 인증이 거부된 상태로 유저명과 비밀번호가 틀려서 나오는 에러이다.

client.username_pw_set() 부분이 틀린게 있나 확인한다.

코드를 실행하면 좌측의 Bitvise(Subscribe)에 메시지가 도착한것을 볼 수 있다.

메시지를 일정 시간 계속 보내는 코드이다.

메시지가 반복적으로 Publish 되는것을 볼 수 있다.

Python으로 mqtt Subscribe하기