SpringBoot+RabbitMQ实现消息可靠性投递

2021-02-17 12:19

阅读：504

摘抄自简书:https://www.jianshu.com/p/9feddd4af8ee

RabbitMQ是目前主流的消息中间件，非常适用于高并发环境。各大互联网公司都在使用的MQ技术，晋级技术骨干、团队核心的必备技术！

谈到消息的可靠性投递，无法避免的，在实际的工作中会经常碰到，比如一些核心业务需要保障消息不丢失，接下来我们看一个可靠性投递的流程图，说明可靠性投递的概念：

Step 1：首先把消息信息(业务数据）存储到数据库中，紧接着，我们再把这个消息记录也存储到一张消息记录表里（或者另外一个同源数据库的消息记录表）
Step 2：发送消息到MQ Broker节点（采用confirm方式发送，会有异步的返回结果）
Step 3、4：生产者端接受MQ Broker节点返回的Confirm确认消息结果，然后进行更新消息记录表里的消息状态。比如默认Status = 0 当收到消息确认成功后，更新为1即可！
Step 5：但是在消息确认这个过程中可能由于网络闪断、MQ Broker端异常等原因导致回送消息失败或者异常。这个时候就需要发送方（生产者）对消息进行可靠性投递了，保障消息不丢失，100%的投递成功！（有一种极限情况是闪断，Broker返回的成功确认消息，但是生产端由于网络闪断没收到，这个时候重新投递可能会造成消息重复，需要消费端去做幂等处理）所以我们需要有一个定时任务，（比如每5分钟拉取一下处于中间状态的消息，当然这个消息可以设置一个超时时间，比如超过1分钟 Status = 0 ，也就说明了1分钟这个时间窗口内，我们的消息没有被确认，那么会被定时任务拉取出来）
Step 6：接下来我们把中间状态的消息进行重新投递 retry send，继续发送消息到MQ ，当然也可能有多种原因导致发送失败
Step 7：我们可以采用设置最大努力尝试次数，比如投递了3次，还是失败，那么我们可以将最终状态设置为Status = 2 ，最后交由人工解决处理此类问题（或者把消息转储到失败表中）。
接下来，我们使用SpringBoot2.x实现这一可靠性投递策略：

废话不多说，直接上代码：

数据库库表结构：订单表和消息记录表

-- 表 order 订单结构
CREATE TABLE IF NOT EXISTS `t_order` (
  `id` varchar(128) NOT NULL, -- 订单ID
  `name` varchar(128), -- 订单名称 其他业务熟悉忽略
  `message_id` varchar(128) NOT NULL, -- 消息唯一ID
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- 表 broker_message_log 消息记录结构
CREATE TABLE IF NOT EXISTS `broker_message_log` (
  `message_id` varchar(128) NOT NULL, -- 消息唯一ID
  `message` varchar(4000) DEFAULT NULL, -- 消息内容
  `try_count` int(4) DEFAULT ‘0‘, -- 重试次数
  `status` varchar(10) DEFAULT ‘‘, -- 消息投递状态  0 投递中 1 投递成功   2 投递失败
  `next_retry` timestamp NOT NULL DEFAULT ‘0000-00-00 00:00:00‘,  -- 下一次重试时间 或 超时时间
  `create_time` timestamp NOT NULL DEFAULT ‘0000-00-00 00:00:00‘, -- 创建时间
  `update_time` timestamp NOT NULL DEFAULT ‘0000-00-00 00:00:00‘, -- 更新时间
  PRIMARY KEY (`message_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

整合SpringBoot实现生产端代码如下：

修改 pom.xml配置

xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    >4.0.0>
 
    >com.bfxy>
    >rabbitmq-springboot-producer>
    >0.0.1-SNAPSHOT>
    >jar>
 
    >rabbitmq-springboot-producer>
    >rabbitmq-springboot-producer>
 
    >
        >org.springframework.boot>
        >spring-boot-starter-parent>
        >2.0.2.RELEASE>
        /> 
    >
 
    >
        >UTF-8>
        >UTF-8>
        >1.8>
    >
 
    >
        >
            >org.springframework.boot>
            >spring-boot-starter-web>
        > 
 
        >
            >org.springframework.boot>
            >spring-boot-starter-test>
            >test>
        >
 
        >
            >org.springframework.boot>
            >spring-boot-starter-amqp>
        >        
 
         
        >
          >org.mybatis.spring.boot>

上一篇：希尔排序

下一篇：C++——指针（一）

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：SpringBoot+RabbitMQ实现消息可靠性投递
文章链接：http://soscw.com/index.php/essay/56568.html

亲，登录后才可以留言！

SpringBoot+RabbitMQ实现消息可靠性投递

数据库库表结构：订单表和消息记录表

整合SpringBoot实现生产端代码如下：

评论

热门文章

推荐文章

最新文章

置顶文章