Spring框架有哪些核心模块?
- 内容介绍
- 文章标签
- 相关推荐
本文共计2114个文字,预计阅读时间需要9分钟。
目录+重试+消息发送失败处理+消费错误处理+自定义MessageHandler类型+端点+Metrics指标+Serverless+分区系统+轮询消费者+支持多Binder同时使用+建立事件机制+重试+消费者+端点可配置
目录
- 重试
- 消息发送失败的处理
- 消费错误处理
- 自定义MessageHandler类型
- Endpoint端点
- Metrics指标
- Serverless
- Partition统一
- Polling Consumer
- 支持多个Binder同时使用
- 建立事件机制
重试
Consumer端可以配置重试次数,当消息消费失败的时候会进行重试。
底层使用Spring Retry去重试,重试次数可自定义配置。
# 默认重试次数为3,配置大于1时才会生效 spring.cloud.stream.bindings.<channelName>.consumer.maxAttempte=3
消息发送失败的处理
Producer发送消息出错的情况下,可以配置错误处理,将错误信息发送给对应ID的MessageChannel
- 消息发送失败的场景下,会将消息发送到一个
MessageChannel。
本文共计2114个文字,预计阅读时间需要9分钟。
目录+重试+消息发送失败处理+消费错误处理+自定义MessageHandler类型+端点+Metrics指标+Serverless+分区系统+轮询消费者+支持多Binder同时使用+建立事件机制+重试+消费者+端点可配置
目录
- 重试
- 消息发送失败的处理
- 消费错误处理
- 自定义MessageHandler类型
- Endpoint端点
- Metrics指标
- Serverless
- Partition统一
- Polling Consumer
- 支持多个Binder同时使用
- 建立事件机制
重试
Consumer端可以配置重试次数,当消息消费失败的时候会进行重试。
底层使用Spring Retry去重试,重试次数可自定义配置。
# 默认重试次数为3,配置大于1时才会生效 spring.cloud.stream.bindings.<channelName>.consumer.maxAttempte=3
消息发送失败的处理
Producer发送消息出错的情况下,可以配置错误处理,将错误信息发送给对应ID的MessageChannel
- 消息发送失败的场景下,会将消息发送到一个
MessageChannel。

