RabbitMQ实现订单30分钟超时自动关闭

秒速五厘米 2023-07-12 06:25 14阅读 0赞

demo地址:链接：https://pan.baidu.com/s/1kGaSCHlfhm6UvbPcRUYp4g   
提取码：11hs

订单30分钟未支付,系统自动超时关闭有哪些实现方案?  
    1.基于任务调度实现,效率是非常低,耗服务器性能  
    2.基于redis过期key实现.用户下单的时候,生成一个令牌(有效期)30分钟,存放到我们redis;  
        redis.set(orderToken ,orderID) 下单时候存放到redis,并存储id入库,30分钟过期,  
        redis客户端监听,过期获取到orderId,拿orderId去查订单,没有支付则,订单关闭,库存增加  
        缺点:非常冗余 ,会在表中存放一个冗余字段 [https://blog.csdn.net/zhangshengqiang168/article/details/104925649][https_blog.csdn.net_zhangshengqiang168_article_details_104925649]

3.基于redis延迟队列   [https://blog.csdn.net/zhangshengqiang168/article/details/100130523][https_blog.csdn.net_zhangshengqiang168_article_details_100130523]  
    4.基于MQ的延迟队列实现(最佳)    死信队列(延迟队列)  
        原理:当我们在下单的时候,往MQ投递一个消息设置有效期为30分钟,但该消息失效的时候(没有被消费的情况下),  
             执行我们客户端一个方法告诉我们该消息已经失效,这时候查询这笔订单是否有支付.

# 实现原理(消息过期投递到死信队列) #

原理:下单投放消息到A交换机(过期时间30分钟),消息到aa队列(绑定死信交换机),不设置aa队列的消费者(故此消息一直未消费).  
30分钟后,过期消息投递到死信交换机,死信队列,由死信消费者消费,判断订单id是否支付,执行业务逻辑,支付->return   
未支付->关闭订单,返还库存

### demo演示: ###

1.声明订单和死信交换机、 订单和死信队列 、关键步骤订单队列绑定订单交换机和死信交换机 、死信队列绑定死信交换机

@Component
    public class DeadLetterMQConfig {
        /**
         * 订单交换机
         */
        @Value("${mayikt.order.exchange}")
        private String orderExchange;
        /**
         * 订单队列
         */
        @Value("${mayikt.order.queue}")
        private String orderQueue;
        /**
         * 订单路由key
         */
        @Value("${mayikt.order.routingKey}")
        private String orderRoutingKey;
        /**
         * 死信交换机
         */
        @Value("${mayikt.dlx.exchange}")
        private String dlxExchange;
        /**
         * 死信队列
         */
        @Value("${mayikt.dlx.queue}")
        private String dlxQueue;
        /**
         * 死信路由
         */
        @Value("${mayikt.dlx.routingKey}")
        private String dlxRoutingKey;
        /**
         * 声明死信交换机
         */
        @Bean
        public DirectExchange dlxExchange() {
            return new DirectExchange(dlxExchange);
        }
        /**
         * 声明死信队列
         */
        @Bean
        public Queue dlxQueue() {
            return new Queue(dlxQueue);
        }
        /**
         * 声明订单业务交换机
         */
        @Bean
        public DirectExchange orderExchange() {
            return new DirectExchange(orderExchange);
        }
        /**
         * 声明订单队列 核心操作一
         */
        @Bean
        public Queue orderQueue() {
            Map<String, Object> arguments = new HashMap<>(2);
            // 绑定我们的死信交换机
            arguments.put("x-dead-letter-exchange", dlxExchange);
            // 绑定我们的路由key
            arguments.put("x-dead-letter-routing-key", dlxRoutingKey);
            return new Queue(orderQueue, true, false, false, arguments);
        }
        /**
         * 绑定订单队列到订单交换机
         */
        @Bean
        public Binding orderBinding() {
            return BindingBuilder.bind(orderQueue()).to(orderExchange()).with(orderRoutingKey);
        }
        /**
         * 绑定死信队列到死信交换机
         */
        @Bean
        public Binding binding() {
            return BindingBuilder.bind(dlxQueue()).to(dlxExchange()).with(dlxRoutingKey);
        }
    }

2.application.properties文件配置 交换机队列相关名称和其他配置

server.port=8082
    spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8
    spring.datasource.username=root
    spring.datasource.password=root
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    
    #开启驼峰命名  譬如数据库create_time 自动映射pojo属性createTime
    mybatis.configuration.map-underscore-to-camel-case=true
    
    #配置virtual-host虚拟主机
    spring.rabbitmq.virtual-host=/zhang_rabbit
    #ip地址
    spring.rabbitmq.host=127.0.0.1
    #用户名  密码
    spring.rabbitmq.username=zhang
    spring.rabbitmq.password=zhang
    #连接端口号
    spring.rabbitmq.port=5672
    #spring.rabbitmq.publisher-confirm-type=
    
    #模拟演示死信队列
    mayikt.dlx.exchange=mayikt_order_dlx_exchange
    mayikt.dlx.queue=mayikt_order_dlx_queue
    mayikt.dlx.routingKey=dlx
    
    ##备胎交换机
    mayikt.order.exchange=mayikt_order_exchange
    mayikt.order.queue=mayikt_order_queue
    mayikt.order.routingKey=mayikt.order

3.创建producer生产者.暂时设置消息10秒过期,验证消息是否加入死信队列

@RestController
    public class OrderController {
    
        @Autowired
        private OrderMapper orderMapper;
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        @Value("${mayikt.order.exchange}")
        private String orderExchange; //订单交换机
    
        @Value("${mayikt.order.routingKey}")
        private String orderRoutingKey; //订单路由key
    
        @GetMapping("/addOrder")
        public String addOrder(){
            String orderId=System.currentTimeMillis()+"";
            OrderEntity orderEntity=new OrderEntity("订单30分钟过期",orderId,0);
            //订单入库
            int result= orderMapper.addOrder(orderEntity);
            if(result<=0){
                return "fail";
            }
            //rabbit投递消息
        rabbitTemplate.convertAndSend(orderExchange,orderRoutingKey,orderId,messagePostProcessor());
            return "success";
        }
    
        //处理待发送消息
        private MessagePostProcessor messagePostProcessor(){
            return  new MessagePostProcessor() {
                @Override
                public Message postProcessMessage(Message message) throws AmqpException {
                    //设置有效期30分钟
                    //message.getMessageProperties().setExpiration("1800000");
                    message.getMessageProperties().setExpiration("10000");
                    return message;
                }
            };
        }
    }

4.死信消费者消费过期消息

@Component //死信队列
    public class OrderDlxConsumer {
        
        @Autowired
        private OrderMapper orderMapper;
    
        /**
         * 监听我们的死信队列
         */
        @RabbitListener(queues = "mayikt_order_dlx_queue")
        public void orderConsumer(String orderId) {
            System.out.println("死信队列获取消息:" + orderId);
            if (StringUtils.isEmpty(orderId)) {
                return;
            }
            //根据id查询
            OrderEntity orderEntity = orderMapper.getOrder(orderId);
            if (null == orderEntity) {
                return;
            }
            //获取状态
            Integer orderStatus=orderEntity.getOrderStatus();
            //判断未支付 , 关闭订单
            if(0==orderStatus){
                orderMapper.updateStatus(orderId,2);
                //库存返还
            }
        }
    }

5.下单测试  [http://localhost:8082/addOrder][http_localhost_8082_addOrder].订单入库成功.状态0未支付

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70][]

10秒后,死信消费者处理 状态0未支付 变为2 已关闭

![2020030718141176.png][]

[https_blog.csdn.net_zhangshengqiang168_article_details_104925649]: https://blog.csdn.net/zhangshengqiang168/article/details/104925649
[https_blog.csdn.net_zhangshengqiang168_article_details_100130523]: https://blog.csdn.net/zhangshengqiang168/article/details/100130523
[http_localhost_8082_addOrder]: http://localhost:8082/addOrder
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200307181427266.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA==,size_16,color_FFFFFF,t_70
[2020030718141176.png]: https://img-blog.csdnimg.cn/2020030718141176.png