RabbitMq整合Springboot超全实战案例+图文演示+源码自取_rabbitmq 实战项目_springboot3.x 配置rabbitmq

先自我介绍一下，小编浙江大学毕业，去过华为、字节跳动等大厂，目前阿里P7

深知大多数程序员，想要提升技能，往往是自己摸索成长，但自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年最新大数据全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，涵盖了95%以上大数据知识点，真正体系化！

由于文件比较多，这里只是将部分目录截图出来，全套包含大厂面经、学习笔记、源码讲义、实战项目、大纲路线、讲解视频，并且后续会持续更新

如果你需要这些资料，可以添加V获取：vip204888 （备注大数据）

正文

启动测试:

下单付款加积分示例

介绍

下面以用户在下单付款后系统为用户添加积分的案例为例来对mq进行场景使用

代码

先建两张数据库表,一张订单表,一张用户积分表

用户积分表

业务场景:

通过orderNo进行订单付款,生产者生成付款消息,付款后用户订单状态调整为已付款状态,消费者消费该消息并且为用户积分表添加在原有积分基础上添加该订单所奖励的积分,积分值这里直接取订单表中的productPrice字段数据

初始化数据库表

付款订单号为1336557511364313088订单,status付款状态初始化为0(未付款),1是付款状态

该订单目前积分为

生产者接口:

消费者监听消费

 

启动测试:

 

查看数据库

 积分新增成功,由原先的1000,新增了订单的productPrice的1399变为了2399

消费成功

注意在启动测试这个案例前先把之前测试时设置的手动签收和预取关掉,否则消费者不会自动实时消费生产者生产的消息

可靠性投递示例

介绍

可靠性投递是指在消息队列中确保消息得到正确且可靠地传递，即使在出现网络故障或服务器宕机等异常情况下，消息也不会丢失。在RabbitMQ中，可靠性投递通常采用以下两个概念：

1. 生产者确认（Publisher Confirms）：当生产者将消息发送到RabbitMQ时，会等待RabbitMQ发送确认消息，告诉生产者消息已被成功接收。如果RabbitMQ没有收到消息，或者消息发送失败，则会通知生产者重新发送消息。
2. 消费者确认（Consumer Acknowledgements）：当消费者从队列中接收消息时，它们会发送一个确认消息给RabbitMQ，告诉RabbitMQ已经接收到并处理了该消息。如果消费者未发送确认消息，则RabbitMQ会认为消息未被正确处理，从而重新将消息发送给消费者。

代码

生产者服务中开启配置