rockerMQ实例功能

API文档.md

-# API 接口文档
+# API 接口文档
@@ -276,5 +276,4 @@ destination:/topic/test-topic
 | `/kafka/**` | 🔓 无需认证 |
 | `/kafka-test.html` | 🔓 无需认证 |
 | `/api/protected/**` | 🔒 需要JWT认证 |
-| 其他接口 | 🔒 需要JWT认证 |
-0
+| 其他接口 | 🔒 需要JWT认证 |
\ No newline at end of file
\ No newline at end of file

pom.xml

@@ -28,6 +28,10 @@
     </scm>
     <properties>
         <java.version>21</java.version>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <dubbo.version>3.2.0</dubbo.version>
+        <spring.version>5.3.21</spring.version>
     </properties>
 
 
@@ -181,6 +185,27 @@
             <artifactId>spring-kafka</artifactId>
         </dependency>
 
+
+        <!-- Dubbo核心依赖 -->
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo</artifactId>
+            <version>${dubbo.version}</version>
+        </dependency>
+
+        <!-- Zookeeper客户端依赖 -->
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-framework</artifactId>
+            <version>4.0.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-recipes</artifactId>
+            <version>4.0.1  </version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/example/demo/common/SecurityConfig.java

 package com.example.demo.common;
 
-
-//import com.example.security.JwtAuthenticationEntryPoint;
-//import com.example.security.JwtAuthenticationFilter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.security.authentication.AuthenticationManager;

src/main/java/com/example/demo/controller/kafkaController.java

 package com.example.demo.controller;
 
 import org.apache.kafka.clients.producer.*;
-        import org.apache.kafka.common.serialization.StringSerializer;
+import org.apache.kafka.common.serialization.StringSerializer;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;

常用命令.md

+mvn mybatis-generator:generate -e
+mvn mybatis-generator:generate -e
\ No newline at end of file