增加 rpc 调用
在多进程应用中，进程间通讯是不可或缺的。在 pomelo 中，借助 javascript 的语言特性，实现了对开发者非常友好的一个 rpc 框架。下面，我们将在我们的 chat 应用中，实践一个 rpc 调用。为了保持简单，而又能说明问题，我们“画蛇添足”地实现一个时间服务器，当 gate 服务器接受到用户的查询请求时，我们让 gate 服务器向时间服务器请求当前的时间，并将其打印在 console 上。当然这个例子没有啥实际意义，你也可以认为它有意义，因为一个统一的时间服务器可以提供统一的时间信息。这里仅仅是为了示例 rpc 调用的使用方式，并向用户展示 pomelo 中 rpc 调用的方便性。
实际上在我们的聊天应用中，已经有了 rpc 调用的实现，那就是当有用户连接 connector 或者离开时，connector 会向 chat 发起 rpc，chat 会根据相应的用户离开和加入，对应操作其 Channel 信息。由于在前面我们并没有很详细地对其进行分析，所以干脆重新实现一个全新的 rpc，同时，我们也可以展示如何在 pomelo 应用中增加一个服务器类型。
chat 中增加 rpc
下面将给我们的聊天应用增加一个 rpc 调用和一个 time 类型的服务器，具体的代码在分支 tutorial-rpc 上，使用如下命令切换分支:$ git checkout tutorial-rpc// timeRemote.js
module.exports.getCurrentTime = function (arg1, arg2, cb) {
console.log("timeRemote - arg1: " + arg1+ "; " + "arg2: " + arg2);
var d = new Date();
var hour = d.getHours();
var min = d.getMinutes();
var sec = d.getSeconds();
cb( hour, min, sec);
};
// gateHandler.js
var routeParam = Math.floor(Math.random()*10);
this.app.rpc.time.timeRemote.getCurrentTime(routeParam, arg1, arg2, function(hour, min, sec) {
// ...
});
当有多个 time 服务器的时候，我们还要为每一次对 time 服务的请求配置相应的路由，rpc 路由函数的第一个参数为 rpc 调用时的第一个参数，对于本例来说，就是随机数 routeParam。在 pomelo 中很多时候是使用 session 作为路由参数的，这里示例了一个不一样的路由参数，具体示例代码如下：
// app.js
var router = function(routeParam, msg, context, cb) {
var timeServers = app.getServersByType('time');
var id = timeServers[routeParam % timeServers.length].id;
cb(null, id);
}
app.route('time', router);
在服务器配置 config/servers.json 中增加 time 服务器如下：
"time":[
{"id": "time-server-1", "host":"127.0.0.1", "port" : 7000},
{"id": "time-server-2", "host":"127.0.0.1", "port" : 7001}
]
一些说明
你可能注意到了我们在 time 服务器的 timeRemote.js 和 chat 服务器的 chatRemote.js中，定义远程调用方式的不同了。在 timeRemote.js 中，直接在 module.exports 上面挂载 getCurrentTime，而在 chatRemote.js 中，则是另一种方式，示例如下:// chatRemote.js
module.exports = function(app) {
return new ChatRemote(app);
};
// timeRemote.js
module.exports.getCurrentTime(arg1, arg2, cb) {
// ...
};
当 remote 需要当前的 application 实例的时候，往往可以使用第一种 chatRemote 的那种方式，而当 remote 跟 app 完全没关系时，也可以使用 timeRemote 的这种实现方式，这在 pomelo 中是没有差别的。
不仅仅是 remote，对于 handler 也是一样，也就是说定义 handler 的时候也可以使用这两种方式中的一种，只不过到目前为止，我们这个例子中使用的都是类似于 chatRemote 中的那种实现方式。
- 当前端服务器接受客户端请求，将请求路由给后端服务器时，pomelo 使用的是发起一个系统级远程调用的方式，这个时候会使用 session 作为 rpc 请求的路由参数，这也是我们看到的前面在给 chat 配置路由的时候，路由函数的第一个参数总是 session。在 time 中，我们使用了一个随机整数作为路由参数，因此 time 的路由函数的第一个参数也就是这个随机整数了。实际上 pomelo 的 rpc 框架对于路由参数的使用是没有限制的，并不仅限于一直使用 session；
- rpc 调用的返回值是通过回调的形式获得的，回调函数也就是我们上面看到的 rpc 调用的最后一个参数。这个回调函数可以有多个参数，表示远程调用可以返回多个值，在我们这个例子中，返回了时分秒三个值；
- 0.8 版本以后，当进行 rpc 调用的时候，可以跳过路由计算而直接将调用发送到一个具体的服务器或者广播到一类服务器的调用方式，代码示例如下：
// route var routeParam = session; app.rpc.area.playerRemote.leaveTeam(routeParam, args..., cb); // to specified server 'area-server-1' app.rpc.area.playerRemote.leaveTeam.toServer('area-server-1', args..., cb); // broadcast to all the area servers app.rpc.area.playerRemote.leaveTeam.toServer('*', args..., cb);