SpringCloud实战9-Stream消息驱动

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