mqtt pub 소스 > 소스코드

본문 바로가기

회원로그인

회원가입

소스코드

python mqtt pub 소스

페이지 정보

profile_image
작성자 최고관리자
댓글 0건 조회 70회 작성일 22-06-28 11:31

본문

import paho.mqtt.client as mqtt
import json


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_publish(client, userdata, mid):
    print("In on_pub callback mid= ", mid)


# 새로운 클라이언트 생성
client = mqtt.Client()
# 콜백 함수 설정 on_connect(브로커에 접속), on_disconnect(브로커에 접속중료), on_publish(메세지 발행)
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_publish = on_publish

# address : localhost, port: 1883 에 연결
client.username_pw_set("mqtt아이디", "mqtt비번")
client.connect('mqtt 서버주소', 1883)

client.loop_start()

# common topic 으로 메세지 발행
client.publish('python/pub1', json.dumps({"success": "ok"}), 1)
client.loop_stop()

# 연결 종료
client.disconnect()

댓글목록

등록된 댓글이 없습니다.