Spring cloud Stream 的概要介绍
image.png
- 应用程序通过input、output和Stream中的Binder进行交互，Stream中的Binder则与中间件交互，Binder是Stream中的抽象概念（类似Delphi中的Binder)是应用与消息中间件之间的联合器。
- 优势：使用Strean最大的方便之处莫过于对消息中间件的进一步封装，可以做到代码层面对消息中间件的无感知，甚至于动态的却换中间件。
- 局限：Spring cloud stream 支持的binder只有2种 RabbitMq和Kafka.
SpringCloud Stream可以实现rabbitMq 操作消息的能力
目前我采用的是直接操作rabbitmq,以后有采用spring cloud stream操作消息时再补充例子。
一个应用启动多个实例时，如何做到只有一个实例可以收到消息
一个应用启动多个实例时，如何做到只有一个实例可以收到消息。spring
cloud里面提供一个配置配置分组的功能
#设置分组实例
spring.cloud.stream.bindings.myMessage.group = order
消息订阅分组只有一个app实例可以收到消息
不然rabbitMq种存储对象被系列号为base64配置
image.png
网友评论