From 5148ae5e140bd7c6c7253a4197f1f1dd9ff23fbd Mon Sep 17 00:00:00 2001
From: lijiayao <13831655+xiao-yao-charge-forward@user.noreply.gitee.com>
Date: Tue, 2 Apr 2024 14:23:01 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20=E6=96=B0=E5=A2=9E=E8=A7=A3=E6=9E=90?=
 =?UTF-8?q?=E7=B3=BB=E7=BB=9F=E6=A8=A1=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../couplet-analyze-incident/pom.xml          | 20 ++++++++++
 .../couplet-analyze-msg/pom.xml               | 20 ++++++++++
 .../java/com/couplet/msg/domain/MsgData.java  |  0
 .../com/couplet/msg/domain/TroubleLog.java    |  0
 .../src/test/java/com/couplet/msg/Main.java   |  0
 .../test/java/com/couplet/msg/ParsingMsg.java |  0
 .../{couplet-msg => couplet-analyze}/pom.xml  |  7 +++-
 .../couplet-electronic-fence-server/pom.xml   |  4 ++
 .../src/test/java/test.java                   | 33 +++++++++++++++
 .../src/test/java/test2.java                  | 40 +++++++++++++++++++
 couplet-modules/pom.xml                       |  2 +-
 11 files changed, 124 insertions(+), 2 deletions(-)
 create mode 100644 couplet-modules/couplet-analyze/couplet-analyze-incident/pom.xml
 create mode 100644 couplet-modules/couplet-analyze/couplet-analyze-msg/pom.xml
 rename couplet-modules/{couplet-msg => couplet-analyze/couplet-analyze-msg}/src/main/java/com/couplet/msg/domain/MsgData.java (100%)
 rename couplet-modules/{couplet-msg => couplet-analyze/couplet-analyze-msg}/src/main/java/com/couplet/msg/domain/TroubleLog.java (100%)
 rename couplet-modules/{couplet-msg => couplet-analyze/couplet-analyze-msg}/src/test/java/com/couplet/msg/Main.java (100%)
 rename couplet-modules/{couplet-msg => couplet-analyze/couplet-analyze-msg}/src/test/java/com/couplet/msg/ParsingMsg.java (100%)
 rename couplet-modules/{couplet-msg => couplet-analyze}/pom.xml (93%)
 create mode 100644 couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test.java
 create mode 100644 couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test2.java

diff --git a/couplet-modules/couplet-analyze/couplet-analyze-incident/pom.xml b/couplet-modules/couplet-analyze/couplet-analyze-incident/pom.xml
new file mode 100644
index 0000000..cc43d1a
--- /dev/null
+++ b/couplet-modules/couplet-analyze/couplet-analyze-incident/pom.xml
@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.couplet</groupId>
+        <artifactId>couplet-analyze</artifactId>
+        <version>3.6.3</version>
+    </parent>
+
+    <artifactId>couplet-analyze-incident</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>
diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/pom.xml b/couplet-modules/couplet-analyze/couplet-analyze-msg/pom.xml
new file mode 100644
index 0000000..2c78901
--- /dev/null
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/pom.xml
@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.couplet</groupId>
+        <artifactId>couplet-analyze</artifactId>
+        <version>3.6.3</version>
+    </parent>
+
+    <artifactId>couplet-analyze-msg</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>
diff --git a/couplet-modules/couplet-msg/src/main/java/com/couplet/msg/domain/MsgData.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/msg/domain/MsgData.java
similarity index 100%
rename from couplet-modules/couplet-msg/src/main/java/com/couplet/msg/domain/MsgData.java
rename to couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/msg/domain/MsgData.java
diff --git a/couplet-modules/couplet-msg/src/main/java/com/couplet/msg/domain/TroubleLog.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/msg/domain/TroubleLog.java
similarity index 100%
rename from couplet-modules/couplet-msg/src/main/java/com/couplet/msg/domain/TroubleLog.java
rename to couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/msg/domain/TroubleLog.java
diff --git a/couplet-modules/couplet-msg/src/test/java/com/couplet/msg/Main.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/test/java/com/couplet/msg/Main.java
similarity index 100%
rename from couplet-modules/couplet-msg/src/test/java/com/couplet/msg/Main.java
rename to couplet-modules/couplet-analyze/couplet-analyze-msg/src/test/java/com/couplet/msg/Main.java
diff --git a/couplet-modules/couplet-msg/src/test/java/com/couplet/msg/ParsingMsg.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/test/java/com/couplet/msg/ParsingMsg.java
similarity index 100%
rename from couplet-modules/couplet-msg/src/test/java/com/couplet/msg/ParsingMsg.java
rename to couplet-modules/couplet-analyze/couplet-analyze-msg/src/test/java/com/couplet/msg/ParsingMsg.java
diff --git a/couplet-modules/couplet-msg/pom.xml b/couplet-modules/couplet-analyze/pom.xml
similarity index 93%
rename from couplet-modules/couplet-msg/pom.xml
rename to couplet-modules/couplet-analyze/pom.xml
index d826790..1e3d70e 100644
--- a/couplet-modules/couplet-msg/pom.xml
+++ b/couplet-modules/couplet-analyze/pom.xml
@@ -9,7 +9,12 @@
         <version>3.6.3</version>
     </parent>
 
-    <artifactId>couplet-msg</artifactId>
+    <artifactId>couplet-analyze</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>couplet-analyze-incident</module>
+        <module>couplet-analyze-msg</module>
+    </modules>
 
     <properties>
         <maven.compiler.source>17</maven.compiler.source>
diff --git a/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/pom.xml b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/pom.xml
index c207416..0dbec53 100644
--- a/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/pom.xml
+++ b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/pom.xml
@@ -89,6 +89,10 @@
             <groupId>com.couplet</groupId>
             <artifactId>couplet-common-system</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+        </dependency>
 
     </dependencies>
 
diff --git a/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test.java b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test.java
new file mode 100644
index 0000000..58bc462
--- /dev/null
+++ b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test.java
@@ -0,0 +1,33 @@
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
+
+import java.util.Properties;
+
+/**
+ * @Author: LiJiaYao
+ * @Date: 2024/4/1
+ * 异步发送
+ */
+public class test {
+    public static void main(String[] args) {
+
+        Properties props = new Properties();
+        props.put("bootstrap.servers","39.103.133.136:9092");
+        //使用默认的配置
+//        props.put("acks","all");
+//        props.put("retries",0);
+//        props.put("batch.size",16384);
+//        props.put("linger.ms",1);
+//        props.put("buffer.memory",33554432);
+        props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
+        props.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
+        KafkaProducer<String, String> producer = new KafkaProducer<>(props);
+        for (int i = 0; i < 10; i++) {
+            producer.send(new ProducerRecord<String,String>("my-topic",Integer.toString(i),Integer.toString(i)));
+        }
+        producer.close();
+    }
+
+
+
+}
diff --git a/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test2.java b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test2.java
new file mode 100644
index 0000000..1969ae1
--- /dev/null
+++ b/couplet-modules/couplet-electronic-fence/couplet-electronic-fence-server/src/test/java/test2.java
@@ -0,0 +1,40 @@
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.Producer;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.clients.producer.RecordMetadata;
+import org.yaml.snakeyaml.introspector.Property;
+
+import java.util.Properties;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+/**
+ * @Author: LiJiaYao
+ * @Date: 2024/4/1
+ * 同步发送
+ */
+public class test2 {
+
+    public static void main(String[] args) {
+
+        Properties properties = new Properties();
+        properties.put("bootstrap.servers", "39.103.133.136:9092");
+        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        KafkaProducer<String, String> producer = new KafkaProducer<String, String>(properties);
+        for (int i = 0; i < 10; i++) {
+            Future<RecordMetadata> result = producer.send(new ProducerRecord<>("test", Integer.toString(i), Integer.toString(i)));
+            try {
+                RecordMetadata recordMetadata =result.get();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            } catch (ExecutionException e) {
+                e.printStackTrace();
+            }
+        }
+        producer.close();
+
+    }
+
+
+}
diff --git a/couplet-modules/pom.xml b/couplet-modules/pom.xml
index 2ef9b94..1ce01cd 100644
--- a/couplet-modules/pom.xml
+++ b/couplet-modules/pom.xml
@@ -18,7 +18,7 @@
         <module>couplet-modules-vehicle</module>
         <module>couplet-modules-mq</module>
         <module>couplet-enterprisemanagement</module>
-        <module>couplet-msg</module>
+        <module>couplet-analyze</module>
     </modules>
 
     <artifactId>couplet-modules</artifactId>