重庆哪家网站,沭阳三剑客做网站,电商平台开发流程,外贸做哪个网站平台一、本文抒写背景
前面我也在延迟队列篇章提到过死信队列#xff0c;也提到过一些应用场景#xff01;
今天呢#xff0c;这篇文章#xff0c;主要就是实战一个业务场景的小Demo流程#xff0c;哈哈#xff0c;那就是延迟关闭订单。
二、开始啦#xff01;letgo!
首…一、本文抒写背景
前面我也在延迟队列篇章提到过死信队列也提到过一些应用场景
今天呢这篇文章主要就是实战一个业务场景的小Demo流程哈哈那就是延迟关闭订单。
二、开始啦letgo!
首先我来讲解下这个场景非常常见尤其是和支付挂钩的业务必然会有类似的场景。
注
当然本文重要的是掌握延迟消息的用法而不是实现一个真实支付的场景因为实现真实支付的场景涉及
的知识太多啦考虑的情况太多了呜呜呜放过我吧
三、来吧Common On进入代码实现吧
本章代码实现的整体思路主要为以下
SpringBoot整合RabbitMQ利用死信队列实现延迟关闭订单的效果。
1. 死信队列原理
利用RabbitMQ的懒消费机制当消息超过TTL过期时间未被消费就会通过死信交换机放入死信
队列中再专门消费死信队列中的消息达到延迟处理的效果。
一张图看明白 别说啦前面本人已经提到过死信交换机啦这张图的思想跟死信交换机所画图思想有一定的挂钩哟有兴趣
可参考下本人死信交换机篇章
2. 实现案例
本文为了突出核心的逻辑案例就用伪代码来展示啦省略一些非必要的东西这样会显得更清晰直观。
创建订单消息对象
// OrderMessage.java
public class OrderMessage {private String orderId;// 省略getter和setter
}
创建订单服务类也就是执行关闭订单的一些业务逻辑比如调微信支付关闭订单操作或改本地业务状态等。
Service
public class OrderService {public void closeOrder(String orderId) {// 执行关单操作System.out.println(关闭订单 orderId);}
}
创建延迟队列配置类这里的核心就是利用了RabbitMQ的消息过期(ttl)特性以及定义死信交换机 -- 转发的
路由 -- 死信队列。
Configuration
public class DelayQueueConfig {// 定义延迟队列名称public static final String DELAY_QUEUE_NAME delay.queue;// 定义死信队列名称public static final String DEAD_LETTER_QUEUE_NAME dead.letter.queue;// 定义延迟时间单位毫秒public static final long DELAY_TIME 5000;Beanpublic Queue delayQueue() {MapString, Object args new HashMap();// x-dead-letter-exchange被设置为空字符串表示将死信消息发送到默认交换机。// 如果您想要将死信消息发送到特定的交换机可以将其设置为相应的交换机名称。args.put(x-dead-letter-exchange, );args.put(x-dead-letter-routing-key, DEAD_LETTER_QUEUE_NAME);args.put(x-message-ttl, DELAY_TIME);return new Queue(DELAY_QUEUE_NAME, true, false, false, args);}Beanpublic Queue deadLetterQueue() {return new Queue(DEAD_LETTER_QUEUE_NAME);}
}
创建消息发送者用于向延迟队列发送订单消息发送到指定的交换机和延迟队列。
Component
public class OrderMessageSender {Autowiredprivate RabbitTemplate rabbitTemplate;Value(DelayQueueConfig.DELAY_QUEUE_NAME)private String delayQueue;public void sendOrderMessage(OrderMessage orderMessage) {rabbitTemplate.convertAndSend(, delayQueue, orderMessage);}
}
创建消息接收者也就是监听前面定义的死信队列的消息消费消息并处理关单逻辑。
Component
public class OrderMessageReceiver {Autowiredprivate OrderService orderService;RabbitListener(queues DelayQueueConfig.DEAD_LETTER_QUEUE_NAME)public void processDeadLetterMessage(OrderMessage orderMessage) {// 处理关单逻辑orderService.closeOrder(orderMessage.getOrderId());}
}
四、本文总结
最后咱们再来回顾总结一下利用死信队列实现延迟关单的流程
1、订单消息通过OrderMessageSender发送到延迟队列。
2、延迟时间过后订单消息被投递到死信队列。
3、OrderMessageReceiver监听死信队列一旦有消息到达调用OrderService的closeOrder方法执行关单
操作。
这种延迟关单功能还可以用于定时任务、订单超时处理等场景。
