移除rocketmq集成功能

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>

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);
-    }
 }

src/main/java/cn/xf/basedemo/mq/RocketMqMsgConsumer.java

@@ -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);
-    }
-}

src/main/java/cn/xf/basedemo/mq/RocketMqMsgProducer.java

@@ -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);
-    }
-
-}

src/main/java/cn/xf/basedemo/service/UserService.java

@@ -18,5 +18,4 @@ public interface UserService {
 
     RetObj getEsId(Long userId);
 
-    RetObj sendMQMsg(String msg);
 }

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();
-    }
 }