Mqtt demo code

mqtt-example.md

Mqtt Example

About

This is the example code of mqtt.

pub.py

import paho.mqtt.client as mqtt
import time

client = mqtt.Client()
client.connect('localhost', 1883, keepalive=60)
client.loop_start()

while True:
    client.publish('/message', 'test')
    time.sleep(1)

sub.py

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, respons_code):
    print('connected')
    client.subscribe('/message')

def on_message(client, userdata, msg):
    print(msg.topic + ' ' + str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect('localhost', 1883, keepalive=60)
client.loop_forever()