Springboot使用RabbitMQ实现关闭超时订单的一个简单示例

1.maven中引入rabbitmq的依赖：

1.         <dependency>
2.             <groupId>org.springframework.boot</groupId>
3.             <artifactId>spring-boot-starter-amqp</artifactId>
4.         </dependency>

复制代码

2.application.yml中进行rabbitmq相干设置：

1. # rabbitmq空一格写，内嵌在spring里边
2. rabbitmq:
3.     host: 192.168.56.10
4.     port: 5672
5.     virtual-host: /
6.     #发送端确认机制 correlated：发布消息成功到交换器后会触发回调方法
7.     publisher-confirm-type: correlated
8.     template:
9.     # 只要抵达队列，以异步发送优先回调以异步发送优先回调我们这个returnconfirm
10.       mandatory: true
11.     # 开启发送消息抵达队列的确认
12.     publisher-returns: true

复制代码

 在项目启动类中添加开启rabbitmq的注解@EnableRabbit
3.创建交换机，队列，并将队列绑定到指定交换机：

1. import com.atguigu.gulimall.order.entity.OrderEntity;
2. import com.rabbitmq.client.Channel;
3. import org.springframework.amqp.core.*;
4. import org.springframework.amqp.rabbit.annotation.RabbitListener;
5. import org.springframework.context.annotation.Bean;
6. import org.springframework.context.annotation.Configuration;
8. import java.io.IOException;
9. import java.util.HashMap;
10. import java.util.Map;
13. @Configuration
14. public class MyMQConfig {
17.     @Bean
18.     public Queue orderDelayQueue(){
19.         /* * 构造一个死信队列
20.          *  x-dead-letter-exchange: order-event-exchange
21.          *  x-dead-letter-routing-key: order.release.order
22.          *  x-message-ttl: 60000
23.          * @create 2025/1/1
24.          **/
25.         Map<String,Object>arguments=new HashMap<>();
26.         arguments.put("x-dead-letter-exchange","order-event-exchange");
27.         arguments.put("x-dead-letter-routing-key","order.release.order");
28.         arguments.put("x-message-ttl",60000);
29.         Queue queue = new Queue("order.delay.queue", true, false, false,arguments);
30.         return queue;
31.     }
33.     @Bean
34.     public Queue orderReleaseOrderQueue(){
35.         Queue queue = new Queue("order.release.order.queue", true, false, false);
36.         return queue;
37.     }
39.     @Bean
40.     public Exchange orderEventExchange(){
41.        return new TopicExchange("order-event-exchange",true,false);
42.     }
44.     @Bean
45.     public Binding orderCreateOrderBinding(){
46.        return new Binding("order.delay.queue", Binding.DestinationType.QUEUE,"order-event-exchange","order.create.order",null);
47.     }
49.     @Bean
50.     public Binding orderReleaseOrderBinding(){
51.         return new Binding("order.release.order.queue", Binding.DestinationType.QUEUE,"order-event-exchange","order.release.order",null);
53.     }
54. }

复制代码

 在上面的代码中，创建了2个队列：order.delay.queue和order.release.order.queue，此中order.delay.queue是延时队列，为了方便演示，将延时时间设置为1分钟（60000ms）。order.release.order.queue是普通队列。创建了1个交换机：order-event-exchange。order.delay.queue队列通过路由键order.create.order绑定到order-event-exchange交换机，order.release.order.queue队列通过路由键order.release.order也绑定到order-event-exchange交换机。在交换机的选择上，思量到要绑定到不同的队列和路由键，支持模糊匹配，这里使用Topic交换机。
4.在MyMQConfig 创建一个方法监听队列：

1.     @RabbitListener(queues = "order.release.order.queue")
2.     public void listener(OrderEntity order, Channel channel, Message message) throws IOException {
3.         System.out.println("收到过期的订单信息，准备关闭订单"+order.getOrderSn());
4.         channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
5.     }

复制代码

 添加上面的方法后，当我们的服务连上rabbitmq，rabbitmq就会创建上面@Bean标注的交换机和队列了。
5.写一个创建订单的接口，简单模仿下这个过程：

1.     @Autowired
2.     private RabbitTemplate rabbitTemplate;
4.     @GetMapping("/test/createOrder")
5.     @ResponseBody
6.     public String creatOrder(){
7.         OrderEntity order=new OrderEntity();
8.         order.setOrderSn(UUID.randomUUID().toString());
9.         order.setCreateTime(new Date());
10.         rabbitTemplate.convertAndSend("order-event-exchange","order.create.order",order);
11.         return "ok";
12.     }

复制代码

使用rabbitTemplate将订单数据通过交换机order-event-exchange和路由键order.create.order将订单数据order发送给队列order.delay.queue。启动服务调用接口，来观察rabbitmq背景队列的变化：

可以看到 order.delay.queue队列中有1条消息等候消耗，由于rabbitmq背景每隔5秒刷新一次，过1分钟再去看，队列中已有消息了。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。