Redis (@halsp/redis)

添加 @halsp/redis 插件以使用 Redis

@halsp/redis 的功能基于 Redis，使用 @halsp/redis 可以简化 Redis 的管理

安装

npm install @halsp/redis

快速开始

在 startup.ts 中

import '@halsp/redis';

startup.useRedis({
  url: "redis://test",
})

在中间件或服务通过依赖注入获取 Redis 连接实例

import { Middleware } from "@halsp/core";
import { RedisConnection, RedisInject } from "@halsp/redis";

class TestMiddleware extends Middleware {
  @RedisInject()
  private readonly redisClient!: RedisConnection;

  async invoke(): Promise<void> {
    await redisClient.set("key", "value");
    const value = redisClient.get("key");

    this.ok({ value });
  }
}

连接多个 Redis

@halsp/redis 支持多个 Redis 连接，只需调用多次 useRedis ，并传参 identity 用于区分

import "@halsp/redis";

startup
  .useRedis({
    identity: "db1",
    url: "redis://redis1",
    // ...
  })
  .useRedis({
    identity: "db2",
    url: "redis://redis2",
    // ...
  });

在中间件或服务中，给装饰器 @RedisInject() 传参字符串以区分连接

import { Middleware } from "@halsp/core";
import { RedisConnection, RedisInject } from "@halsp/redis";

class TestMiddleware extends Middleware {
  @RedisInject("db1")
  private readonly redisClient1!: RedisConnection;
  @RedisInject("db2")
  private readonly redisClient2!: RedisConnection;

  async invoke(): Promise<void> {
    this.redisClient1.set("key1", "value1");
    this.redisClient2.set("key2", "value2");
    await this.next();
  }
}

注意

只有在 useRedis 之后的中间件，才能获取到 Redis 连接实例

获取实例

你可以通过依赖注入的方式获取实例，也可以用 ctx.getRedis 获取实例

依赖注入

用 @RedisInject 装饰属性或构造函数参数，通过 @halsp/inject 依赖注入创建实例

import { Middleware } from "@halsp/core";
import { RedisConnection, RedisInject } from "@halsp/redis";

@Inject
class TestMiddleware extends Middleware {
  constructor(
    @RedisInject private readonly connection: RedisConnection,
    @RedisInject("id2") private readonly connection2: RedisConnection
  ) {}

  @RedisInject("id1")
  private readonly connection1!: RedisConnection;

  async invoke(): Promise<void> {
    await this.next();
  }
}

ctx.getRedis

使用 ctx.getRedis 的方式更灵活，但代码易读性不如使用依赖注入

import "@halsp/redis";

startup.use(async (ctx, next) => {
  const connection1 = await ctx.getRedis("id1");
  const connection2 = await ctx.getRedis("id2");
  const connection = await ctx.getRedis();
});

生命周期与作用域

作用域

通过 startup.useRedis 函数传参 injectType 以修改该实例作用域

参考 https://halsp.org/usage/inject.html#作用域

import '@halsp/redis';

startup
  .useRedis({
    url: "redis://redis1",
    injectType: InjectType.Singleton
  })

生命周期

Redis 连接实例通过依赖注入 @halsp/inject 创建，因此其生命周期符合 @halsp/inject 规则

参考 http://halsp.org/usage/inject.html#生命周期

销毁的行为是在 startup.useInject 中间件的返回管道中触发，伪代码逻辑如

await initInject(); // 初始化依赖注入
await initializeRedis(); // 初始化 Redis 连接
await next(); // 执行下个中间件
await dispose(); // 销毁