在之前的文章中，我们详细介绍了 SpringBoot 整合 mail 实现各类邮件的自动推送服务。

但是这类服务通常不稳定，当出现网络异常的时候，会导致邮件推送失败。

本篇文章将介绍另一种高可靠的服务架构，实现邮件 100% 被投递成功。类似的短信自动发送等服务也大体相同。

01、先来一张流程图

本文内容主要围绕这个流程图展开，利用 RabbitMQ 消息队列来实现邮件 100% 被投递，内容涵盖了 RabbitMQ 很多知识点，如：

• 生产者和消费者模型
• 消息发送确认机制
• 消费确认机制
• 消息的重新投递
• 消费幂等性, 等等

02、实现思路

• 1.创建一台 Linux 服务器，并安装 RabbitMQ
• 2.开放 QQ 邮箱或者其它邮箱授权码，用于发送邮件
• 3.创建邮件发送项目并编写代码
• 4.发送邮件测试
• 5.消息发送失败处理

03、环境准备

获取邮箱授权码的目的，主要是为了通过代码进行发送邮件，例如 QQ 邮箱授权码获取方式，如下图：

点击【开启】按钮，然后发送短信，即可获取授权码，该授权码就是配置文件spring.mail.password需要的密码！

04、项目介绍

• springboot版本：2.1.5.RELEASE
• RabbitMQ版本：3.6.5
• SendMailUtil：发送邮件工具类
• ProduceServiceImpl：生产者，发送消息
• ConsumerMailService：消费者，消费消息，发送邮件

05、代码实现

5.1、创建项目

在 IDEA 下创建一个名称为smail的 Springboot 项目，pom文件中加入amqp和mail。

publicinterfaceMsgLogService{/***插入消息日志*@parammsgLog*/voidinsert(MsgLogmsgLog);/***更新消息状态*@parammsgId*@paramstatus*/voidupdateStatus(StringmsgId,Integerstatus);/***查询消息*@parammsgId*@return*/MsgLogselectByMsgId(StringmsgId);}

7.3、改写服务逻辑

在生产服务类中，新增数据写入。

同时，在RabbitConfig服务配置，当消息发送成功之后，新增更新消息状态逻辑。

改造消费者ConsumerMailService，每次消费的时候，从数据库中查询，如果消息已经被消费，不用再重复发送数据！

这样即可保证，如果 rabbitMQ 服务器，即使重启之后重新推送消息，通过数据库判断，也不会重复消费进而发生业务异常！

7.4、利用定数任务对消息投递失败进行补偿

当 rabbitMQ 服务器突然挂掉之后，生成者就无法正常进行投递数据，此时因为消息已经被记录到数据库，因此我们可以利用定数任务查询出没有投递成功的消息，进行补偿投递。

利用定数任务，对投递失败的消息进行补偿投递，基本可以保证消息 100% 消费成功！

08、总结

本文主要是通过发送邮件这个业务案例，来讲解 Springboot 与 rabbitMQ 技术的整合和使用！

当然解决这个业务需求的技术方案还有很多，例如 Springboot 与 rocketMQ 也可以实现这个需求，这个会在后期的文章讲解！

代码都经过自测，希望小伙伴能有所收获！

项目源代地址如下！

https://gitee.com/pzblogs/spring-boot-example-demo

09、参考

1、https://www.jianshu.com/p/dca01aad6bc8

• IO 核心知识万字汇总，太硬核了！

• 一文讲透 TCP 滑动窗口实现机制，绝了！

• 浅谈ConcurrentHashMap 线程安全的具体实现方式

• SpringBoot+mail 轻松实现各类邮件自动推送

• 听说过 HashMap 会导致CPU飙升100%吗？

• 手把手带你开发一套用户权限系统，精确到按钮级