pomelo解耦代码组织

本文 demo 基于上一篇博文（pomelo链接mysql），将暴露给客户端的 servers 逻辑部分解耦到 service 层，从而实现关注点分离。

需求：把购买物品的逻辑解耦到 service 目录。

在 Handler 中添加持久对象

在 Handler 构造函数中引入并实例化 GoodsService，挂载为 this.GoodsService：

module.exports = function (app) {
    return new Handler(app);
};

var Handler = function (app) {
    this.app = app;


    var GoodsService = require(app.getBase() + "/app/service/game/GoodsService.js");
    this.GoodsService = new GoodsService();


};
var handler = Handler.prototype;

修改 gameHandler.js 中的 buyGoods 函数

将原来内联的购买逻辑委托给 this.GoodsService.buyGoods：

handler.buyGoods = function (msg, session, next) {
    var id = msg.id;
    var count = msg.count;

    ///////////////////////////////

    if (id == "100" && count == 1) {//验证购买条件        //允许购买

        this.GoodsService.buyGoods(msg.id, session.uid, function (err, res) {

            if (err) { // 购买失败
                console.error("[Error]:数据库服务器错误");
                next(null, { msg: "购买失败，服务器错误！", code: 200 });

            }
            else {//购买成功
                next(null, { msg: "购买物品:#活血丹 成功", code: 200 });

            }
        });

    } else { // 不允许购买
        next(null, { msg: "你的金币不足，购买失败", code: 200 });
    }


}
//还可以进一步解耦为
handler.buyGoods = function (msg, session, next) {
        this.GoodsService.buyGoods(msg.id, session.uid, next);
}

新建 GoodsService.js

添加 game-server\app\service\game\GoodsService.js，封装数据库操作：

function GoodsService() {
    console.error("[GoodsService]:new GoodsService"); // 检测不同的客户端是否会new 该脚本
}

GoodsService.prototype.buyGoods = function (id, owner, cb) {
    var sql = " insert into `goods` (`id`, `owner`) VALUES(?, ?)";

    var args = [id, owner];
    var dbclient = pomelo.app.get('dbclient');//获取全局mysql client

    console.log(dbclient);
    dbclient.query(sql, args, function (err, res) {//执行sql语句 函数insert和query等效

        cb(err, res);
    });

};

module.exports = GoodsService;


//进一步解耦 在这里 不列出

新建多个客户端连接后可以观察到：构造器只被调用了一次，说明所有客户端共享同一个服务器的 handler 实例。因此，合理利用路由来分配服务器压力尤为重要。