Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Sudo apt-get update
- sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa
- sudo apt-get update
- sudo apt-get install mosquitto
- sudo apt-get install mosquitto-clients
- sudo nano /etc/mosquitto/mosquitto.conf
- listener 1883
- listener 1884
- protocol mqtt
- listener 2883
- protocol websockets
- # Este script publica mensajes MQTT
- import paho.mqtt.client as mqtt
- import json
- client = mqtt.Client()
- client.connect("192.168.1.100", 1883, 60)
- client.publish("test", 'Este es mi primer mensaje')
- client.disconnect()
- # Este script escucha los mensajes MQTT
- import paho.mqtt.client as mqtt
- def on_message_test(mosq, obj, msg):
- print("Recibió el mensaje de : " + msg.topic + " que dice " + str(msg.payload))
- mqttc = mqtt.Client()
- mqttc.message_callback_add("test", on_message_test)
- mqttc.on_message = on_message
- mqttc.connect("192.168.1.100", 1883, 60)
- mqttc.subscribe("test", 0)
- mqttc.loop_forever()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement