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则没有打印出消息。

     

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

相关文章
|
3天前
|
前端开发 Java 开发者
Spring生态学习路径与源码深度探讨
【11月更文挑战第13天】Spring框架作为Java企业级开发中的核心框架,其丰富的生态系统和强大的功能吸引了无数开发者的关注。学习Spring生态不仅仅是掌握Spring Framework本身,更需要深入理解其周边组件和工具,以及源码的底层实现逻辑。本文将从Spring生态的学习路径入手,详细探讨如何系统地学习Spring,并深入解析各个重点的底层实现逻辑。
23 9
|
23天前
|
前端开发 Java 数据库
SpringBoot学习
【10月更文挑战第7天】Spring学习
33 9
|
24天前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经:从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经,旨在帮助开发者系统化、体系化地掌握核心技术,提升技术实力,从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合,解决传统Dubbo架构缺乏HTTP入口的问题,实现高性能的微服务网关。
|
24天前
|
XML Java 数据格式
Spring学习
【10月更文挑战第6天】Spring学习
19 1
|
28天前
|
Java 测试技术 开发者
springboot学习四:Spring Boot profile多环境配置、devtools热部署
这篇文章主要介绍了如何在Spring Boot中进行多环境配置以及如何整合DevTools实现热部署,以提高开发效率。
52 2
|
28天前
|
前端开发 Java 程序员
springboot 学习十五:Spring Boot 优雅的集成Swagger2、Knife4j
这篇文章是关于如何在Spring Boot项目中集成Swagger2和Knife4j来生成和美化API接口文档的详细教程。
49 1
|
28天前
|
Java API Spring
springboot学习七:Spring Boot2.x 拦截器基础入门&实战项目场景实现
这篇文章是关于Spring Boot 2.x中拦截器的入门教程和实战项目场景实现的详细指南。
19 0
springboot学习七:Spring Boot2.x 拦截器基础入门&实战项目场景实现
|
28天前
|
Java API Spring
springboot学习六:Spring Boot2.x 过滤器基础入门&实战项目场景实现
这篇文章是关于Spring Boot 2.x中过滤器的基础知识和实战项目应用的教程。
21 0
springboot学习六:Spring Boot2.x 过滤器基础入门&实战项目场景实现
|
28天前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
48 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
28天前
|
Java 关系型数据库 MySQL
springboot学习四:springboot链接mysql数据库,使用JdbcTemplate 操作mysql
这篇文章是关于如何使用Spring Boot框架通过JdbcTemplate操作MySQL数据库的教程。
21 0
springboot学习四:springboot链接mysql数据库,使用JdbcTemplate 操作mysql
下一篇
无影云桌面