redis_api.js 982 Bytes
var redis   = require('redis');
var config=require('./config.js')
var client  = redis.createClient(config.redis.port, config.redis.host,{
	db:config.redis.db,password:config.redis.auth
});
exports.getsid=function(sid,call){
	client.select('1',function(err){			
			if(!err){
				//console.log('select 0',err)
				client.get('Token:'+sid ,function(err,reply){
					console.log('------Token:'+sid)
					console.log('Token:',sid,err,reply)
					console.log('end ------Token:'+sid)
					if(err){
						call(err)
					}else{
						//console.log('sess:'+sid+'=',reply)
						call(0,JSON.parse(reply))
					}					
				})
			}
	})
}
//根据userid 获取消息数
exports.getmessage=function(userid,call){
	client.select('1',function(err){
		if(!err){
			client.get('MSG:'+userid,function(err,reply){
				if(!err){
					console.log('message:'+userid+'='+reply)
					call(0,JSON.parse(reply))
				}else{
					call(err)
				}
				// 关闭链接
           		//client.quit();
			})
		}
	})
}