[MQTT] python 으로 sub / pub 구현하기

MQTT와 Kakfa 비교

kafka와 mqtt에 대해서 찾아보고 정리했다.

그리고는 mqtt를 한번 사용해 보려고 한다.

 

진행

1. python으로 topic에 message를 전송한다.

2. MQTT Explorer로 message를 잘 받는지 확인한다.

3. python으로 topic을 subscribe하고 message를 확인한다.

 

(0) pip 설치

pip install paho-mqtt

 

(1) python - message 전송

import paho.mqtt.client as mqtt

BROKER = "test.mosquitto.org"
PORT = 1883
TOPIC = "topicA"

client = mqtt.Client()

client.connect(BROKER, PORT, 60)

def publish_message(client, topic, message):
    client.publish(topic, message)
    print(f"Sent message: {message} on topic: {topic}")
    
client.loop_start()

try:
    publish_message(client, TOPIC, "Hello, this is a test message")
finally:
    client.loop_stop()
    client.disconnect()

 

> 실행하면 아래와 같이 확인할 수 있다.

Sent message: Hello, this is a test message on topic: topicA

 

(2) MQTT Explorer

아래와 같이 message를 확인할 수 있다.

 

(3) python - message 받기

import paho.mqtt.client as mqtt

BROKER = "test.mosquitto.org"
PORT = 1883
TOPIC = "topicA"

def on_message(client, userdata, message):
    print(f"Received message: '{message.payload.decode()}' on topic: '{message.topic}'")

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to broker successfully")
        client.subscribe(TOPIC)
        print(f"Subscribed to topic: {TOPIC}")
    else:
        print(f"Failed to connect, return code {rc}")

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(BROKER, PORT, 60)

client.loop_forever()

 

> 실행하면 client에 연결된 상태를 유지하며, (1) message 전송 에서 보내는 message를 받을 수 있다.

Connected to broker successfully
Subscribed to topic: topicA
Received message: 'Hello, this is a test message' on topic: 'topicA'