当前位置：首页 > news >正文

redis 在 nodejs 中如何应用？

news 2025/8/27 12:43:12

在 Node.js 中使用 Redis 可以实现数据缓存、会话存储、消息队列等功能。下面我将介绍如何在 Node.js 项目中应用 Redis，并提供一些常见使用场景的示例。

首先，需要安装 Redis 客户端，最常用的是 ioredis 库：

npm install ioredis

基本使用示例

下面是一个完整的示例，展示了 Redis 在 Node.js 中的基本操作和常见应用场景：

// 引入 ioredis 库
const Redis = require('ioredis');// 创建 Redis 客户端实例
// 可以配置主机、端口、密码等信息
const redis = new Redis({host: 'localhost',  // Redis 服务器地址port: 6379,         // Redis 端口号password: '',       // 密码，如果有的话db: 0,              // 数据库编号，默认为 0retryStrategy: (times) => {// 重连策略：随着重连次数增加，延迟逐渐增加return Math.min(times * 50, 2000);}
});// 监听连接错误
redis.on('error', (err) => {console.error('Redis 连接错误:', err);
});// 1. 基本键值对操作
async function basicOperations() {console.log('\n--- 基本键值对操作 ---');// 设置键值对，过期时间 10 秒await redis.set('username', 'john_doe', 'EX', 10);// 获取值const username = await redis.get('username');console.log('获取 username:', username);// 检查键是否存在const exists = await redis.exists('username');console.log('username 是否存在:', exists === 1);// 删除键const deleted = await redis.del('username');console.log('删除 username 结果:', deleted === 1);
}// 2. 哈希表操作 (适合存储对象)
async function hashOperations() {console.log('\n--- 哈希表操作 ---');// 存储用户信息await redis.hset('user:1001', {name: 'Alice',age: 30,email: 'alice@example.com'});// 获取用户的所有信息const user = await redis.hgetall('user:1001');console.log('用户 1001 的信息:', user);// 获取用户的单个字段const age = await redis.hget('user:1001', 'age');console.log('用户 1001 的年龄:', age);// 删除用户的某个字段await redis.hdel('user:1001', 'email');// 增加用户年龄await redis.hincrby('user:1001', 'age', 1);console.log('增加年龄后:', await redis.hget('user:1001', 'age'));
}// 3. 列表操作 (适合实现队列、栈等)
async function listOperations() {console.log('\n--- 列表操作 ---');// 向列表左侧添加元素await redis.lpush('tasks', '学习 Redis');await redis.lpush('tasks', '编写代码');await redis.lpush('tasks', '测试应用');// 获取列表长度const length = await redis.llen('tasks');console.log('任务列表长度:', length);// 获取列表所有元素const tasks = await redis.lrange('tasks', 0, -1);console.log('所有任务:', tasks);// 从列表右侧弹出元素 (实现队列)const nextTask = await redis.rpop('tasks');console.log('取出的下一个任务:', nextTask);console.log('剩余任务:', await redis.lrange('tasks', 0, -1));
}// 4. 集合操作 (适合存储唯一值，实现交集、并集等)
async function setOperations() {console.log('\n--- 集合操作 ---');// 向集合添加元素await redis.sadd('tags', 'javascript', 'nodejs', 'redis');// 获取集合所有元素const tags = await redis.smembers('tags');console.log('所有标签:', tags);// 检查元素是否在集合中const hasNodejs = await redis.sismember('tags', 'nodejs');console.log('是否包含 nodejs 标签:', hasNodejs === 1);// 添加另一个集合await redis.sadd('frameworks', 'express', 'koa', 'nodejs');// 计算两个集合的交集const common = await redis.sinter('tags', 'frameworks');console.log('标签和框架的交集:', common);
}// 5. 缓存应用示例
async function cacheExample() {console.log('\n--- 缓存应用示例 ---');// 模拟从数据库获取数据的函数async function fetchDataFromDB(id) {console.log('从数据库获取数据...');// 模拟数据库查询延迟await new Promise(resolve => setTimeout(resolve, 1000));return { id, name: `数据 ${id}`, content: '这是从数据库获取的内容' };}// 获取数据的函数，先检查缓存，缓存不存在则从数据库获取并更新缓存async function getData(id) {const cacheKey = `data:${id}`;// 尝试从缓存获取const cachedData = await redis.get(cacheKey);if (cachedData) {console.log('从缓存获取数据');return JSON.parse(cachedData);}// 缓存未命中，从数据库获取const data = await fetchDataFromDB(id);// 将数据存入缓存，设置过期时间 60 秒await redis.set(cacheKey, JSON.stringify(data), 'EX', 60);return data;}// 第一次获取，会从数据库获取console.log(await getData(1));// 第二次获取，会从缓存获取console.log(await getData(1));
}// 6. 发布订阅示例
async function pubSubExample() {console.log('\n--- 发布订阅示例 ---');// 创建一个订阅者客户端const subscriber = new Redis();// 订阅 channel1 频道subscriber.subscribe('channel1', (err, count) => {if (err) {console.error('订阅失败:', err);} else {console.log(`订阅了 ${count} 个频道`);}});// 监听消息subscriber.on('message', (channel, message) => {console.log(`从频道 ${channel} 收到消息: ${message}`);});// 发布消息setTimeout(async () => {await redis.publish('channel1', '这是一条测试消息');await redis.publish('channel1', '这是另一条消息');// 关闭订阅者setTimeout(() => {subscriber.unsubscribe('channel1');subscriber.quit();}, 1000);}, 1000);
}// 执行所有示例
async function runExamples() {try {await basicOperations();await hashOperations();await listOperations();await setOperations();await cacheExample();await pubSubExample();// 等待发布订阅示例完成setTimeout(() => {redis.quit();console.log('\n所有操作完成，关闭 Redis 连接');}, 3000);} catch (err) {console.error('操作出错:', err);redis.quit();}
}// 运行示例
runExamples();