generated from tailored/router-db-template
39 lines
1.4 KiB
TypeScript
39 lines
1.4 KiB
TypeScript
import { Redis } from 'ioredis';
|
|
import { config } from './config.ts';
|
|
import { useContextKey } from '@kevisual/context';
|
|
|
|
const redisConfig = {
|
|
host: config.REDIS_HOST || 'localhost',
|
|
port: parseInt(config.REDIS_PORT || '6379'),
|
|
password: config.REDIS_PASSWORD,
|
|
};
|
|
export const createRedisClient = (options = {}) => {
|
|
const redisClient = new Redis({
|
|
host: 'localhost', // Redis 服务器的主机名或 IP 地址
|
|
port: 6379, // Redis 服务器的端口号
|
|
// password: 'your_password', // Redis 的密码 (如果有)
|
|
db: 0, // 要使用的 Redis 数据库索引 (0-15)
|
|
keyPrefix: '', // key 前缀
|
|
retryStrategy(times) {
|
|
// 连接重试策略
|
|
return Math.min(times * 50, 2000); // 每次重试时延迟增加
|
|
},
|
|
maxRetriesPerRequest: null, // 允许请求重试的次数 (如果需要无限次重试)
|
|
...redisConfig,
|
|
...options,
|
|
});
|
|
redisClient.on('connect', () => {
|
|
console.log('Redis client connected successfully');
|
|
});
|
|
redisClient.on('error', (err) => {
|
|
console.error('Redis client error:', err);
|
|
});
|
|
return redisClient;
|
|
};
|
|
// 配置 Redis 连接
|
|
export const redis = useContextKey('redis', () => createRedisClient());
|
|
|
|
// 初始化 Redis 客户端
|
|
// export const redisPublisher = createRedisClient(); // 用于发布消息
|
|
// export const redisSubscriber = createRedisClient(); // 用于订阅消息
|