{

  "development": {

    "id": "master-server-1", "host": "127.0.0.1", "port": 15005

  },

  "production": {

    "id": "master-server-1", "host": "127.0.0.1", "port": 15005

  }

}

{

    "development":{

        "connector":[

             {"id":"connector-server-1", "host":"127.0.0.1", "port":14050, "clientPort": 13050, "frontend": true},

             {"id":"connector-server-2", "host":"127.0.0.1", "port":14051, "clientPort": 13051, "frontend": true},

             {"id":"connector-server-3", "host":"127.0.0.1", "port":14052, "clientPort": 13052, "frontend": true}

         ],

        "chat":[

             {"id":"chat-server-1", "host":"127.0.0.1", "port":16050},

             {"id":"chat-server-2", "host":"127.0.0.1", "port":16051},

             {"id":"chat-server-3", "host":"127.0.0.1", "port":16052}

        ],

        "gate":[

           {"id": "gate-server-1", "host": "127.0.0.1", "clientPort": 15014, "frontend": true}

        ]

    },

    "production":{

           "connector":[

             {"id":"connector-server-1", "host":"127.0.0.1", "port":14050, "clientPort": 13050, "frontend": true},

             {"id":"connector-server-2", "host":"127.0.0.1", "port":14051, "clientPort": 13051, "frontend": true},

             {"id":"connector-server-3", "host":"127.0.0.1", "port":14052, "clientPort": 13052, "frontend": true}

         ],

        "chat":[

             {"id":"chat-server-1", "host":"127.0.0.1", "port":16050},

             {"id":"chat-server-2", "host":"127.0.0.1", "port":16051},

             {"id":"chat-server-3", "host":"127.0.0.1", "port":16052}

        ],

        "gate":[

           {"id": "gate-server-1", "host": "127.0.0.1", "clientPort": 15014, "frontend": true}

        ]

  }

}

[{

    "type": "connector",

    "token": "agarxhqb98rpajloaxn34ga8xrunpagkjwlaw3ruxnpaagl29w4rxn"

}, {

    "type": "chat",

    "token": "agarxhqb98rpajloaxn34ga8xrunpagkjwlaw3ruxnpaagl29w4rxn"

},{

    "type": "gate",

    "token": "agarxhqb98rpajloaxn34ga8xrunpagkjwlaw3ruxnpaagl29w4rxn"

}]

var crc = require('crc');

module.exports.dispatch = function(uid, connectors) {

    var index = Math.abs(crc.crc32(uid)) % connectors.length;

    return connectors[index];

};

var exp = module.exports;

var dispatcher = require('./dispatcher');

exp.chat = function(session, msg, app, cb) {

    var chatServers = app.getServersByType('chat');

    if(!chatServers || chatServers.length === 0) {

        cb(new Error('can not find chat servers.'));

        return;

    }

    var res = dispatcher.dispatch(session.get('rid'), chatServers);

    cb(null, res.id);

};

var dispatcher = require('../../../util/dispatcher');

module.exports = function(app) {

    return new Handler(app);

};

var Handler = function(app) {

    this.app = app;

};

var handler = Handler.prototype;

/**

 * Gate handler that dispatch user to connectors.

 *

 * @param {Object} msg message from client

 * @param {Object} session

 * @param {Function} next next stemp callback

 *

 */

handler.queryEntry = function(msg, session, next) {

    var uid = msg.uid;

    if(!uid) {

        next(null, {

            code: 500

        });

        return;

    }

    // get all connectors

    var connectors = this.app.getServersByType('connector');

    if(!connectors || connectors.length === 0) {

        next(null, {

            code: 500

        });

        return;

    }

    // select connector

    var res = dispatcher.dispatch(uid, connectors);

    next(null, {

        code: 200,

        host: res.host,

        port: res.clientPort

    });

};

module.exports = function(app) {

    return new ChatRemote(app);

};

var ChatRemote = function(app) {

    this.app = app;

    this.channelService = app.get('channelService');

};

/**

 * Add user into chat channel.

 *

 * @param {String} uid unique id for user

 * @param {String} sid server id

 * @param {String} name channel name

 * @param {boolean} flag channel parameter

 *

 */

ChatRemote.prototype.add = function(uid, sid, name, flag, cb) {

    var channel = this.channelService.getChannel(name, flag);

    var username = uid.split('*')[0];

    var param = {

        route: 'onAdd',

        user: username

    };

    channel.pushMessage(param);

    if( !! channel) {

        channel.add(uid, sid);

    }

    cb(this.get(name, flag));

};

/**

 * Get user from chat channel.

 *

 * @param {Object} opts parameters for request

 * @param {String} name channel name

 * @param {boolean} flag channel parameter

 * @return {Array} users uids in channel

 *

 */

ChatRemote.prototype.get = function(name, flag) {

    var users = [];

    var channel = this.channelService.getChannel(name, flag);

    if( !! channel) {

        users = channel.getMembers();

    }

    for(var i = 0; i < users.length; i++) {

        users[i] = users[i].split('*')[0];

    }

    return users;

};

/**

 * Kick user out chat channel.

 *

 * @param {String} uid unique id for user

 * @param {String} sid server id

 * @param {String} name channel name

 *

 */

ChatRemote.prototype.kick = function(uid, sid, name, cb) {

    var channel = this.channelService.getChannel(name, false);

    // leave channel

    if( !! channel) {

        channel.leave(uid, sid);

    }

    var username = uid.split('*')[0];

    var param = {

        route: 'onLeave',

        user: username

    };

    channel.pushMessage(param);

    cb();

};

var chatRemote = require('../remote/chatRemote');

module.exports = function(app) {

    return new Handler(app);

};

var Handler = function(app) {

    this.app = app;

};

var handler = Handler.prototype;

/**

 * Send messages to users

 *

 * @param {Object} msg message from client

 * @param {Object} session

 * @param  {Function} next next stemp callback

 *

 */

handler.send = function(msg, session, next) {

    var rid = session.get('rid');

    var username = session.uid.split('*')[0];

    var channelService = this.app.get('channelService');

    var param = {

        route: 'onChat',

        msg: msg.content,

        from: username,

        target: msg.target

    };

    channel = channelService.getChannel(rid, false);

    //the target is all users

    if(msg.target == '*') {

        channel.pushMessage(param);

    }

    //the target is specific user

    else {

        var tuid = msg.target + '*' + rid;

        var tsid = channel.getMember(tuid)['sid'];

        channelService.pushMessageByUids(param, [{

            uid: tuid,

            sid: tsid

        }]);

    }

    next(null, {

        route: msg.route

    });

};

module.exports = function(app) {

    return new Handler(app);

};

var Handler = function(app) {

        this.app = app;

};

var handler = Handler.prototype;

/**

 * New client entry chat server.

 *

 * @param  {Object}   msg     request message

 * @param  {Object}   session current session object

 * @param  {Function} next    next stemp callback

 * @return {Void}

 */

handler.enter = function(msg, session, next) {

    var self = this;

    var rid = msg.rid;

    var uid = msg.username + '*' + rid

    var sessionService = self.app.get('sessionService');

    //duplicate log in

    if( !! sessionService.getByUid(uid)) {

        next(null, {

            code: 500,

            error: true

        });

        return;

    }

    session.bind(uid);

    session.set('rid', rid);

    session.push('rid', function(err) {

        if(err) {

            console.error('set rid for session service failed! error is : %j', err.stack);

        }

    });

    session.on('closed', onUserLeave.bind(null, self.app));

    //put user into channel

    self.app.rpc.chat.chatRemote.add(session, uid, self.app.get('serverId'), rid, true, function(users){

        next(null, {

            users:users

        });

    });

};

/**

 * User log out handler

 *

 * @param {Object} app current application

 * @param {Object} session current session object

 *

 */

var onUserLeave = function(app, session) {

    if(!session || !session.uid) {

        return;

    }

    app.rpc.chat.chatRemote.kick(session, session.uid, app.get('serverId'), session.get('rid'), null);

};

var express = require('express');

var router = express.Router();

router.get('/', function (req, res, next) {

    res.render('index', { title: 'Nodejs学习笔记（十六）--- Pomelo介绍&入门' });

});

module.exports = router;

var express = require('express');

var path = require('path');

var logger = require('morgan');

var cookieParser = require('cookie-parser');

var bodyParser = require('body-parser');

var app = express();

var index = require('./routers/index.js');

// views engine setup

app.set('views', path.join(__dirname, 'views'));

app.set('view engine', 'ejs');

app.use(logger('dev'));

app.use(bodyParser.json());

app.use(bodyParser.urlencoded({ extended: false }));

app.use(cookieParser());

app.use(express.static(path.join(__dirname, 'public')));

app.use('/', index);

app.use(function(req, res, next) {

    var err = new Error('Not Found');

    err.status = 404;

    res.render('404');

});

if (app.get('env') === 'development') {

    app.use(function(err, req, res, next) {

        console.log(err);

        res.status(err.status || 500);

        res.render('500', {

            message: err.message,

            error: err

        });

    });

}

app.use(function(err, req, res, next) {

    console.log(err);

    res.status(err.status || 500);

    res.render('500', {

        message: err.message,

        error: {}

    });

});

app.listen(10111, function () {

    console.log("You can debug your app test with http://127.0.0.1:10111");

});

module.exports = app;