提交全部代码

ruoyi-modules-api/ruoyi-knowledge-api/pom.xml

@@ -21,6 +21,7 @@
 
     <dependencyManagement>
         <dependencies>
+
             <dependency>
                 <groupId>dev.langchain4j</groupId>
                 <artifactId>langchain4j-bom</artifactId>
@@ -38,7 +39,11 @@
             <artifactId>commons-io</artifactId>
             <version>2.17.0</version>
         </dependency>
-
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>4.9.4</version> <!-- 使用最新稳定版本 -->
+        </dependency>
         <dependency>
             <groupId>org.ruoyi</groupId>
             <artifactId>ruoyi-system-api</artifactId>

ruoyi-modules-api/ruoyi-knowledge-api/src/main/java/org/ruoyi/mapper/ThinkModelMapper.java

@@ -17,6 +17,7 @@ public interface ThinkModelMapper extends BaseMapperPlus<ThinkModel, ThinkModel>
     int deleteModelById(Integer id);
 
     int insertModel(Map<String, Object> map);
+
     int updateModelSort(@Param("id") Long id, @Param("sort") Long sort);
 
     int updateModel(Map<String, Object> map);

ruoyi-modules/ruoyi-chat/pom.xml

@@ -39,7 +39,11 @@
             <artifactId>json</artifactId>
             <version>${org-json.version}</version>
         </dependency>
-
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>4.9.4</version> <!-- 使用最新稳定版本 -->
+        </dependency>
         <dependency>
             <groupId>net.dv8tion</groupId>
             <artifactId>JDA</artifactId>

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/config/RocketMQConfig.java

@@ -0,0 +1,22 @@
+package org.ruoyi.chat.config;
+
+import org.apache.rocketmq.client.exception.MQClientException;
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RocketMQConfig {
+
+    // 从你的信息中提取的配置
+    private String nameServerAddr = "221.224.213.226:15208"; // 外网地址:端口
+    private String producerGroup = "device-tracking-producer-group"; // 生产者组名，可自定义
+
+    @Bean
+    public DefaultMQProducer mqProducer() throws MQClientException {
+        DefaultMQProducer producer = new DefaultMQProducer(producerGroup);
+        producer.setNamesrvAddr(nameServerAddr);
+        producer.start();
+        return producer;
+    }
+}

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/controller/chat/MessageController.java

@@ -0,0 +1,28 @@
+package org.ruoyi.chat.controller.chat;
+
+import org.apache.rocketmq.client.producer.SendResult;
+import org.ruoyi.chat.service.RocketMQService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/RocketMQ")
+public class MessageController {
+
+    @Autowired
+    private RocketMQService rocketMQService;
+
+    @PostMapping("/send")
+
+    public String sendMessageToRocketMQ(@RequestBody String message) {
+        try {
+            SendResult result = rocketMQService.sendMessage(message);
+            return "消息发送成功: " + result;
+        } catch (Exception e) {
+            return "消息发送失败: " + e.getMessage();
+        }
+    }
+}

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/RocketMQService.java

@@ -0,0 +1,22 @@
+package org.ruoyi.chat.service;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.common.message.Message;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class RocketMQService {
+
+    @Autowired
+    private DefaultMQProducer producer;
+
+    private final String topic = "device-tracking"; // 你的topic
+    private final String tags = "202861"; // 看起来像是tags或keys
+
+    public SendResult sendMessage(String messageBody) throws Exception {
+        Message message = new Message(topic, tags, messageBody.getBytes());
+        return producer.send(message);
+    }
+}