0.1.0

bak.log

@@ -0,0 +1,9 @@
+2022-02-20 13:01:33.604  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication v0.1.0 using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 19200 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\app.jar started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-20 13:01:33.606  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-20 13:01:34.690  INFO 19200 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-20 13:01:34.702  INFO 19200 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-20 13:01:34.703  INFO 19200 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-20 13:01:34.754  INFO 19200 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-20 13:01:34.755  INFO 19200 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1113 ms
+2022-02-20 13:01:35.034  INFO 19200 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-20 13:01:35.042  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.824 seconds (JVM running for 2.181)

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/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-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)