在开发的过程中,因为某些路由数据计算过程耗时比较长,数据实时性要求低,面对这种情况,最好的办法是,检测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的逻辑。