From ad2e60b54a018d94392a0e2d14f370268f75a64d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=B5=B7=E8=A8=80?= <2439534736@qq.com>
Date: Thu, 6 Nov 2025 18:09:43 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4rocketmq=E9=9B=86=E6=88=90?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       |  7 ----
 .../controller/business/UserController.java   |  7 ----
 .../xf/basedemo/mq/RocketMqMsgConsumer.java   | 25 ------------
 .../xf/basedemo/mq/RocketMqMsgProducer.java   | 39 -------------------
 .../cn/xf/basedemo/service/UserService.java   |  1 -
 .../service/impl/UserServiceImpl.java         |  9 -----
 6 files changed, 88 deletions(-)
 delete mode 100644 src/main/java/cn/xf/basedemo/mq/RocketMqMsgConsumer.java
 delete mode 100644 src/main/java/cn/xf/basedemo/mq/RocketMqMsgProducer.java

diff --git a/pom.xml b/pom.xml
index 87e1f48..4a86b2e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,6 @@
         <spring-cloud.version>2023.0.1</spring-cloud.version>
         <elasticsearch.version>8.16.0</elasticsearch.version>
         <sverlet.version>4.0.1</sverlet.version>
-        <rocketmq.version>2.3.4</rocketmq.version>
     </properties>
     <dependencies>
         <dependency>
@@ -129,12 +128,6 @@
             <artifactId>elasticsearch-java</artifactId>
             <version>${elasticsearch.version}</version>
         </dependency>
-        <!-- rocketMQ 消息队列 -->
-        <dependency>
-            <groupId>org.apache.rocketmq</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
-            <version>${rocketmq.version}</version>
-        </dependency>
     </dependencies>
 
     <build>
diff --git a/src/main/java/cn/xf/basedemo/controller/business/UserController.java b/src/main/java/cn/xf/basedemo/controller/business/UserController.java
index 22598ad..2af5a09 100644
--- a/src/main/java/cn/xf/basedemo/controller/business/UserController.java
+++ b/src/main/java/cn/xf/basedemo/controller/business/UserController.java
@@ -51,11 +51,4 @@ public class UserController {
         return userService.getEsId(userId);
     }
 
-
-    //发送队列消息
-    @Operation(summary = "发送队列消息", description = "发送队列消息")
-    @GetMapping("/sendMsg")
-    public RetObj sendMsg(String msg) {
-        return userService.sendMQMsg(msg);
-    }
 }
diff --git a/src/main/java/cn/xf/basedemo/mq/RocketMqMsgConsumer.java b/src/main/java/cn/xf/basedemo/mq/RocketMqMsgConsumer.java
deleted file mode 100644
index b0f816a..0000000
--- a/src/main/java/cn/xf/basedemo/mq/RocketMqMsgConsumer.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package cn.xf.basedemo.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;
-
-/**
- * RocketMqMsgComsumer
- *
- * @author 海言
- * @date 2025/10/13
- * @time 14:37
- * @Description
- */
-@Slf4j
-@Component
-@RocketMQMessageListener(topic = "user-topic",consumerGroup = "consumer-group")
-public class RocketMqMsgConsumer implements RocketMQListener<String> {
-    @Override
-    public void onMessage(String s) {
-        log.info("接收到消息---------：{}",s);
-    }
-}
diff --git a/src/main/java/cn/xf/basedemo/mq/RocketMqMsgProducer.java b/src/main/java/cn/xf/basedemo/mq/RocketMqMsgProducer.java
deleted file mode 100644
index 71bdc46..0000000
--- a/src/main/java/cn/xf/basedemo/mq/RocketMqMsgProducer.java
+++ /dev/null
@@ -1,39 +0,0 @@
-package cn.xf.basedemo.mq;
-
-import jakarta.annotation.Resource;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.stereotype.Service;
-
-/**
- * RocketMqMsgProducer
- *
- * @author 海言
- * @date 2025/10/13
- * @time 14:34
- * @Description
- */
-@Slf4j
-@Service
-public class RocketMqMsgProducer {
-
-    @Resource
-    private RocketMQTemplate rocketMQTemplate;
-
-    //发送普通消息
-    public void sendMsg(String topic, String msg) {
-        rocketMQTemplate.convertAndSend(topic, msg);
-        log.info("发送普通消息：{}", msg);
-    }
-
-    //发送带标签的消息
-    public void sendMsg(String topic, String tag, String msg) {
-        rocketMQTemplate.convertAndSend(topic + ":" + tag, msg);
-    }
-
-    //发送延迟消息
-    public void sendDelayMsg(String topic, String msg, int delayLevel) {
-        rocketMQTemplate.syncSendDelayTimeMills(topic, msg, delayLevel);
-    }
-
-}
\ No newline at end of file
diff --git a/src/main/java/cn/xf/basedemo/service/UserService.java b/src/main/java/cn/xf/basedemo/service/UserService.java
index bf66f8f..4348ed0 100644
--- a/src/main/java/cn/xf/basedemo/service/UserService.java
+++ b/src/main/java/cn/xf/basedemo/service/UserService.java
@@ -18,5 +18,4 @@ public interface UserService {
 
     RetObj getEsId(Long userId);
 
-    RetObj sendMQMsg(String msg);
 }
diff --git a/src/main/java/cn/xf/basedemo/service/impl/UserServiceImpl.java b/src/main/java/cn/xf/basedemo/service/impl/UserServiceImpl.java
index 5191de7..3bd98c7 100644
--- a/src/main/java/cn/xf/basedemo/service/impl/UserServiceImpl.java
+++ b/src/main/java/cn/xf/basedemo/service/impl/UserServiceImpl.java
@@ -52,9 +52,6 @@ public class UserServiceImpl implements UserService {
     @Autowired
     private RedisTemplate redisTemplate;
 
-    @Resource
-    private RocketMqMsgProducer rocketMqMsgProducer;
-
     @Override
     public RetObj login(LoginInfoRes res) {
 
@@ -122,10 +119,4 @@ public class UserServiceImpl implements UserService {
         }
         return RetObj.error("es中不存在该用户");
     }
-
-    @Override
-    public RetObj sendMQMsg(String msg) {
-        rocketMqMsgProducer.sendMsg("user-topic", msg);
-        return RetObj.success();
-    }
 }