From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 09 六月 2025 11:54:00 +0800
Subject: [PATCH] 6.9新增登录失败冻结逻辑

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java |   84 +++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 82 insertions(+), 2 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java
index af96b92..e512def 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java
@@ -9,7 +9,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
-@Configuration
+//@Configuration
 public class RabbitmqConfig {
 
 
@@ -33,6 +33,24 @@
     public static final String ACID_ROUTING_KEY="huacheng.acid.key";
     public static final String ACID_EXCHANGE="huacheng.acid.exchange";
 
+    public static final String ACID_DANGER_QUEUE = "huacheng.acid.danger.queue";
+    public static final String ACID_DANGER_ROUTING_KEY = "huacheng.acid.danger.key";
+    public static final String ACID_DANGER_EXCHANGE = "huacheng.acid.danger.exchange";
+
+    public static final String ACID_DIRECT_QUEUE = "huacheng.acid.direct.queue";
+    public static final String ACID_DIRECT_ROUTING_KEY = "huacheng.acid.direct.key";
+    public static final String ACID_DIRECT_EXCHANGE = "huacheng.acid.direct.exchange";
+
+    public static final String ACID_MESSAGE_QUEUE="huacheng.acid.message.queue";
+    public static final String ACID_MESSAGE_ROUTING_KEY = "huacheng.acid.message.key";
+    public static final String ACID_MESSAGE_EXCHANGE = "huacheng.acid.message.exchange";
+
+    /**
+     * 服务商城订单
+     */
+    public static final String SHOP_ORDER_QUEUE="huacheng.shop.order.queue";
+    public static final String SHOP_ORDER_ROUTING_KEY = "huacheng.shop.order.key";
+    public static final String SHOP_ORDER_EXCHANGE = "huacheng.shop.order.exchange";
 
     @Bean
     public Queue preOrderQueue(){
@@ -82,7 +100,53 @@
 
     @Bean
     public Binding acidBinding(){
-        return BindingBuilder.bind(raffleQueue()).to(raffleExchange()).with(ACID_ROUTING_KEY).noargs();
+        return BindingBuilder.bind(acidQueue()).to(acidExchange()).with(ACID_ROUTING_KEY).noargs();
+    }
+
+    @Bean
+    public Queue acidDangerQueue(){
+        return new Queue(ACID_DANGER_QUEUE,true,false,false,null);
+    }
+
+    @Bean
+    public Exchange acidDangerExchange(){
+        Map<String, Object> arguments = new HashMap<>();
+        arguments.put("x-delayed-type", ExchangeTypes.DIRECT);
+        return new CustomExchange(ACID_DANGER_EXCHANGE,"x-delayed-message",true,false,arguments);
+    }
+
+    @Bean
+    public Binding acidDangerBinding(){
+        return BindingBuilder.bind(acidDangerQueue()).to(acidDangerExchange()).with(ACID_DANGER_ROUTING_KEY).noargs();
+    }
+
+    @Bean
+    public Queue acidDirectQueue(){
+        return new Queue(ACID_DIRECT_QUEUE,true,false,false,null);
+    }
+
+    @Bean
+    public Exchange acidDirectExchange(){
+        return new DirectExchange(ACID_DIRECT_EXCHANGE,true,false);
+    }
+
+    @Bean
+    public Binding acidDirectBinding(){
+        return BindingBuilder.bind(acidDirectQueue()).to(acidDirectExchange()).with(ACID_DIRECT_ROUTING_KEY).noargs();
+    }
+    @Bean
+    public Queue acidMessageQueue(){
+        return new Queue(ACID_MESSAGE_QUEUE,true,false,false,null);
+    }
+
+    @Bean
+    public Exchange acidMessageExchange(){
+        return new DirectExchange(ACID_MESSAGE_EXCHANGE,true,false);
+    }
+
+    @Bean
+    public Binding acidMessageBinding(){
+        return BindingBuilder.bind(acidMessageQueue()).to(acidMessageExchange()).with(ACID_MESSAGE_ROUTING_KEY).noargs();
     }
 
     @Bean
@@ -179,5 +243,21 @@
     }
 
 
+    @Bean
+    public Queue shopOrderQueue(){
+        return new Queue(SHOP_ORDER_QUEUE,true,false,false,null);
+    }
+
+    @Bean
+    public Exchange shopOrderExchange(){
+        Map<String, Object> arguments = new HashMap<>();
+        arguments.put("x-delayed-type", ExchangeTypes.DIRECT);
+        return new CustomExchange(SHOP_ORDER_EXCHANGE,"x-delayed-message",true,false,arguments);
+    }
+
+    @Bean
+    public Binding shopOrderBinding(){
+        return BindingBuilder.bind(shopOrderQueue()).to(shopOrderExchange()).with(SHOP_ORDER_ROUTING_KEY).noargs();
+    }
 }
 

--
Gitblit v1.7.1