企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
## Redis [Redis](https://redis.io/) 传输器实现了[Pub/Sub(发布/订阅)](https://redis.io/topics/pubsub)消息传递范例,并利用了 `Redis` 的 [Pub/Sub](https://redis.io/topics/pubsub) 特性。 已发布的消息按渠道分类,不知道哪些订阅者(如果有)最终会收到该消息。 每个微服务可以订阅任意数量的渠道。 此外,一次可以订阅多个频道。这意味着如果发布了一条消息,并且没有订阅者对此消息感兴趣,则该消息将被删除并且无法恢复。 因此,您不能保证消息或事件将至少由一项服务处理。 一条消息可以由多个订户订阅(并接收)。 ![](https://docs.nestjs.com/assets/Redis_1.png) ### 安装 构建基于 `Redis` 的微服务,请首先安装所需的软件包(注意目前支持的 Redis 版本是 ^3,而不是最新的 ^4): ``` $ npm i --save redis ``` > ps:如果你的 `redis` 无法使用,请尝试使用 `redis@^3` ### 概述 要使用 `Redis` 传输器,请将以下选项对象传递给 `createMicroservice()` 方法: > main.ts ```typescript const app = await NestFactory.createMicroservice(AppModule, { transport: Transport.REDIS, options: { url: 'redis://localhost:6379', }, }); ``` > `Transport` 需要从 `@nestjs/microservices` 包导入。 ### 选项 有许多可用的选项可以确定传输器的行为。`Redis` 公开了下面描述的属性。 | | | | :--------------------- | :-------------------------- | | `url` | 连接网址| | `retryAttempts` | 连接尝试的总数 | | `retryDelay` | 连接重试延迟(ms) | [Redis](https://www.npmjs.com/package/redis#options-object-properties)客户端支持的所有属性该传输器都支持。 ### 客户端 像其他微服务传输器一样,你可以在创建`ClientProxy`实例时传输[一些选项](https://docs.nestjs.com/microservices/basics#client)。 一种来创建实例的方法是使用`ClientsModule`。要使用`ClientsModule`创建一个客户端实例,引入并使用`register()`方法并传递一个 `options` 对象,该对象具有与前面在 `createMicroservice()` 方法具有相同的属性。`name`属性被用于注入`token`,更多关于`ClientsModule`内容参见[这里](https://docs.nestjs.com/microservices/basics#client)。 ```typescript @Module({ imports: [ ClientsModule.register([ { name: 'MATH_SERVICE', transport: Transport.REDIS, options: { url: 'redis://localhost:6379', } }, ]), ] ... }) ``` 也可以使用其他创建客户端的实例( `ClientProxyFactory` 或 `@Client()` )。 ### 上下文 在更复杂的场景中,您可能希望访问关于传入请求的更多信息。在`Redis` 中,您可以访问 `RedisContext`对象。 ```typescript @MessagePattern('notifications') getDate(@Payload() data: number[], @Ctx() context: RedisContext) { console.log(`Channel: ${context.getChannel()}`); } ``` > `@Payload()`, `@Ctx()` 和 `RedisContext` 需要从 `@nestjs/microservices` 包导入.