SpringCloud学习(二十一):Stream的分组消费与持久化

简介: SpringCloud学习(二十一):Stream的分组消费与持久化

一、分组消费


     

1、依照8802克隆出一个8803


cloud-stream-rabbitmq-consumer8803

   

2、运行发现问题

     

启动服务注册eureka7001、rabbitmq、消息生产者8801、消息消费者8802、8803


访问           http://localhost:8801/sendMessage        刷新两次,发送两条消息


291013299ff34caeb0f5dabbf83f788c.pngb426707129ce432c9696ef575c6f8dc6.png034439e15435459eb181a931b46ae8c7.png


可以看到,8802和8803都收到了消息。

     

但事实上一条消息只能由一个消费者消费,这就是重复消费问题。

     

3、如何解决


进入rabbitmq的exchanges中可以看到,我们的8802和8803默认在不同的分组.


019177ce129944a182ecafb092123d96.png

微服务应用放置于同一个group中,就能够保证消息只会被其中一个应用消费一次。

不同的组是可以消费的,同一个组内会发生竞争关系,只有其中一个可以消费。

       

假如我们不想让8802和8803重复接到消息,只想让消息被他们其中的一个接收,只需要为他们指定相同的分组即可。

1085c1dde6f040c39fb587f51f0791ec.png

再次测试:

b549670413bd4dcf9b967148d24af32c.png7b65a743195e47abb43c5e4405150fdb.png1d988560f30c43b88acb96ba05aa3146.png


可以看到,生产者8801发出的消息只会被8802和8803中的一个接收(默认为轮询)。


二、消息持久化



     

现在我们将8802中的分组去掉,保留8803中的分组 。然后关闭8802和8803,只剩下eureka7001和生产者8801在运行。


此时刷新        http://localhost:8801/sendMessage        4次。

ed4e19eaa713457980580f663421be1e.png


然后再运行消费者8802和8803。

     

可以看到,即使在8801发送消息的时候8803并没有运行,但有分组属性的8803后台还是打印出了消息;

be64ad8b0b74424fb3c66f7508df33db.png


而没有分组属性的8802则没有打印出消息。

     

这个现象就被成为消息持久化。

相关文章
|
15天前
|
负载均衡 Java 开发者
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
59 5
|
1月前
|
前端开发 Java 开发者
Spring生态学习路径与源码深度探讨
【11月更文挑战第13天】Spring框架作为Java企业级开发中的核心框架,其丰富的生态系统和强大的功能吸引了无数开发者的关注。学习Spring生态不仅仅是掌握Spring Framework本身,更需要深入理解其周边组件和工具,以及源码的底层实现逻辑。本文将从Spring生态的学习路径入手,详细探讨如何系统地学习Spring,并深入解析各个重点的底层实现逻辑。
59 9
|
2月前
|
前端开发 Java 数据库
SpringBoot学习
【10月更文挑战第7天】Spring学习
38 9
|
24天前
|
Java Kotlin 索引
学习Spring框架特性及jiar包下载
Spring 5作为最新版本,更新了JDK基线至8,修订了核心框架,增强了反射和接口功能,支持响应式编程及Kotlin语言,引入了函数式Web框架,并提升了测试功能。Spring框架可在其官网下载,包括文档、jar包和XML Schema文档,适用于Java SE和Java EE项目。
27 0
|
2月前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经:从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经,旨在帮助开发者系统化、体系化地掌握核心技术,提升技术实力,从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合,解决传统Dubbo架构缺乏HTTP入口的问题,实现高性能的微服务网关。
|
2月前
|
XML Java 数据格式
Spring学习
【10月更文挑战第6天】Spring学习
22 1
|
2月前
|
Java 测试技术 开发者
springboot学习四:Spring Boot profile多环境配置、devtools热部署
这篇文章主要介绍了如何在Spring Boot中进行多环境配置以及如何整合DevTools实现热部署,以提高开发效率。
97 2
|
2月前
|
前端开发 Java 程序员
springboot 学习十五:Spring Boot 优雅的集成Swagger2、Knife4j
这篇文章是关于如何在Spring Boot项目中集成Swagger2和Knife4j来生成和美化API接口文档的详细教程。
159 1
|
2月前
|
Java API Spring
springboot学习七:Spring Boot2.x 拦截器基础入门&实战项目场景实现
这篇文章是关于Spring Boot 2.x中拦截器的入门教程和实战项目场景实现的详细指南。
33 0
springboot学习七:Spring Boot2.x 拦截器基础入门&实战项目场景实现
|
2月前
|
Java API Spring
springboot学习六:Spring Boot2.x 过滤器基础入门&实战项目场景实现
这篇文章是关于Spring Boot 2.x中过滤器的基础知识和实战项目应用的教程。
32 0
springboot学习六:Spring Boot2.x 过滤器基础入门&实战项目场景实现