From a64b1f9533eb632d09762f7a32502a1e7f2b0f71 Mon Sep 17 00:00:00 2001
From: landaiqing <3517283258@qq.com>
Date: Tue, 25 Jun 2024 17:09:49 +0800
Subject: [PATCH] feat: add RocketMQ

---
 .../pom.xml                                   | 10 ++--
 .../auth/application/mq/TestConsumer.java     | 50 +++++++++----------
 .../pom.xml                                   | 10 ++--
 .../pom.xml                                   |  5 ++
 .../src/main/resources/application.yml        |  8 +--
 5 files changed, 44 insertions(+), 39 deletions(-)

diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/pom.xml b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/pom.xml
index b3b5321..993ce0c 100644
--- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/pom.xml
+++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/pom.xml
@@ -19,10 +19,10 @@
     </properties>
 
     <dependencies>
-<!--        <dependency>-->
-<!--            <groupId>com.schisandra</groupId>-->
-<!--            <artifactId>schisandra-cloud-storage-auth-domain</artifactId>-->
-<!--            <version>1.0-SNAPSHOT</version>-->
-<!--        </dependency>-->
+        <dependency>
+            <groupId>com.schisandra</groupId>
+            <artifactId>schisandra-cloud-storage-auth-domain</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
     </dependencies>
 </project>
diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/src/main/java/com/schisandra/auth/application/mq/TestConsumer.java b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/src/main/java/com/schisandra/auth/application/mq/TestConsumer.java
index d658018..8f26d0b 100644
--- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/src/main/java/com/schisandra/auth/application/mq/TestConsumer.java
+++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-application/schisandra-cloud-storage-auth-application-mq/src/main/java/com/schisandra/auth/application/mq/TestConsumer.java
@@ -1,25 +1,25 @@
-//package com.schisandra.auth.application.mq;
-//
-//import lombok.extern.slf4j.Slf4j;
-//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-//import org.apache.rocketmq.spring.core.RocketMQListener;
-//import org.springframework.stereotype.Component;
-//
-///**
-// * @Classname TestConsumer
-// * @BelongsProject: schisandra-cloud-storage
-// * @BelongsPackage: com.schisandra.auth.application.mq
-// * @Author: landaiqing
-// * @CreateTime: 2024-06-25  14:39
-// * @Description: TODO
-// * @Version: 1.0
-// */
-//@Component
-//@RocketMQMessageListener(topic = "first-topic", consumerGroup = "schisandra-cloud-storage-auth-producer")
-//@Slf4j
-//public class TestConsumer implements RocketMQListener<String> {
-//    @Override
-//    public void onMessage(String s) {
-//        log.info("接收到ma消息：{}", s);
-//    }
-//}
+package com.schisandra.auth.application.mq;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Classname TestConsumer
+ * @BelongsProject: schisandra-cloud-storage
+ * @BelongsPackage: com.schisandra.auth.application.mq
+ * @Author: landaiqing
+ * @CreateTime: 2024-06-25  14:39
+ * @Description: TODO
+ * @Version: 1.0
+ */
+@Component
+@RocketMQMessageListener(topic = "first-topic", consumerGroup = "schisandra-cloud-storage-auth-consumer-group")
+@Slf4j
+public class TestConsumer implements RocketMQListener<String> {
+    @Override
+    public void onMessage(String s) {
+        log.info("接收到ma消息：{}", s);
+    }
+}
diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/pom.xml b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/pom.xml
index 17b2917..2ef7753 100644
--- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/pom.xml
+++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/pom.xml
@@ -67,10 +67,10 @@
             <artifactId>schisandra-cloud-storage-auth-common</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
-<!--        <dependency>-->
-<!--            <groupId>org.apache.rocketmq</groupId>-->
-<!--            <artifactId>rocketmq-spring-boot-starter</artifactId>-->
-<!--            <version>2.1.1</version>-->
-<!--        </dependency>-->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.1.1</version>
+        </dependency>
     </dependencies>
 </project>
diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/pom.xml b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/pom.xml
index f44caec..0a4c224 100644
--- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/pom.xml
+++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/pom.xml
@@ -54,6 +54,11 @@
             <artifactId>schisandra-cloud-storage-auth-infra</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.schisandra</groupId>
+            <artifactId>schisandra-cloud-storage-auth-application-mq</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
 
     </dependencies>
 
diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/src/main/resources/application.yml b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/src/main/resources/application.yml
index fdbbc12..4d90593 100644
--- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/src/main/resources/application.yml
+++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-starter/src/main/resources/application.yml
@@ -103,7 +103,7 @@ web:
 cipher:
   salt: E2754BC007CA407190E85DFF6E566003
 
-#rocketmq:
-#  name-server: 1.95.0.111:9876
-#  producer:
-#    group: schisandra-cloud-storage-auth-producer
+rocketmq:
+  name-server: 1.95.0.111:9876
+  producer:
+    group: schisandra-cloud-storage-auth-group