SpringBoot RabbitMQ 延时队列取消订单【SpringBoot系列14】

缺乏、安全感 2023-10-08 20:41 18阅读 0赞

> SpringCloud 大型系列课程正在制作中，欢迎大家关注与提意见。  
> 程序员每天的CV 与 板砖，也要知其所以然，本系列课程可以帮助初学者学习 SpringBooot 项目开发 与 SpringCloud 微服务系列项目开发

##### 1 项目准备 #####

[SpringBoot 雪花算法生成商品订单号【SpringBoot系列13】本文章 基于这个项目来开发][SpringBoot _SpringBoot_13_]

**本文章是系列文章 ，每节文章都有对应的代码，每节的源码都是在上一节的基础上配置而来，对应的视频讲解课程正在火速录制中。**

订单系统，用户下单，即要保存即时性，也要保证流畅性，同时还要防止超卖，本文章是基于 RabbitMQ 消息队列 + Redis 实现的下单，当然后续还会的秒杀系统设计 以及后续的微服务以及熔断控制等等

如下图所示是本项目实现的一个下单流程的主要过程：

![在这里插入图片描述][8b083e88d88446b1b6479b54e2f736c3.png]

本文章实现的是 当用户下单成功后10分钟内没有支付时，使用 RabbitMQ 延时消息队列取消订单，并恢复商品的库存。

##### 1 RabbitMQ 延时插件的加载 #####

[插件地址][Link 1]：

https://www.rabbitmq.com/community-plugins.html

![在这里插入图片描述][6e565b7f79cb45b49fb1c01ce0678ecd.png]  
下载对应的版本到电脑本地，打开终端 将下载的压缩包 移动到plugins目录下

docker cp /Users/androidlongs/Downloads/rabbitmq_delayed_message_exchange-3.9.0.ez  rabbitmq:/plugins

然后进入容器，我这里使用容器名字 也可以用容器id进入

docker exec -it rabbitmq /bin/bash

移动到plugins目录下

cd plugins

查看是否上传成功

也可以使用

rabbitmq-plugins list

然后启用延时插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

##### 2 SpringBoot RabbitMQ 延时消息 #####

###### 2.1 创建消息队列 ######

import org.springframework.amqp.core.*;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.HashMap;
    import java.util.Map;
    
    /**
     * 插件配置类
     */
    @Configuration
    public class TestDelayedMessageConfig {
        
    
        public static final String DIRECT_QUEUE = "test.queue.direct";//队列
        public static final String DELAYED_EXCHANGE = "test.exchange.delayed";//延迟交换机
        public static final String ROUTING_KEY = "test.routingkey.bind";//绑定的routing-key
    
    
        /**
         * 定义队列
         **/
        @Bean
        public Queue directQueue(){
        
            return new Queue(DIRECT_QUEUE,true);
        }
    
        /**
         * 定义延迟交换机
         * args:根据该参数进行灵活路由，设置为“direct”，意味着该插件具有与直连交换机具有相同的路由行为
         * 交换机类型为 x-delayed-message
         **/
        @Bean
        public CustomExchange delayedExchange(){
        
            Map<String, Object> args = new HashMap<String, Object>();
            args.put("x-delayed-type", "direct");
            return new CustomExchange(DELAYED_EXCHANGE, "x-delayed-message", true, false, args);
        }
    
    
        /**
         * 队列和延迟交换机绑定
         **/
        @Bean
        public Binding orderBinding() {
        
            return BindingBuilder.bind(directQueue()).to(delayedExchange()).with(ROUTING_KEY).noargs();
        }
    
    }

CustomExchange 是自定义交换机，一般是配合插件来使用的。

###### 2.2 创建延时消息 生产者 ######

import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    @Service
    @Slf4j
    public class TestDelayedMQSender {
        
        
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        public void testSsend(String msg, Integer delayTime) {
        
            log.info("测试发送延时消息 {} : {}", delayTime, msg);
            //将消息携带路由键值
            rabbitTemplate.convertAndSend(
                    TestDelayedMessageConfig.DELAYED_EXCHANGE,//交换机名称
                    TestDelayedMessageConfig.ROUTING_KEY,//路由 key 
                    msg,
                    message -> {
        
                        //设置延时的时间  单位毫秒
                        message.getMessageProperties().setDelay(delayTime);
                        return message;
                    });
        }
    
    }

###### 2.3 创建延时消息 消费者 ######

import lombok.extern.log4j.Log4j;
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    @Log4j
    @RabbitListener(queues = TestDelayedMessageConfig.DIRECT_QUEUE)//监听队列名称
    public class TestDelayedMQReciever {
        
    
    
        @RabbitHandler
        public void process(String message){
        
            log.info("DelayedMQReciever接收到的消息是："+ message);
        }
    }

###### 2.4 测试 ######

@Api(tags = "订单测试模块")
    @RestController()
    @RequestMapping("/test/orders")
    @Slf4j
    public class OrderTestController {
        
    
        @Autowired
        TestDelayedMQSender delayedMQSender;
    
        @GetMapping("/send/delay")
        public R createPreOrder(@RequestParam(required = false,defaultValue = "10000")  Integer delayTime) {
        
            delayedMQSender.testSsend("测试延时消息了",delayTime);
            return R.ok();
        }
    
    }

##### 3 延时取消订单 #####

实现思路是用户下单，创建订单成功后，发一个带有订单信息的延时消息，然后当到达指定时间后，判断一下订单是否未支付。

如果已支付 就不做任何处理，如果未支付，就取消订单，取消订单后

*  更新redis 缓存
 *  更新 ES 订单信息
 *  发送取消订单的通知
 *  恢复商品库存
 *  …

项目源码在这里 ：[https://gitee.com/android.long/spring-boot-study/tree/master/biglead-api-11-snow\_flake][https_gitee.com_android.long_spring-boot-study_tree_master_biglead-api-11-snow_flake]  
有兴趣可以关注一下公众号：biglead

--------------------

1.  [ 创建SpringBoot基础项目][_SpringBoot]
2.  [SpringBoot项目集成mybatis][SpringBoot_mybatis]
3.  [SpringBoot 集成 Druid 数据源【SpringBoot系列3】][SpringBoot _ Druid _SpringBoot_3]
4.  [SpringBoot MyBatis 实现分页查询数据【SpringBoot系列4】][SpringBoot MyBatis _SpringBoot_4]
5.  [SpringBoot MyBatis-Plus 集成 【SpringBoot系列5】][SpringBoot MyBatis-Plus _ _SpringBoot_5]
6.  [SpringBoot mybatis-plus-generator 代码生成器 【SpringBoot系列6】][SpringBoot mybatis-plus-generator _ _SpringBoot_6]
7.  [SpringBoot MyBatis-Plus 分页查询 【SpringBoot系列7】][SpringBoot MyBatis-Plus _ _SpringBoot_7]
8.  [SpringBoot 集成Redis缓存 以及实现基本的数据缓存【SpringBoot系列8】][SpringBoot _Redis_ _SpringBoot_8]
9.  [SpringBoot 整合 Spring Security 实现安全认证【SpringBoot系列9】][SpringBoot _ Spring Security _SpringBoot_9]
10. [SpringBoot Security认证 Redis缓存用户信息【SpringBoot系列10】][SpringBoot Security_ Redis_SpringBoot_10]
11. [SpringBoot 整合 RabbitMQ 消息队列【SpringBoot系列11】][SpringBoot _ RabbitMQ _SpringBoot_11]
12. [SpringBoot 结合RabbitMQ与Redis实现商品的并发下单【SpringBoot系列12】][SpringBoot _RabbitMQ_Redis_SpringBoot_12]
13. [SpringBoot 雪花算法生成商品订单号【SpringBoot系列13】][SpringBoot _SpringBoot_13_]

[SpringBoot _SpringBoot_13_]: https://biglead.blog.csdn.net/article/details/129613629
[8b083e88d88446b1b6479b54e2f736c3.png]: https://img-blog.csdnimg.cn/8b083e88d88446b1b6479b54e2f736c3.png
[Link 1]: https://www.rabbitmq.com/community-plugins.html
[6e565b7f79cb45b49fb1c01ce0678ecd.png]: https://img-blog.csdnimg.cn/6e565b7f79cb45b49fb1c01ce0678ecd.png
[https_gitee.com_android.long_spring-boot-study_tree_master_biglead-api-11-snow_flake]: https://gitee.com/android.long/spring-boot-study/tree/master/biglead-api-07-security
[_SpringBoot]: https://biglead.blog.csdn.net/article/details/129510825
[SpringBoot_mybatis]: https://biglead.blog.csdn.net/article/details/129394530
[SpringBoot _ Druid _SpringBoot_3]: https://biglead.blog.csdn.net/article/details/129535296
[SpringBoot MyBatis _SpringBoot_4]: https://biglead.blog.csdn.net/article/details/129536510
[SpringBoot MyBatis-Plus _ _SpringBoot_5]: https://biglead.blog.csdn.net/article/details/129538116
[SpringBoot mybatis-plus-generator _ _SpringBoot_6]: https://biglead.blog.csdn.net/article/details/129538743
[SpringBoot MyBatis-Plus _ _SpringBoot_7]: https://biglead.blog.csdn.net/article/details/129541845
[SpringBoot _Redis_ _SpringBoot_8]: https://biglead.blog.csdn.net/article/details/129544029
[SpringBoot _ Spring Security _SpringBoot_9]: https://biglead.blog.csdn.net/article/details/129551021
[SpringBoot Security_ Redis_SpringBoot_10]: https://biglead.blog.csdn.net/article/details/129570925
[SpringBoot _ RabbitMQ _SpringBoot_11]: https://biglead.blog.csdn.net/article/details/129578909
[SpringBoot _RabbitMQ_Redis_SpringBoot_12]: https://biglead.blog.csdn.net/article/details/129601572