Difference between revisions of "Mosquitto"
Jump to navigation
Jump to search
(→Python) |
(→Python) |
||
Line 46: | Line 46: | ||
===Python=== |
===Python=== |
||
+ | ====Publication en Python==== |
||
[[Image:Rpi+arduino.jpg|200px|thumb|right|RPI + Arduino running Mosquitto MQTT publisher]] |
[[Image:Rpi+arduino.jpg|200px|thumb|right|RPI + Arduino running Mosquitto MQTT publisher]] |
||
Publication depuis le Raspberry Pi (et un Arduino) http://mosquitto.org/documentation/python/ |
Publication depuis le Raspberry Pi (et un Arduino) http://mosquitto.org/documentation/python/ |
||
Line 169: | Line 170: | ||
</pre> |
</pre> |
||
+ | ====Souscription en Python==== |
||
Souscription depuis l'hôte http://mosquitto.org/documentation/python/ |
Souscription depuis l'hôte http://mosquitto.org/documentation/python/ |
Revision as of 11:06, 20 August 2013
Serveur MQTT écrit en C et C++
Installation rapide et simple
Premiers pas
Installation
sur Raspberry Pi
wget https://bitbucket.org/pypa/setuptools/raw/bootstrap/ez_setup.py -O - | python sudo python get-pip.py
sur MacOS X
brew install mosquitto
sur Ubuntu
http://mosquitto.org/2013/01/mosquitto-debian-repository/
Lancement du broker
Lancez le broker Mosquitto sur l'hôte (10.0.1.3). Remarque : le broker est parfois lancé via initd (vérifiez avec ps -ax | grep mosquitto )
mosquitto
Publication & Souscription
Command lines
Souscription depuis l'hôte http://mosquitto.org/man/mosquitto_sub-1.html
BROKER=10.0.1.3 mosquitto_sub -h $BROKER -d -t arduino/temp
Publication depuis le Raspberry Pi http://mosquitto.org/man/mosquitto_pub-1.html
BROKER=10.0.1.3 mosquitto_pub -h $BROKER -d -t arduino/temp -m "100"
Python
Publication en Python
Publication depuis le Raspberry Pi (et un Arduino) http://mosquitto.org/documentation/python/
BROKER=10.0.1.3 python publisharduino.py $BROKER
#!/usr/bin/python # # simple app to read string from serial port (arduino board) # and publish via MQTT # # uses the Python MQTT client from the Mosquitto project # http://mosquitto.org # # initially Andy Piper http://andypiper.co.uk # 2011/09/15 import serial import mosquitto import os import sys broker=sys.argv[1] port = 1883 serialdev = '/dev/ttyACM0' #MQTT callbacks def on_connect(mosq, obj, rc): if rc == 0: print("Connected successfully.") else: raise Exception def on_disconnect(mosq, obj, rc): print("Disconnected successfully.") def on_publish(mosq, obj, mid): print("Message "+str(mid)+" published.") def on_subscribe(mosq, obj, mid, qos_list): print("Subscribe with mid "+str(mid)+" received.") def on_unsubscribe(mosq, obj, mid): print("Unsubscribe with mid "+str(mid)+" received.") def on_message(mosq, obj, msg): print("Message received on topic "+msg.topic+" with QoS "+str(msg.qos)+" and payload "+msg.payload) #called on exit #close serial, disconnect MQTT def cleanup(): print "Ending and cleaning up" ser.close() mqttc.disconnect() try: print "Connecting... ", serialdev #connect to serial port ser = serial.Serial(serialdev, 9600, timeout=20) except: print "Failed to connect serial" #unable to continue with no serial input raise SystemExit try: ser.flushInput() #create an mqtt client mypid = os.getpid() client_uniq = "arduino_pub_"+str(mypid) mqttc = mosquitto.Mosquitto(client_uniq) #attach MQTT callbacks mqttc.on_connect = on_connect mqttc.on_disconnect = on_disconnect mqttc.on_publish = on_publish mqttc.on_subscribe = on_subscribe mqttc.on_unsubscribe = on_unsubscribe #mqttc.on_message = on_message #connect to broker mqttc.connect(broker, port, 60) #remain connected to broker #read data from serial and publish while mqttc.loop() == 0: line = ser.readline() #split line as it contains V,temp list = line.split(",") #second list element is temp temp = list[0].rstrip() print("Temp is "+temp) mqttc.publish("arduino/temp", temp) pass # handle list index error (i.e. assume no data received) except (IndexError): print "No data received within serial timeout period" cleanup() # handle app closure except (KeyboardInterrupt): print "Interrupt received" cleanup() except (RuntimeError): print "uh-oh! time to die" cleanup()
Souscription en Python
Souscription depuis l'hôte http://mosquitto.org/documentation/python/
BROKER=10.0.1.3 python subscribearduino.py $BROKER
#!/usr/bin/python # # simple app to subscribe MQTT topic # # uses the Python MQTT client from the Mosquitto project # http://mosquitto.org # # initially Andy Piper http://andypiper.co.uk # 2011/09/15 import os import mosquitto import sys broker=sys.argv[1] #broker = "10.0.1.3" port = 1883 serialdev = '/dev/ttyACM0' #MQTT callbacks def on_connect(mosq, obj, rc): if rc == 0: print("Connected successfully.") else: raise Exception def on_disconnect(mosq, obj, rc): print("Disconnected successfully.") def on_publish(mosq, obj, mid): print("Message "+str(mid)+" published.") def on_subscribe(mosq, obj, mid, qos_list): print("Subscribe with mid "+str(mid)+" received.") def on_unsubscribe(mosq, obj, mid): print("Unsubscribe with mid "+str(mid)+" received.") def on_message(mosq, obj, msg): print("Message received on topic "+msg.topic+" with QoS "+str(msg.qos)+" and payload "+msg.payload) #called on exit # disconnect MQTT def cleanup(): print "Ending and cleaning up" mqttc.disconnect() try: #create an mqtt client mypid = os.getpid() client_uniq = "arduino_pub_"+str(mypid) mqttc = mosquitto.Mosquitto(client_uniq) #attach MQTT callbacks mqttc.on_connect = on_connect mqttc.on_disconnect = on_disconnect mqttc.on_publish = on_publish mqttc.on_subscribe = on_subscribe mqttc.on_unsubscribe = on_unsubscribe mqttc.on_message = on_message #connect to broker mqttc.connect(broker, port, 60) mqttc.subscribe("arduino/temp") #remain connected to broker while mqttc.loop() == 0: pass # handle app closure except (KeyboardInterrupt): print "Interrupt received" cleanup() except (RuntimeError): print "uh-oh! time to die" cleanup()
Node.js
Souscription
npm install mqtt BROKER=10.0.1.3 node subscribe.js $BROKER 1883 arduino/temp
#!/usr/bin/env node var mqtt = require('mqtt'); var argv = process.argv; for (var i = 2; i <= 4; i++) { if(!argv[i]) process.exit(-1); } var port = argv[3] , host = argv[2] , topic = argv[4]; var c = mqtt.createClient(port, host); c.on('connect', function() { c.on('message', function(topic, message) { console.log(topic + ' ' + message); }); c.subscribe(topic); });
Simple Souscripteur avec une interface Web
npm install mqtt npm install express BROKER=10.0.1.3 node webmqttsub.js $BROKER 1883 arduino/temp
curl http://localhost:3000/stream
#!/usr/bin/env node var mqtt = require('mqtt'); var argv = process.argv; for (var i = 2; i <= 4; i++) { if(!argv[i]) process.exit(-1); } var brokerport = argv[3] , brokerhost = argv[2] , subscribedtopic = argv[4]; var lastTopic = ' ', lastMessage = ' No Message' var c = mqtt.createClient(brokerport, brokerhost); c.on('connect', function() { c.on('message', function(topic, message) { console.log(topic + ' ' + message); lastTopic=topic; lastMessage=message; }); c.subscribe(subscribedtopic); }); var express = require('express'); var app = express(); app.get('/stream', function(req, res){ res.send(lastTopic + ' ' + lastMessage); }); app.listen(3000);
Bridge HTTP REST <--> MQTT
BROKER=test.mosquitto.org mosquitto_sub -h test.mosquitto.org -t "arduino/#" -v
BROKER=test.mosquitto.org mosquitto_pub -h test.mosquitto.org -t "arduino/temp" -m "246"
BRIDGE=http://test-mosquitto.herokuapp.com curl $BRIDGE/arduino/temp curl -X PUT --data-binary "247" $BRIDGE/arduino/temp curl -X POST --data-binary "248" $BRIDGE/arduino/temp ... curl -X DELETE $BRIDGE/arduino/temp