nodejs使用redis.js并进行封装,实现数据存取
nodejs+redis实现数据存储
·
环境准备:
1、redis服务已成功安装并可访问
2、nodejs工程安装redis.js包,执行npm install redis --save安装redis
npm install redis --save
不熟悉的小伙伴可以翻看下redis.js的官方文档API,看一下createClient的配置参数,set, get,rpush,del等api的说明;
下面是代码封装与实现:
const redis = require('redis');
const host = "127.0.0.1"; // redis服务地址
const port = '6379' // redis服务端口
class Redis {
constructor() {
this.redisClient = redis.createClient({
url: `redis://${host}:${port}`,
legacyMode: true
});
// 配置redis的监听事件
this.redisClient.on('ready', function() {
console.log('Redis Client: ready')
})
// 连接到redis-server回调事件
this.redisClient.on('connect', function () {
console.log(new Date(), 'redis is now connected!');
});
this.redisClient.on('reconnecting', function () {
console.log(new Date(), 'redis reconnecting', arguments);
});
this.redisClient.on('end', function () {
console.log('Redis Closed!');
});
this.redisClient.on('warning', function () {
console.log('Redis client: warning', arguments);
});
this.redisClient.on('error', err => {
console.log('Redis Error ' + err);
});
// 判断redis是否连接
if (this.redisClient.isOpen) {
console.log('rredis is now connected!')
} else {
this.redisClient.connect().catch(error => console.log(error));
}
}
async contect() {
await this.redisClient.connect().catch(error => console.log(error));
}
quit() {
this.redisClient.quit();
}
async exists(key) {
return new Promise((resolve, reject) => {
this.redisClient.exists(key, (err, result) => {
if (err) {
console.log(err);
reject(false);
}
resolve(result);
})
})
}
async set(key, value, exprires) {
if (typeof value === 'object') {
value = JSON.stringify(value)
}
return new Promise((resolve, reject) => {
this.redisClient.set(key, value, (err, result) => {
if (err) {
reject(false);
}
if (!isNaN(exprires)) {
this.redisClient.expire(key, exprires);
}
resolve(result);
})
})
}
async get(key) {
return new Promise((resolve, reject) => {
this.redisClient.get(key, (err, result) => {
if (err) {
reject(false);
}
resolve(result);
})
})
}
async remove(key) {
return new Promise((resolve, reject) => {
this.redisClient.del(key, (err, result) => {
if (err) {
reject(false);
}
resolve(result);
})
});
}
// push 将给定值推入列表的右端 返回值 当前列表长度
async rPush(key, list, exprires) {
return new Promise((resolve, reject) => {
this.redisClient.rPush(key, list, (err, length) => {
if (err) {
reject(false);
}
if (!isNaN(exprires)) {
this.redisClient.exports(key, exprires);
}
resolve(length);
})
})
}
// 查询list的值
async lrange(key, startIndex = 0, stopIndex = -1) {
return new Promise((resolve, reject) => {
this.redisClient.lRange(key, startIndex, stopIndex, (err, result) => {
if (err) {
reject(false);
}
resolve(result)
})
})
}
// 清除list中n个值为value的项
async lrem(key, n = 1, value) {
return new Promise((resolve, reject) => {
this.redisClient.lrem(key, n, value, (err, result) => {
if (err) {
return false
}
resolve(result);
})
});
}
}
module.exports = new Redis();
上面已经对redis的能力进行了简单的封装,代码就不过多的进行解释了,一般都看得懂;
(err, result) => {
if (err) {
reject(false); 这里reject(false),reject(err),都可以,根据需要自己决定,建议reject(err),外面调用的时候惊醒一个异常捕捉,这样做更好一些,
}
resolve(result)
}
下面就是如何调用:这段是向微信服务器获取accesstoken,部分业务代码已经省略,只展示redis的操作
const redisClient = require('../../core/redisClient');
class wxService {
static async getAccessToken() {
// 判断是否存在
const haKey = await redisClient.exists('access_token');
let access_token = '';
if (haKey) {
access_token = await redisClient.get('access_token');
}
// 不存在去获取access_token,并存入到redis中
if (!haKey || !access_token) {
access_token = 'XXXXXXXXXXXXXXXX';
await redisClient.set('access_token', access_token, 60*60*2)
}
}
}
更多推荐
已为社区贡献2条内容
所有评论(0)