Mosquitto

http://mosquitto.org/

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 depuis le Raspberry Pi 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]
#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
#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 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 websub.js $BROKER 1883 arduino/temp

start 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