sockjs-multichannel v1.0.1

Sockjs Multichannel

===================

sockjs-multichannel is a small library on top of SockJS that allows you to create channels (multiplex) over a single SockJS connection also have the ability to create server and client in node instead only in browsers. It's created based on library websocket-multiplex

To learn more about the problem of multiplexing channels in a single connection please read more here

How to use

===================

Create server and register one channel

var http                = require('http');
var express             = require('express');
var sockjs              = require('sockjs');
var multichannelServer = require('sockjs-multichannel').server;

var sockjs_opts = {sockjs_url: "http://cdn.sockjs.org/sockjs-0.3.min.js"};
var service = sockjs.createServer(sockjs_opts);

var multiplexer = new multichannelServer(service);

var red = multiplexer.registerChannel('red');
red.on('connection', function(conn) {
    conn.write('Red is conncted');
    conn.on('data', function(data) {
        conn.write('server : red says ' + data);
    });
});
var app    = express();
var server = http.createServer(app);

service.installHandlers(server, {prefix:'/multiplex'});
console.log(' [*] Listening on 0.0.0.0:9999' );
server.listen(9999, '0.0.0.0');
app.get('/', function (req, res) {
    res.sendfile(__dirname + '/index.html');
});

Create a client in node

var multichannelClient = require('sockjs-multichannel').client;

var multiClient = new multichannelClient("http://localhost:9999/multiplex");

var red = multiClient.channel("red");

function listeners(channel,name){
  channel.on("open",function(){
    console.log("OPEN Channel ",name);
  });
  channel.on("close",function(){
    console.log("CLOSE Channel ",name);
  });
  channel.on("message",function(message){
      console.log("DATA from  Channel ",name, " data : ",message);
  });
}

listeners(red,"red");

setInterval(function(){
    red.send("client : red channel sent this!!");
},1000);

See a more detailed examples here

I hope it's useful!