From 5a6f892ce6cb0201ab819a4df2644d71a3b7a77d Mon Sep 17 00:00:00 2001
From: ZhiShuo_Lou <13209945+zhishuo-lou@user.noreply.gitee.com>
Date: Tue, 5 Dec 2023 10:02:54 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8A=A5=E8=AD=A6=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../base/server/consumer/RabbitConsumer.java  | 70 +++++++++----------
 .../src/main/resources/bootstrap.yml          | 16 -----
 2 files changed, 35 insertions(+), 51 deletions(-)

diff --git a/car-business-server/src/main/java/com/god/base/server/consumer/RabbitConsumer.java b/car-business-server/src/main/java/com/god/base/server/consumer/RabbitConsumer.java
index a3097a4..3c916bc 100644
--- a/car-business-server/src/main/java/com/god/base/server/consumer/RabbitConsumer.java
+++ b/car-business-server/src/main/java/com/god/base/server/consumer/RabbitConsumer.java
@@ -1,35 +1,35 @@
-//package com.god.base.server.consumer;
-//
-//import lombok.extern.java.Log;
-//import lombok.extern.log4j.Log4j;
-//import lombok.extern.log4j.Log4j2;
-//import org.springframework.amqp.rabbit.annotation.Queue;
-//import org.springframework.amqp.rabbit.annotation.RabbitListener;
-//import org.springframework.amqp.rabbit.annotation.RabbitListeners;
-//import org.springframework.stereotype.Component;
-//
-//import javax.annotation.Resource;
-//
-///**
-// * Description:
-// *
-// * @Author: sun-cool-boy
-// * @Date: 2023/11/29
-// * @info:
-// */
-//@Component
-//@Log4j2
-//public class RabbitConsumer {
-//
-//    @RabbitListener(queuesToDeclare = {@Queue("OUT_FENCE")})
-//    public void one(String msg){
-//        log.info("监听到消息：{} , 队列名：{}",msg,"OUT_FENCE");
-//        System.out.println(msg);
-//    }
-//
-//    @RabbitListener(queuesToDeclare = {@Queue("IN_FENCE")})
-//    public void two(String msg){
-//        log.info("监听到消息：{} , 队列名：{}",msg,"IN_FENCE");
-//        System.out.println(msg);
-//    }
-//}
+package com.god.base.server.consumer;
+
+import lombok.extern.java.Log;
+import lombok.extern.log4j.Log4j;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.annotation.RabbitListeners;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * Description:
+ *
+ * @Author: sun-cool-boy
+ * @Date: 2023/11/29
+ * @info:
+ */
+@Component
+@Log4j2
+public class RabbitConsumer {
+
+    @RabbitListener(queuesToDeclare = {@Queue("OUT_FENCE")})
+    public void one(String msg){
+        log.info("监听到消息：{} , 队列名：{},车辆已经驶入围栏内~~~~~~",msg,"OUT_FENCE");
+        System.out.println(msg);
+    }
+
+    @RabbitListener(queuesToDeclare = {@Queue("IN_FENCE")})
+    public void two(String msg){
+        log.info("监听到消息：{} , 队列名：{},车辆已经驶出围栏外~~~~~~",msg,"IN_FENCE");
+        System.out.println(msg);
+    }
+}
diff --git a/car-business-server/src/main/resources/bootstrap.yml b/car-business-server/src/main/resources/bootstrap.yml
index 1da035f..071c4e9 100644
--- a/car-business-server/src/main/resources/bootstrap.yml
+++ b/car-business-server/src/main/resources/bootstrap.yml
@@ -22,22 +22,6 @@ spring:
         # 共享配置
         shared-configs:
           - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
-  rabbitmq:
-    port: 5672
-    host: 10.100.1.5
-    username: guest
-    password: guest
-    #这个配置是保证提供者确保消息推送到交换机中，不管成不成功，都会回调
-    publisher-confirm-type: correlated
-    #保证交换机能把消息推送到队列中
-    publisher-returns: true
-    virtual-host: /
-    #这个配置是保证消费者会消费消息，手动确认
-    listener:
-      simple:
-        acknowledge-mode: manual
-    template:
-      mandatory: true
 logging:
   level:
     com.god.system.mapper: DEBUG