rabbitMq怎么保证消息正确投递和消费

时间: 2024-06-12 21:08:40 浏览: 151

Spring Boot + RabbitMQ发送邮件(保证消息 100% 投递成功并被消费).docx

### Spring Boot + RabbitMQ 发送邮件（保证消息 100% 投递成功并被消费） #### 一、整体流程图与概念说明在深入探讨如何使用Spring Boot结合RabbitMQ来确保邮件消息能够100%投递成功并被消费之前，首先通过一张流程图来大致了解整个系统的运作原理。 **流程图解析：** 1. **生产者**（Producer）将邮件消息发布到**交换机**（Exchange）。 2. **交换机**根据指定的**路由键**（Routing Key）将消息转发至对应的**队列**（Queue）。 3. **消费者**（Consumer）从队列中拉取消息，并执行邮件发送逻辑。 4. 若邮件发送失败，则记录消息日志，并由**定时任务**定期检查这些失败的消息记录，尝试重新发送。 #### 二、实现思路详解 1. **163邮箱授权码的获取**： - 登录163邮箱，进入设置页面获取授权码。 - 授权码用于配置Spring Boot项目的`spring.mail.password`属性。 2. **编写发送邮件工具类**： - 创建`MailUtil`类，封装邮件发送逻辑。 - 使用JavaMailSender接口进行邮件发送操作。 - 可以支持多种类型的邮件发送，如文本、HTML等。 3. **编写RabbitMQ配置文件**： - 配置RabbitMQ连接信息。 - 定义交换机、队列以及绑定关系。 - 设置消息确认机制和消费确认机制。 4. **生产者发起调用**： - 创建生产者服务类`TestServiceImpl`，负责将邮件消息发布到RabbitMQ。 - 使用`@RabbitTemplate.ConfirmCallback`注解监听消息是否成功到达交换机。 - 使用`@RabbitTemplate.ReturnCallback`注解监听消息是否成功路由到队列。 5. **消费者发送邮件**： - 创建消费者类`MailConsumer`，监听队列中的消息。 - 消费者接收到消息后，调用`MailUtil`工具类发送邮件。 - 实现`@RabbitListener`监听器接收消息并处理。 - 消费者需要确认消息已正确处理。 6. **定时任务定时拉取投递失败的消息，重新投递**： - 使用Spring Boot的定时任务功能，如`@Scheduled`注解。 - 查询数据库中状态为“发送失败”的消息记录。 - 将这些消息重新发送到RabbitMQ。 7. **各种异常情况的测试验证**： - 测试网络不稳定时消息能否正常发送。 - 测试RabbitMQ服务不可用时消息能否重试发送。 - 测试邮件服务器拒绝消息时系统如何处理。 8. **拓展：使用动态代理实现消费端幂等性验证和消息确认（ack）**： - 使用AOP（面向切面编程）技术实现消息消费幂等性的验证。 - 对于重复消费的消息进行过滤，避免多次处理同一消息。 - 实现消息确认机制，确保消息被正确处理后再向RabbitMQ发送确认。 #### 三、项目介绍 - **SpringBoot版本**：2.1.5.RELEASE。 - **RabbitMQ版本**：3.7.15。 - **核心组件**： - `MailUtil`：发送邮件工具类。 - `RabbitConfig`：RabbitMQ配置类。 - `TestServiceImpl`：生产者服务类。 - `MailConsumer`：消费者类。 - `ResendMsg`：定时任务类，用于重新投递失败的消息。 - **代码实现**示例： - **163邮箱授权码的获取**：需登录163邮箱设置页面获取。 - **POM文件**：引入RabbitMQ和邮件发送所需的依赖。 - **RabbitMQ配置**：定义交换机、队列及绑定关系，并配置消息确认机制。 - **表结构**：定义消息日志表，用于记录消息状态，包括交换机名称、路由键等信息。 - **MailUtil类**：实现邮件发送逻辑。 - **RabbitConfig类**：配置RabbitMQ连接、消息转换器、确认回调等。 #### 四、代码实现 **部分关键代码示例**： 1. **163邮箱授权码的获取**： - 获取授权码作为配置文件中的`spring.mail.password`值。 2. **RabbitMQ配置**： - `rabbitmq.properties`文件配置示例： ```properties spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest spring.rabbitmq.publisher-confirms=true spring.rabbitmq.publisher-returns=true spring.rabbitmq.template.mandatory=true ``` - `RabbitConfig.java`示例： ```java @Configuration @Slf4j public class RabbitConfig { // ... (省略了部分代码) @Bean public RabbitTemplate rabbitTemplate() { RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); rabbitTemplate.setMessageConverter(converter()); rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { if (ack) { log.info("消息成功发送到Exchange"); String msgId = correlationData.getId(); msgLogService.updateStatus(msgId, Constant.MsgLogStatus.DELIVER_SUCCESS); } else { log.info("消息发送到Exchange失败, {}, cause: {}", correlationData, cause); } }); rabbitTemplate.setMandatory(true); rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> { log.info("消息从Exchange路由到Queue失败: exchange:{}, route:{}, replyCode:{}, replyText:{}, message:{}", exchange, routingKey, replyCode, replyText, message); }); return rabbitTemplate; } // ... (省略了其他配置代码) } ``` 以上是基于Spring Boot和RabbitMQ实现邮件发送系统的核心思想和技术细节。通过这样的设计，可以有效保证消息的可靠性和一致性，确保每一条消息都能够被成功投递并被正确处理。

要保证 RabbitMQ 中的消息正确投递和消费，可以采取以下措施： 1. 持久化消息：将消息标记为持久化，以确保即使在 RabbitMQ 服务器崩溃或重启后，消息也能够得到保留。通过设置消息的 delivery mode 为 2（持久化），确保消息在磁盘上进行持久化存储。 2. 消费者确认机制：在消费者接收并处理消息后，向 RabbitMQ 发送确认信号。通过开启消费者的手动消息确认模式（manual ack mode），在消费者处理消息后主动发送确认信号，告知 RabbitMQ 该消息已成功处理。如果消费者在处理消息过程中发生错误，可以拒绝该消息，或者重新将其放回队列等待重新处理。 3. 限制消费者的并发数量：通过设置同时处理的消费者数量限制来控制消息的消费速度。这样可以避免消费者过载导致消息无法及时处理。 4. 设置消息的 TTL（Time-To-Live）：通过设置消息的过期时间，可以确保过期的消息会被 RabbitMQ 自动丢弃，从而避免消费者消费过期的消息。 5. 使用备份交换器（Alternate Exchange）：当消息发送到某个交换器时无法被路由到任何队列时，可以将这些消息发送到备份交换器中。备份交换器可以保证消息不会丢失，并且可以对无法路由的消息进行处理。

阅读全文

rabbitMq怎么保证消息正确投递和消费

相关推荐

Spring Boot + RabbitMQ发生邮件(保证消息 100% 投递成功并被消费).docx

springboot整合rabbitmq，开启手工确认。保证消息100%投递

rabbitmq的可靠性投递

超级好用的RabbitMQ消息100投递的解决方案.docx

RabbitMQ可靠性投递与实践经验.rar

Spring Boot与RabbitMQ实现邮件100%投递与消费确认

SpringBoot2与RabbitMQ整合实现可靠性消息投递

RabbitMQ延迟消息插件：实现高效消息调度

使用RabbitMQ实现消息的可靠性投递

使用RabbitMQ实现消息的顺序消费

使用RabbitMQ进行消息过滤和路由

SpringBoot集成RabbitMQ实现消息队列

Spring Boot整合RabbitMQ实现消息队列

RabbitMQ中消息的优先级队列实现

使用RabbitMQ实现消息的延迟处理

RabbitMQ中的消息确认和回退机制

rabbitmq的百分百投递

RabbitMQ消息丢失

RabbitMQ重复消费

最新推荐

SSM Java项目：StudentInfo 数据管理与可视化分析

管理建模和仿真的文件

负载均衡技术深入解析：确保高可用性的网络服务策略

怎么解决头文件重复包含

pyedgar：Python库简化EDGAR数据交互与文档下载

"互动学习：行动中的多样性与论文攻读经历"

网络监控工具使用宝典：实时追踪网络状况的专家级技巧

unity 实现子物体不跟随父物体移动和旋转

Node.js环境下wfdb文件解码与实时数据处理

关系数据表示学习