增加 filter
在实际的应用中，我们往往需要在逻辑服务器处理请求之前对用户请求做一些前置处理，而当请求被处理后，又需要做一些善后处理，由于这是一种很常见的情形，pomelo 对其进行了抽象，也就是 filter。在 pomelo 中，filter 分为 before filter 和 after filter。在一个请求到达 handler 被处理之前，可以经过多个 before filter 组成的 filter 链进行一些前置处理，比如对请求进行排队，超时处理。当请求被 handler 处理完成后，又可以通过一个 after filter 链进行一些善后处理。这里需要注意的是在 after filter 中一般只做一些清理处理，而不应该再去修改到客户端的响应内容，因为此时，对客户端的响应内容已经发给了客户端。本例是一个聊天应用，在聊天室里，当有人说脏话时，往往需要进行屏蔽。我们在这里就以加一个脏话屏蔽的 filter 来示范如何使用 pomelo 的 filter。具体的代码请切换到 tutorial-abuse-filter 分支，使用如下命令：
$ git checkout tutorial-abuse-filterFilter 结构
Filter 是一个对象，定义一个 filter 的大致代码如下:var Filter = function () {
// ....
};
Filter.prototype.before = function(msg, session, next) {
// ...
}
Filter.prototype.after = function(err, msg, session, resp, next) {
// ...
}
对于 before filter 来说，其有两个参数 msg 和 session，这里 msg 可能是用户请求原始内容，也可能是经过了前面 filter 链处理后的内容。如果在后端服务器上，session 在这里是 BackendSession，如果在前端服务器上，则是 FrontendSession，用户对其的直接修改都只会在整个请求处理链的后面处理过程中有效，而不会对前端的 session 有任何影响，更不会影响原始的 session 信息了。当然如果确实有需要修改 session 的话，比如绑定 uid 的话，可以通过 BackendSessionService 的相关调用达到目的。
在 after 中，err 是当前面有错误的错误信息，resp 是对客户端的相应内容。当定义好 filter 后，通过 application 的 filter，before 或 after 调用将其挂到对应的逻辑服务器处理的处理链上。这是只是一个简单教程，不做深入探讨。
定义我们自己的 Filter
我们这里需要的一个脏话过滤 Filter，为了简单起见我们只对 fuck 进行过滤。在 before filter 里，如果用户发言里有 fuck 字眼，那么就将其替换为 ****，并在其 session 里增加一个标记。在 after filter 里，我们检查 session 的这个标记，如果是脏话，那么就将这个用户的名字记录下来，同样为了简单起见，我们将其记录的方式仅仅是打到 console 中。我们的 abuseFilter 代码如下:// abuseFilter.js
module.exports = function() {
return new Filter();
}
var Filter = function() {
};
Filter.prototype.before = function (msg, session, next) {
if (msg.content.indexOf('fuck') !== -1) {
session.__abuse__ = true;
msg.content = msg.content.replace('fuck', '****');
}
next();
};
Filter.prototype.after = function (err, msg, session, resp, next) {
if (session.__abuse__) {
var user_info = session.uid.split('*');
console.log('abuse:' + user_info[0] + " at room " + user_info[1]);
}
next(err);
};
// app.js
var abuseFilter = require('./app/servers/chat/filter/abuseFilter');
app.configure('production|development', 'chat', function() {
app.filter(abuseFilter());
});
一些说明
- 需要指出的是，这里使用 filter 来做脏话替换，可能不是很合理，但仅仅为了示例 filter 的使用，还是可以的。一般情况下，在 before filter 里，可以做一些请求排队，超时处理， 而在 after filter 里做一些清理记录的处理。比如，为了统计 handler 的处理请求时间，可以在 before filter 里给 session 记录一个时间戳，在 after filter 里取出刚才的时间戳，跟当前时间做运算，就能得到 handler 处理请求的时间。pomelo 内置提供了几个 filter，有 toobusy、timeout 等，这里不再深入。
- 一个 filter 里可以只定义 before，可以只定义 after，也可以两者都定义。application 中与 filter 相关的调用为 filter、after 和 before。如果一个 filter 既定义了 before 又定义了 after，那么就可以调用 filter，这样，application 就会将其 after 和 before 都加载进去，否则，就只能调用 after 或者 before了。