nodejs连接redis数据库
1、安装redis数据库,官网下载安装,一般安装后都默认启动了数据库,如果没有启动,请手动启动,右键计算机-管理-服务
2、安装可视化工具redisClient,打开可视化工具添加服务器,输入名称,地址,默认无密码
3、安装redis模块,
npm install redis
4、后端代码:
var redis = require("redis");
var client = redis.createClient();
client.on("error", function (err) {
console.log("Error " + err);
});
client.on('connect', function(){
console.log('Redis连接成功.');
})
client.on('end', function(){
console.log('Redis关闭.');
})
var name = 'test name';
client.set(name, 'test value', function(err,result){
if (err) {
console.log(err);
return;
}
console.log('插入数据结果:',result);
//过期时间,单位秒
client.expire(name,60);
})
client.get(name, function(err,result){
if (err) {
console.log(err);
return;
}
console.log("查询结果 :",result);
});
5、运行结果和数据库截图:
6、为了方便使用,应该封装方法.redis.js 代码:
var db = {};
var redis = require("redis");
var client = redis.createClient();
client.on("error", function (err) {
console.log("Error :" , err);
});
client.on('connect', function(){
console.log('Redis连接成功.');
})
/**
* 添加string类型的数据
* @param key 键
* @params value 值
* @params expire (过期时间,单位秒;可为空，为空表示不过期)
* @param callBack(err,result)
*/
db.set = function(key, value, expire, callback){
client.set(key, value, function(err, result){
if (err) {
console.log(err);
callback(err,null);
return;
}
if (!isNaN(expire) && expire > 0) {
client.expire(key, parseInt(expire));
}
callback(null,result)
})
}
/**
* 查询string类型的数据
* @param key 键
* @param callBack(err,result)
*/
db.get = function(key, callback){
client.get(key, function(err,result){
if (err) {
console.log(err);
callback(err,null)
return;
}
callback(null,result);
});
}
module.exports = db;
7、使用封装的方法:
var db = require('./redis');
//设置值
db.set('test2', '封装方法', '100', function(err,result){
if (err) {
console.log(err);
return;
}
console.log('插入数据结果:', result);
})
//获取值
db.get('test2', function(err,result){
if (err) {
console.log(err);
return;
}
console.log(result);
})
去看看效果吧