rayson

Rayson is a JSON-RPC 2.0 mqtt client and mqtt server for node.js based on jayson.

Installation

$ npm install --save rayson

Server

jason-mqtt server played as a mqtt consumer, so it need a mqtt server start first. We can use mosca.

Exposes an array of functions which retrieves and returns data.

var rayson = require('../'/*'rayson'*/);
 
var moscaServer = new require('mosca').Server({port: 9999}); // start mosca server for test
 
var server = rayson.server({
    localtime: function (cb) {
        console.log('localtime has been called');
        cb(null, new Date());
    }
}).mqtt('mqtt://localhost:9999', '$rpc/server1/localtime');
 
server.format('msgpack'); // default is `json`
 

Client

Consumes the api exposed by the previous example.

var rayson = require('../'/*'rayson'*/);
 
var client = rayson.client.mqtt('mqtt://localhost:9999', '$rpc/:sid/localtime');
 
client.format('msgpack'); // default is `json`
 
client.mqtt.on('error', function (err) {
    console.error(err);
});
 
client.mqtt.on('connect', function () {
    console.log('connected');
});
 
client.mqtt.on('reconnect', function () {
    console.log('reconnect');
});
 
client.mqtt.on('offline', function () {
    console.log('offline');
});
 
client.sid('server1').request('localtime', [], function(err, error, time) {
    console.log('localtime: ', time);
}).timeout(10);
 

License

MIT © taoyuan