@perfectnode 这个得自己封装吧，与业务相关，我们就是自己封装的

@perfectnode YY.get_cache = function( self, tablename, where, row, cb ) { redis.get( key, function( err, res ) { if( err ) { cb( err ); } else { if( res === null ) { //console.log( ‘no cache’ ); var sql = YY.selectSQL( tablename, where, row ); self.query( sql, function( err, res ) { if( err ) { args( err ); } else { cb( null, res ); if( res.length !== 0 ) { redis.set( key, JSON.stringify( res ), ‘NX’, ‘EX’, 43200, function( err, res ) { if( err ) { console.error( err ); } }); } } }); } else { //console.log( ‘data from cache’ ); cb( null, JSON.parse( res ) ); } } });

};

@perfectnode 我们封装的与业务关系比较大，贴出来完整的估计也看不了明白，思路就是：1.redis缓存我们业务需要的数据（有生命周期），以减轻数据库的压力，当查询数据时，先走redis，redis没有数据走数据库，同时把得到的数据存入redis；2.当数据发生delete或者update操作时，删掉redis中的数据，同时更改数据库。

注意的地方：第一步中，从数据库中取数据存入redis，redis存储失败成功不重要。第二步中，必须等redis中清楚数据成功以后才能更改数据库，不然下次取数据就会有问题。

@perfectnode get_cache的代码就是上面的啊，你自己再写个delete_cache的就行了，没什么难度

@perfectnode //存储缓存 YY.get_cache = function( self, tablename, where, row, args ) {
if( tablename === ‘card’ ) { //卡组查询 if( where.indexOf( ‘card_group’ ) !== -1 ) { var groupid = where.match( new RegExp(‘card_group=([^ ])’) )[ 1 ]; var key = ‘group_id=’ + groupid; var redis = pomelo.app.get( ‘redis’); redis.get( key, function( err, mres ) { if( err ) { args( err ); } else { //卡组信息缓存存在 if( mres ) { //console.log( ‘card_group from cache’ ); res = JSON.parse( mres ); YY.get_multi_card( self, res, args ); } //卡组缓存不存在 else { //console.log( ‘card_group no cache’ ); var tmp_reg = where.match( new RegExp('role_id=([^ ])’) ); if( tmp_reg ) { var roleid = tmp_reg[ 1 ]; var sql = YY.selectSQL( ‘card_group’, ‘group_id=’ + groupid + ’ AND role_id=’ + roleid, ‘*’ ); self.query( sql, function( err, res ) { YY.get_multi_card( self, res[ 0 ], args ); redis.set( key , JSON.stringify( res[ 0 ] ), ‘NX’, ‘EX’, 43200, function( err, mres ) { if( err ) { console.error( err ); } }); }); } else { console.error( ‘select card_group, role_id is required’ ); } } } }); } //通过card_id来查询 else if( where.indexOf( ‘card_id’ ) !== -1 ) { var card_id_arr = where.match(/card_id=(\d+)/g).map(function(n){return n.match(/\d+/)[0]}); var redis = pomelo.app.get( ‘redis’); //多张卡片的查询 if( card_id_arr.length > 1 ) { YY.get_multi_card( self, card_id_arr, args ); } //单张卡片的查询 else { var key = ‘card_id=’ + card_id_arr[ 0 ]; redis.get( key, function( err, res ) { if( err ) { args( err ); } else { //单张卡片没有缓存 if( res === null ) { //console.log( ‘card no cache’ ); var sql = YY.selectSQL( ‘card’, where, row ); self.query( sql, function( err, res ) { if( err ) { args( err ); } else { args( null, res ); if( res.length !== 0 ) { redis.set( key, JSON.stringify( res ), ‘NX’, ‘EX’, 43200, function( err, res ) { if( err ) { console.error( err ); } }); } } }); } //读取缓存 else { //console.log( ‘card from cache’ ); args( null, JSON.parse( res ) ); } } }); } } //通过role_id来查询 else if( where.indexOf( ‘role_id’ ) !== -1 ) { var sql = YY.selectSQL( ‘card’, where, row ); self.query( sql, function( err, res ) { if( err ) { args( err ); } else { args( null, res ); if( res.length !== 0 ) { var redis = pomelo.app.get( ‘redis’); res.forEach(function( card ) { //判断key是否存在，如果不存在，就缓存 var key = ‘card_id=’ + card.card_id; redis.exists( key, function( err, res ) { if( err ) { console.error( err ); } else { if( res === 0 ) { redis.set( key, JSON.stringify( [ card ] ), ‘NX’, ‘EX’, 43200, function( err, res ) { if( err ) { console.error( err ); } }); } } }); }); } } }); } else { console.log( ‘no such condition is found’ ); } } };

//删除缓存 YY.del_cache = function( self, tablename, data, where, args, memc ) { var async = require( ‘async’ ); var redis = pomelo.app.get( ‘redis’ ); /* 删除key / function removekey( keys ) { var fun_arr = []; keys.forEach( function( key, idx ) { if( idx === 0 ) { fun_arr.push( function( cb ) { redis.exists( key, cb ); } ); } else { fun_arr.push( function( res, cb ) { redis.exists( key, cb ); } ); } fun_arr.push( function( res, cb ) { //没有缓存 if( res === 0 ) { cb( null, null ); } else { redis.del( key, function( err, res ) { //删除成功 if( res ) { cb( null, null ); } //删除失败 else { cb( ‘mysql cahce del failed’ ); } }); } } ); }); fun_arr.push( function( res, cb ) { if( memc.sql == ‘update’ ) { //console.log( ‘update cache success’ ); self[ memc.sql ]( tablename, data, where, args, true ); } else if( memc.sql == ‘delete’ ) { //console.log( ‘delete cache success’ ); self[ memc.sql ]( tablename, where, args, true ); } } ); async.waterfall( fun_arr, function( err ) { args( err ); }); } //卡组逻辑 if( tablename == ‘card_group’ ) { var groupid = where.match( new RegExp('group_id=([^ ])’) )[ 1 ]; var keys = [ ‘group_id=’ + groupid ]; removekey( keys ); } else if( tablename == ‘card’ ) { var card_id_arr = where.match(/card_id=(\d+)/g).map(function(n){return n.match(/\d+/)[0]}); var keys = []; for( var i = 0; i < card_id_arr.length; i++ ) { keys.push( ‘card_id=’ + card_id_arr[ i ] ); } removekey( keys ); } else{ console.error( ‘mysql delete cache error, no such options’ ); } };

对于直接贴代码的做法我是不太赞成的，在这上面一般都是提供思路，剩下的自己去做。 我们代码和业务关系比较大，而且我们用的是mysql，能不能看懂就看你自己了。