redis_api.js
982 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
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();
})
}
})
}