缓存你的express路由数据

在开发的过程中，因为某些路由数据计算过程耗时比较长，数据实时性要求低，面对这种情况，最好的办法是，检测redis里面是否有该结果的集合，如果没有数据集合，从数据库里面读取，将数据写入redis，待下次访问的时候，从redis里面取出数据，如果有数据集合，则从缓存里面读取结果集合返回页面，通过这样的手段，能让服务器响应更快，同时也减轻数据库的压力。

实例1

app.get('/demo', function (req, res) {
    var name = req.query.name;
    User.findOne({name: name}, function (err, user) {
        if (err) {
            return res.send({message: 'Failed', data: err});
        }

        return res.send({message: 'OK', user});
    })
});

上面是一段经典的业务代码，前端通过query请求里面的name属性，在db查找用户信息，然后将用户信息返回前端。接下来，我们基于这段代码，进行路由数据的缓存改造。

实例2

var redis = require('redis');
var md5 = require('md5');
var redisClient = redis.createClient();


app.get('/demo', function (req, res) {
    var name = req.query.name;
    var key = md5([req.method, req.url, JSON.stringify(req.query)].join(':'));
    var expired = 60*5;

    redisClient.get(key, function (err, result) {
        if (err) {
            return res.send({message: 'Failed', data: err});
        }

        if (result) {
            // Read data from cache.
            return res.send({message: 'OK', JSON.parse(result)});

        } else {
            // Read data from Mongo and write result into redis.
            User.findOne({name: name}, function (err, user) {
                if (err) {
                    return res.send({message: 'Failed', data: err});
                }

                res.send({message: 'OK', user});
                redisClient.setex(key, expired, JSON.stringify(user));
            });
        }

    });
});

wow,瞬间代码量暴增，这样真的合适吗？虽然性能提高了，但Node.js需要回调的特性，导致读写缓存的过程变得非常麻烦，让代码变得很难维护，而且我需要多个路由都对结果进行缓存，那得怎么办，不禁让人觉得Node.js太坑爹了。既然觉得Node.js坑爹，那么看看python 的flask是如何实现路由缓存的。

@mobile.route('/user/<str:name>', methods=['GET'])
@cached(600)
def item_detail(item_id):
    user = Models.User.find_one(name=str(name))
    return jsonify(message='OK', user=user)

看不懂python没关系，关键是代码当中的cached(600) ，python通过自带的装饰器实现了路由的缓存，因为Node.js读取缓存是存在回调的情况，所以无法实现类似python的装饰器。
不过，javascript拥有高阶函数的特性，利用高阶函数的封装来达到装饰器的效果，具体实现可以参考实例3。

实例3

var cacheRouter = function (fn, t) {
    var expiredTime = t || 5000;
    return function (req, res, next) {
        var send = res.send;

        var method = req.method;
        var url = req.url;
        var query;

        if (method === 'GET') {
            query = req.query;
        } else {
            query = req.body;
        }

        var key = md5([method, url, JSON.stringify(query)].join(':'));
        redisQueue.get(key, function (err, value) {
            if (err) {
                return next(err);
            }

            if (value) {
                var data = value;
                try {
                    data = JSON.parse(data);
                } catch (err) {
                    console.log(err);
                }

                return res.send(data);
            }

            res.send = function (data) {
                redisQueue.setex(key, expiredTime, JSON.stringify(data));
                return send.call(this, data);
            }

            return fn.call(null, req, res);
        });
    }
}

var demoView = function (req, res) {
    var name = req.query.name || 'default name';
    var data = {
        hello: name
    };

    res.send({message: 'OK', data: data});
}

router.get('/demo', routerCache(demoView, 60*5));

实例3当中cacheRouter是一个高阶函数，利用高阶函数的方式来实现缓存机制的复用，有效地隔离业务代码。只需要简单地添加cacheRouter 轻松实现路由数据缓存。

实例3，完整代码
https://github.com/youyudehexie/express-cache-router-demo

最后，值得注意的是，做缓存的时候注意路径里面是否有经常变动的信息，例如session，会导致缓存命中失效，会降低做缓存的效果，可以考虑在 routerCache 添加上 过滤某些关键字做 key的逻辑。