Fastify中如何在内部服务里访问Redis客户端？

你已经通过@fastify/redis传入了自定义初始化的Redis客户端，最合理的方案就是复用这个已初始化的客户端实例，不需要额外创建新连接，具体步骤如下：

1. 封装Redis客户端初始化逻辑 #

单独创建一个Redis工具文件（比如./cache/redis.js），在这里统一处理客户端的初始化和导出：

// ./cache/redis.js
import Redis from 'ioredis'; // 根据你实际使用的Redis客户端库调整

// 初始化客户端的函数
export const initRedis = (host, password) => {
  return new Redis({
    host,
    password,
    // 其他必要配置，比如端口、数据库编号等
  });
};

// 维护单例实例，供全局复用
export let redisClient;

// 用于启动时初始化客户端的方法
export const setupRedisClient = (host, password) => {
  redisClient = initRedis(host, password);
  return redisClient;
};

2. 在Fastify中复用该客户端 #

在Fastify应用启动文件中，初始化Redis客户端并传给@fastify/redis插件：

// app.js 或你的Fastify启动文件
import { setupRedisClient } from './cache/redis.js';
import redisPlugin from '@fastify/redis';

// 初始化Redis客户端
const redisClient = setupRedisClient(app.config.REDIS_INTERNAL__HOST, app.config.REDIS_INTERNAL__PASS);

// 注册Redis插件，传入已初始化的客户端
app.register(redisPlugin, {
  client: redisClient,
  closeClient: true,
});

3. 在独立服务中直接使用客户端 #

在无法获取FastifyInstance的工具函数或服务文件中，直接导入已初始化的redisClient即可：

// 比如你的缓存服务文件
import { redisClient } from './cache/redis.js';

const cacheOrder = async (order) => {
  // 注意：Redis只能存储字符串，对象需要序列化
  await redisClient.set('order', JSON.stringify(order));
  // 可选：设置过期时间，比如1小时
  // await redisClient.set('order', JSON.stringify(order), 'EX', 3600);
};

关键说明 #

• 复用同一个客户端实例可以避免创建多个Redis连接，节省资源，同时保证和Fastify内部使用的是同一个连接，数据操作一致。
• 因为你设置了closeClient: true，Fastify应用关闭时会自动关闭这个Redis客户端，无需手动处理，避免内存泄漏。
• 如果你的Redis客户端库不是ioredis，只需调整initRedis函数中的初始化逻辑即可，核心思路不变。

内容的提问来源于stack exchange，提问作者Nguyen Hoang Vu