0.1.0

.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>

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

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