数据重复推送

src/main/java/com/ydtech/config/RabbitMQConfig.java

@@ -52,6 +52,17 @@ public class RabbitMQConfig {
     }
 
 
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    DirectExchange exchangeFail() {
+        return new DirectExchange(RabbitMqEnum.ORDER_EXCHANGE_FAIL.getCode(),true,false);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    DirectExchange exchangeSign() {
+        return new DirectExchange(RabbitMqEnum.ORDER_EXCHANGE_SIGN.getCode(),true,false);
+    }
 
     @Bean
     Binding binding(Queue queue, DirectExchange exchange) {
@@ -60,12 +71,12 @@ public class RabbitMQConfig {
 
 
     @Bean
-    Binding bindingFail(Queue queueFail, DirectExchange exchange) {
-        return BindingBuilder.bind(queueFail).to(exchange).with(RabbitMqEnum.ORDER_ROUTINGKEY_FAIL.getCode());
+    Binding bindingFail(Queue queueFail, DirectExchange exchangeFail) {
+        return BindingBuilder.bind(queueFail).to(exchangeFail).with(RabbitMqEnum.ORDER_ROUTINGKEY_FAIL.getCode());
     }
     @Bean
-    Binding bindingSign(Queue queueSign, DirectExchange exchange) {
-        return BindingBuilder.bind(queueSign).to(exchange).with(RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode());
+    Binding bindingSign(Queue queueSign, DirectExchange exchangeSign) {
+        return BindingBuilder.bind(queueSign).to(exchangeSign).with(RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode());
     }
     /**
      *  @version

src/main/java/com/ydtech/constants/RabbitMqEnum.java

@@ -15,12 +15,16 @@ public enum RabbitMqEnum {
 
     ORDER_QUEUE_FAIL("order_push_fail_queue", "消息失败队列"),
 
+    ORDER_EXCHANGE_FAIL("order_push_fail_exchange", "失败交换机"),
+
     ORDER_ROUTINGKEY_FAIL("order_push_fail_routingKey", "消息失败关键字"),
 
-    ORDER_QUEUE_SIGN("order_push_sign_queue", "承包订单队列"),
+    ORDER_QUEUE_SIGN("order_push_sign_queue", "承保订单队列"),
+
+    ORDER_EXCHANGE_SIGN("order_push_fail_exchange", "承保交换机"),
 
 
-    ORDER_ROUTINGKEY_SIGN("order_push_sign_routingKey", "承包订单关键字");
+    ORDER_ROUTINGKEY_SIGN("order_push_sign_routingKey", "承保订单关键字");
 
     private final String code;
     private final String desc;

src/main/java/com/ydtech/modules/order/service/impl/InsOrderPushMsgServiceImpl.java

@@ -122,7 +122,7 @@ public class InsOrderPushMsgServiceImpl extends ServiceImpl<InsOrderPushMsgMappe
                 try{
                     //更新狀態
                     //insOrderPushMsgService.save(insOrderPushMsg);
-                    this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode(), message_cj);
+                    this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE_FAIL.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_FAIL.getCode(), message_cj);
                     Thread.sleep(1500);
                 }catch(Exception e){
                     e.getStackTrace();
@@ -155,7 +155,7 @@ public class InsOrderPushMsgServiceImpl extends ServiceImpl<InsOrderPushMsgMappe
             try{
                 //更新狀態
                 insOrderPushMsgService.save(insOrderPushMsg);
-                this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode(), message_cj);
+                this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE_FAIL.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode(), message_cj);
 
             }catch(Exception e){
                 e.getStackTrace();