初识spring cloud stream
spring cloud stream是什莫?能做什么?为什么要引入他?
spring cloud stream中文指导手册地址:m.wang1314.com/doc/webapp/topic/20971999.html
spring cloud stream通过Binder作为绑定层来实现隔离:
spring cloud stream常用注解:
至此,开始写个小Demo,以RabbitMQ为例:
生产者8801:
下面时消费者8802: 和8803代码一样
8802 8803都启动之后,有两个问题:1.8802 8803同时都收到了消息,有重复消费问题 2.消息持久化问题;
两个消费者,8802 8803相同组就ok了,生产者如果发送消息之后,同一个组下面各个微服务通过轮询读取消息的。
说完重复消费之后,再说说持久化的问题:8803只要配置了groupA,等到再次开启的时候,会接收到生产者之前发送的消息,这就是持久化。