## 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` 包导入.
- 介绍
- 概述
- 第一步
- 控制器
- 提供者
- 模块
- 中间件
- 异常过滤器
- 管道
- 守卫
- 拦截器
- 自定义装饰器
- 基础知识
- 自定义提供者
- 异步提供者
- 动态模块
- 注入作用域
- 循环依赖
- 模块参考
- 懒加载模块
- 应用上下文
- 生命周期事件
- 跨平台
- 测试
- 技术
- 数据库
- Mongo
- 配置
- 验证
- 缓存
- 序列化
- 版本控制
- 定时任务
- 队列
- 日志
- Cookies
- 事件
- 压缩
- 文件上传
- 流式处理文件
- HTTP模块
- Session(会话)
- MVC
- 性能(Fastify)
- 服务器端事件发送
- 安全
- 认证(Authentication)
- 授权(Authorization)
- 加密和散列
- Helmet
- CORS(跨域请求)
- CSRF保护
- 限速
- GraphQL
- 快速开始
- 解析器(resolvers)
- 变更(Mutations)
- 订阅(Subscriptions)
- 标量(Scalars)
- 指令(directives)
- 接口(Interfaces)
- 联合类型
- 枚举(Enums)
- 字段中间件
- 映射类型
- 插件
- 复杂性
- 扩展
- CLI插件
- 生成SDL
- 其他功能
- 联合服务
- 迁移指南
- Websocket
- 网关
- 异常过滤器
- 管道
- 守卫
- 拦截器
- 适配器
- 微服务
- 概述
- Redis
- MQTT
- NATS
- RabbitMQ
- Kafka
- gRPC
- 自定义传输器
- 异常过滤器
- 管道
- 守卫
- 拦截器
- 独立应用
- Cli
- 概述
- 工作空间
- 库
- 用法
- 脚本
- Openapi
- 介绍
- 类型和参数
- 操作
- 安全
- 映射类型
- 装饰器
- CLI插件
- 其他特性
- 迁移指南
- 秘籍
- CRUD 生成器
- 热重载
- MikroORM
- TypeORM
- Mongoose
- 序列化
- 路由模块
- Swagger
- 健康检查
- CQRS
- 文档
- Prisma
- 静态服务
- Nest Commander
- 问答
- Serverless
- HTTP 适配器
- 全局路由前缀
- 混合应用
- HTTPS 和多服务器
- 请求生命周期
- 常见错误
- 实例
- 迁移指南
- 发现
- 谁在使用Nest?