常量类

ruoyi-modules/ruoyi-backstage/pom.xml

@@ -122,6 +122,15 @@
             <artifactId>ruoyi-common-message</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-test</artifactId>
+        </dependency>
 
     </dependencies>
 

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/KafkaNormalConsumer.java

@@ -12,11 +12,10 @@ import org.dromara.backstage.business.consume.strategy.Impl.ConsumeStrategyConte
 import org.dromara.backstage.consumption.domain.bo.ConsumeRecordBo;
 import org.dromara.backstage.consumption.domain.bo.ConsumptionBo;
 import org.dromara.backstage.consumption.domain.vo.XfConsumeDetailOriginalVo;
-import org.dromara.backstage.mq.domain.bo.KafkaMessage;
 import org.dromara.common.core.domain.R;
 import org.dromara.common.core.enums.CreditTypeEnum;
 import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.stereotype.Component;
+import org.dromara.common.message.kafka.domain.KafkaMessage;
 
 import java.math.BigDecimal;
 import java.util.HashMap;

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/KafkaProducer.java

@@ -0,0 +1,27 @@
+package org.dromara.backstage.mq;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Slf4j
+@Component
+public class KafkaProducer {
+
+    private final KafkaTemplate<String, String> kafkaTemplate;
+
+    /**
+     * Send.
+     *
+     * @param topic   the topic
+     * @param message the message
+     */
+    public void send(String topic , String message) {
+        log.debug("发送消息到kafka消息系统， message:" + message);
+        kafkaTemplate.send(topic, message);
+        log.debug("发送消息到kafka消息系统结束");
+    }
+
+}

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/domain/bo/KafkaHeader.java

@@ -1,38 +0,0 @@
-package org.dromara.backstage.mq.domain.bo;
-
-import lombok.Data;
-
-/**
- * name: KafkaHeader
- * package: org.dromara.stream.domain.bo
- * description: kafka消息头
- * date: 2024-10-15 11:22:26 11:22
- *
- * @author luoyibo
- * @version 0.1
- * @since JDK 1.8
- */
-@Data
-public class KafkaHeader {
-    /**
-     * 发送方
-     */
-    private String sender;
-    /**
-     * 时间戳
-     */
-    private Long timestamp;
-    /**
-     * 事件类型
-     */
-    private String eventType;
-    /**
-     * 事件Id
-     */
-    private String eventId;
-
-    /**
-     * 租户编号
-     */
-    private String tenantId;
-}

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/domain/bo/KafkaMessage.java

@@ -1,19 +0,0 @@
-package org.dromara.backstage.mq.domain.bo;
-
-import lombok.Data;
-/**
- * name: KafkaMessage
- * package: org.dromara.stream.domain.bo
- * description: Kafka消息内容
- * date: 2024-10-15 11:28:02 11:28
- *
- * @author luoyibo
- * @version 0.1
- * @since JDK 1.8
- */
-@Data
-public class KafkaMessage<T> {
-    private KafkaHeader header=new KafkaHeader();
-
-    private T body;
-}

ruoyi-modules/ruoyi-backstage/src/test/java/org/dromara/backstage/mq/KafkaProducerTest.java

@@ -0,0 +1,18 @@
+package org.dromara.backstage.mq;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+public class KafkaProducerTest {
+
+    @Autowired
+    private KafkaProducer kafkaProcedurer;
+
+    @Test
+    public void send()
+    {
+        kafkaProcedurer.send("ykt_local_listener", "test message");
+    }
+}