修改BUG

performance-web/src/main/java/com/clx/performance/config/RabbitBeanConfig.java

 package com.clx.performance.config;
 
 import com.clx.performance.constant.RabbitKeyConstants;
-import org.springframework.amqp.core.Binding;
-import org.springframework.amqp.core.BindingBuilder;
-import org.springframework.amqp.core.DirectExchange;
-import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.*;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -93,32 +91,32 @@ public class RabbitBeanConfig {
 
 
     /**
-     * 货单挂单队列
-     * @return
-     */
-    @Bean
-    public Queue orderGoodsOnQueue() {
-        Map<String, Object> params = new HashMap<>(6);
-        params.put("x-dead-letter-exchange", RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE);
-        params.put("x-dead-letter-routing-key", RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY);
-        return new Queue(RabbitKeyConstants.ORDER_GOODS_ON_QUEUE, true, false, false, params);
-    }
-
-    /**
-     * 货单挂单中交换机
-     **/
-    @Bean
-    public DirectExchange orderGoodsOnExchange() {
-        return new DirectExchange(RabbitKeyConstants.ORDER_GOODS_ON_EXCHANGE);
-    }
-
-    /**
-     * 货单挂单中绑定
-     */
-    @Bean
-    public Binding orderGoodsOnExchangeBind() {
-        return BindingBuilder.bind(orderGoodsOnQueue()).to(orderGoodsOnExchange()).with(RabbitKeyConstants.ORDER_GOODS_ON_ROUTE_KEY);
-    }
+//     * 货单挂单队列
+//     * @return
+//     */
+//    @Bean
+//    public Queue orderGoodsOnQueue() {
+//        Map<String, Object> params = new HashMap<>(6);
+//        params.put("x-dead-letter-exchange", RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE);
+//        params.put("x-dead-letter-routing-key", RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY);
+//        return new Queue(RabbitKeyConstants.ORDER_GOODS_ON_QUEUE, true, false, false, params);
+//    }
+//
+//    /**
+//     * 货单挂单中交换机
+//     **/
+//    @Bean
+//    public DirectExchange orderGoodsOnExchange() {
+//        return new DirectExchange(RabbitKeyConstants.ORDER_GOODS_ON_EXCHANGE);
+//    }
+//
+//    /**
+//     * 货单挂单中绑定
+//     */
+//    @Bean
+//    public Binding orderGoodsOnExchangeBind() {
+//        return BindingBuilder.bind(orderGoodsOnQueue()).to(orderGoodsOnExchange()).with(RabbitKeyConstants.ORDER_GOODS_ON_ROUTE_KEY);
+//    }
 
     /**
      * 死信队列：死信队列处理延迟消息货单挂单
@@ -133,19 +131,26 @@ public class RabbitBeanConfig {
      * 货单挂单中交换机：死信队列处理延迟消息
      **/
     @Bean
-    public DirectExchange orderGoodsOnDeadExchange() {
-        return new DirectExchange(RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE);
+    public CustomExchange orderGoodsOnDeadExchange() {
+        Map<String, Object> arguments = new HashMap<>();
+        //设置路由模式 direct模式
+        arguments.put("x-delayed-type", "direct");
+        return new CustomExchange(RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE,"x-delayed-message", true, false, arguments);
     }
 
     /**
      * 货单挂单中绑定:死信队列处理延迟消息
      */
+//    @Bean
+//    public Binding orderGoodsDeadExchangeBind() {
+//        return BindingBuilder.bind(orderGoodsOnDeadQueue()).to(orderGoodsOnDeadExchange()).with(RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY);
+//    }
+    //绑定交换机,队列和routingKey
     @Bean
-    public Binding orderGoodsDeadExchangeBind() {
-        return BindingBuilder.bind(orderGoodsOnDeadQueue()).to(orderGoodsOnDeadExchange()).with(RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY);
+    public Binding delayedQueueBindingDelayedExchange(@Qualifier("orderGoodsOnDeadQueue")Queue queue,@Qualifier("orderGoodsOnDeadExchange")CustomExchange customExchange) {
+        return BindingBuilder.bind(queue).to(customExchange).with(RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY).noargs();
     }
 
-
     /**
      * 订单取消队列
      * @return

performance-web/src/main/java/com/clx/performance/strategy/impl/OneGoodsOrderStrategy.java

@@ -216,7 +216,7 @@ public class OneGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
 
                 message.getMessageProperties().setExpiration(String.valueOf(epochMilli));
                 rabbitTemplate.send(
-                        RabbitKeyConstants.ORDER_GOODS_ON_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_ROUTE_KEY, message
+                        RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY, message
                 );
             }
         }

performance-web/src/main/java/com/clx/performance/strategy/impl/ThreeGoodsOrderStrategy.java

@@ -231,7 +231,7 @@ public class ThreeGoodsOrderStrategy extends GoodsOrderStrategy implements Initi
 
                 message.getMessageProperties().setExpiration(String.valueOf(epochMilli));
                 rabbitTemplate.send(
-                        RabbitKeyConstants.ORDER_GOODS_ON_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_ROUTE_KEY, message
+                        RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY, message
                 );
             }
         }

performance-web/src/main/java/com/clx/performance/strategy/impl/TwoGoodsOrderStrategy.java

@@ -249,7 +249,7 @@ public class TwoGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
 
                 message.getMessageProperties().setExpiration(String.valueOf(epochMilli));
                 rabbitTemplate.send(
-                        RabbitKeyConstants.ORDER_GOODS_ON_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_ROUTE_KEY, message
+                        RabbitKeyConstants.ORDER_GOODS_ON_DEAD_EXCHANGE, RabbitKeyConstants.ORDER_GOODS_ON_DEAD_ROUTE_KEY, message
                 );
             }
         }