test

.idea/compiler.xml

@@ -10,6 +10,7 @@
         <module name="seecoder-logTracking-common" />
         <module name="seecoder-logTracking-server" />
         <module name="seecoder-logTracking-client" />
+        <module name="testConnect" />
         <module name="seecoder-logTracking-consumer" />
       </profile>
     </annotationProcessing>
@@ -21,6 +22,7 @@
       <module name="seecoder-logTracking-common" options="-parameters" />
       <module name="seecoder-logTracking-consumer" options="-parameters" />
       <module name="seecoder-logTracking-server" options="-parameters" />
+      <module name="testConnect" options="-parameters" />
     </option>
   </component>
 </project>

.idea/encodings.xml

@@ -5,5 +5,6 @@
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-common/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-consumer/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-server/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/testConnect/src/main/java" charset="UTF-8" />
   </component>
 </project>

Dockerfile

@@ -9,5 +9,5 @@ FROM java:8-jre-alpine
 ENV PROJECT_NAME app
 ENV WORK_PATH /opt/$PROJECT_NAME
 WORKDIR /app
-COPY --from=compile_stage $WORK_PATH/seecoder-logTracking-server/target/${PROJECT_NAME}.jar .
+COPY --from=compile_stage $WORK_PATH/testConnect/target/${PROJECT_NAME}.jar .
 CMD ["sh", "-c", "java -Xdebug -Xrunjdwp:transport=dt_socket,address=8888,server=y,suspend=n -jar -server /app/${PROJECT_NAME}.jar"]

pom.xml

@@ -9,6 +9,7 @@
         <module>seecoder-logTracking-client</module>
         <module>seecoder-logTracking-consumer</module>
         <module>seecoder-logTracking-common</module>
+        <module>testConnect</module>
     </modules>
 
     <build>
@@ -29,6 +30,12 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
     </properties>
+    <distributionManagement>
+        <repository>
+            <id>nexus</id>
+            <url>http://nexus.seecoder.cn/repository/maven-releases</url>
+        </repository>
+    </distributionManagement>
 
 
 </project>

seecoder-logTracking-client/src/main/java/client/LogTrackingClient.java

@@ -1,10 +1,10 @@
 package client;
 
-import Utils.LogBuilder;
 import Utils.PostHelper;
 import com.nju.edu.logTracking.dto.LogConfigDto;
 import com.nju.edu.logTracking.enums.Level;
 import com.nju.edu.logTracking.enums.PublishMode;
+import com.nju.edu.logTracking.kafka.Config;
 import lombok.extern.slf4j.Slf4j;
 
 import java.io.IOException;
@@ -60,27 +60,10 @@ public class LogTrackingClient implements logTrackingApi {
     public void publish() {
         threadPoolExecutor.execute(() -> {
             try {
-                PostHelper.post("http://localhost:8080/api/publish", logConfigDto);
+                PostHelper.post(Config.SERVER + "/api/publish", logConfigDto);
             } catch (IOException e) {
                 log.error(e.getMessage());
             }
         });
     }
-
-    public static void main(String[] args) {
-        String log = LogBuilder.getBuilder()
-                .target("1")
-                .source("2")
-                .operationType(3)
-                .data("======this is a kafka message=======")
-                .message("be careful")
-                .build();
-
-        LogTrackingClient
-                .getClient()
-                .singleMode()    //选择模式 现阶段只有单条消息模式，默认为单条消息模式
-                .lowLevel()      //选择消息级别，为低中高三种级别，对应不同的数据完整性，默认为中级别
-                .log(log)        //具体的日志，即上面LogBuilder构造的日志
-                .publish();
-    }
 }

seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/enums/System.java → seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/enums/SeecSystem.java

@@ -1,6 +1,6 @@
 package com.nju.edu.logTracking.enums;
 
-public enum System {
+public enum SeecSystem {
     PAAS(0, "paas"),
     CODER(1,"coder"),
     DEVCLOUD(2,"devcloud"),
@@ -13,7 +13,7 @@ public enum System {
 
     int num;
     String name;
-    System(int num, String name){
+    SeecSystem(int num, String name){
         this.num = num;
         this.name = name;
     }

seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/kafka/Config.java

@@ -4,7 +4,8 @@ import java.util.Arrays;
 import java.util.List;
 
 public class Config {
-    public static List<String> KAFKA_SERVERS = Arrays.asList("http://localhost:9092","");
+    public static List<String> KAFKA_SERVERS = Arrays.asList("environment-40-126.seec.svc.cluster.local:9092","");
+    public static String SERVER = "environment-40-127.seec.svc.cluster.local:8080";
 
     public enum Topic{
         LOG_TRACKING_TOPIC("log-tracking");

seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/kafka/KafkaUtils.java

@@ -42,19 +42,4 @@ public class KafkaUtils {
     public static void send(KafkaProducer<String, String> producer, String topic, String message) {
         producer.send(new ProducerRecord<>(topic, message));
     }
-
-//    public static void main(String[] args) {
-//        Properties props = new Properties();
-//        props.put("bootstrap.servers", "http://localhost:9092");
-//        AdminClient adminClient = AdminClient.create(props);
-//        ArrayList<NewTopic> topics = new ArrayList<NewTopic>();
-//        NewTopic newTopic = new NewTopic("test-topic", 1, (short) 1);
-//        topics.add(newTopic);
-//        CreateTopicsResult result = adminClient.createTopics(topics);
-//        try {
-//            result.all().get();
-//        } catch (InterruptedException | ExecutionException e) {
-//            e.printStackTrace();
-//        }
-//    }
 }

seecoder-logTracking-common/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -1,6 +1,6 @@
+com\nju\edu\logTracking\enums\SeecSystem.class
 com\nju\edu\logTracking\kafka\KafkaUtils.class
 com\nju\edu\logTracking\dto\LogConfigDto.class
-com\nju\edu\logTracking\enums\System.class
 com\nju\edu\logTracking\kafka\Config.class
 com\nju\edu\logTracking\enums\Level.class
 com\nju\edu\logTracking\enums\PublishMode.class

seecoder-logTracking-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -2,5 +2,5 @@ D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\l
 D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\Level.java
 D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\Config.java
 D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\KafkaUtils.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\System.java
 D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\dto\LogConfigDto.java
+D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\SeecSystem.java

seecoder-logTracking-consumer/src/main/java/com/nju/edu/logTracking/LogConsumer.java

@@ -23,14 +23,4 @@ public abstract class LogConsumer {
     }
 
     public abstract void run(String value);
-
-    public static void main(String[] args) {
-        LogConsumer logConsumer = new LogConsumer() {
-            @Override
-            public void run(String value) {
-                System.out.println(value);
-            }
-        };
-        logConsumer.processLog();
-    }
 }

seecoder-logTracking-consumer/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -1,2 +1 @@
-com\nju\edu\logTracking\LogConsumer$1.class
 com\nju\edu\logTracking\LogConsumer.class

seecoder-logTracking-server/target/bak.log

@@ -1,9 +0,0 @@
-2022-02-20 10:32:07.622  INFO 15220 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication v0.1.0 using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 15220 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\app.jar started by Administrator in D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target)
-2022-02-20 10:32:07.622  INFO 15220 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
-2022-02-20 10:32:08.621  INFO 15220 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
-2022-02-20 10:32:08.637  INFO 15220 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
-2022-02-20 10:32:08.637  INFO 15220 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
-2022-02-20 10:32:08.684  INFO 15220 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
-2022-02-20 10:32:08.684  INFO 15220 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1031 ms
-2022-02-20 10:32:08.965  INFO 15220 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
-2022-02-20 10:32:08.965  INFO 15220 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.734 seconds (JVM running for 2.084)

testConnect/pom.xml

@@ -0,0 +1,41 @@
+<?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">
+    <parent>
+        <artifactId>seecoder-logTracking</artifactId>
+        <groupId>com.nju.edu</groupId>
+        <version>0.1.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>testConnect</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>com.nju.edu</groupId>
+            <artifactId>seecoder-logTracking-client</artifactId>
+            <version>0.1.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.nju.edu</groupId>
+            <artifactId>seecoder-logTracking-consumer</artifactId>
+            <version>0.1.0</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

testConnect/src/main/java/Test.java

@@ -0,0 +1,35 @@
+import Utils.LogBuilder;
+import client.LogTrackingClient;
+import com.nju.edu.logTracking.LogConsumer;
+import com.nju.edu.logTracking.enums.SeecSystem;
+
+public class Test {
+    public static void main(String[] args) {
+        String data = "This is an example";
+
+        //此为logBuilder，若不想使用也可自己构建log
+        //注：此logBuilder在调用build方法时会自动添加created_time属性，值为当前时间戳
+        String log = LogBuilder
+                .getBuilder()
+                .target(SeecSystem.EVAL.getName())
+                .source(SeecSystem.CODER.getName())
+                .operationType(1)
+                .data(data)
+                .message("be careful")
+                .build();
+
+        //最简单使用方法，默认为medium级别
+        LogTrackingClient
+                .getClient()
+                .log(log)
+                .publish();
+
+        LogConsumer myConsumer = new LogConsumer() {
+            @Override
+            public void run(String value) {
+                System.out.println(value);
+            }
+        };
+        myConsumer.processLog();
+    }
+}

testConnect/target/maven-archiver/pom.properties

@@ -0,0 +1,3 @@
+artifactId=testConnect
+groupId=com.nju.edu
+version=0.1.0

testConnect/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -0,0 +1,2 @@
+Test$1.class
+Test.class

testConnect/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -0,0 +1 @@
+D:\SEEC\SEEC-LogTracking\testConnect\src\main\java\Test.java