io-old-v2.js

/**
 * 
 * 仅支持http
 * 
 * 参考资料：
 *      https://github.com/socketio/socket.io-emitter
 *      https://github.com/socketio/socket.io-redis
 *      http://socket.io/docs/rooms-and-namespaces/
 *      https://github.com/socketio/socket.io
 */
var Server = require('http').createServer();
var IO = require('socket.io')(Server);
var _ = require('underscore');

var ControlRooms = {};
var platforms = ['fm', 'ctrl', 'jgy'];//miku.us/fm/ctrlview/xxx、miku.us/ctrl/qr#sb、res.miku.us/#!m20&showControlView=xxx

var func = {
    regCmd: function(socket, platform, token){
        var action = 'regCmd';
        if (! (platform in ControlRooms)) ControlRooms[platform] = {};
        if (token in ControlRooms[platform]) {
            ControlRooms[platform][token].push(socket);
        } else {
            ControlRooms[platform][token] = [socket];
        }
    },
    sendCmd: function(socket, platform, token, type, value){
		if (! token) return;
		_.each(ControlRooms[platform][token], function(e){
            var backCmd = platform + '/acceptCmd';
            if (socket != e) { //不发给自己
                //向客户端被控者发送：token-身份标识, type-动作类型, value-附加数据(可选)
                e.emit(backCmd, token, type, value);
            }
		});
    },
    sendCmdToAll: function(socket, platform, type, value){
        var backCmd = platform + '/acceptCmdToAll';
        IO.emit(backCmd, null, type, value);
    }
};

IO.on('connect', function(socket){
    for (var i in platforms) {
        for (var j in func) {
            ~ function(cmd, platform, action){
                socket.on(cmd, function(){ //接受客户端主控者传递的参数：具体结构根据platform来区别
                    var args = Array.prototype.concat.apply([socket,platform], arguments);
                    func[action].apply(this, args);
                });
            }(platforms[i]+'/'+j, platforms[i], j);
        }
    }
});

IO.listen('3000');