test

seecoder-logTracking-client/src/main/java/Utils/PostHelper.java

@@ -23,12 +23,10 @@ public class PostHelper {
         ObjectMapper objectMapper = new ObjectMapper();
         httpPost.setEntity(new StringEntity(objectMapper.writeValueAsString(data), "UTF-8"));
         HttpResponse response = httpClient.execute(httpPost);
-        String result;
+        String result = null;
         int statusCode = response.getStatusLine().getStatusCode();
         if (200 == statusCode) {
             result = EntityUtils.toString(response.getEntity());
-        } else {
-            return null;
         }
         httpPost.abort();
         return result;

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

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

testConnect/pom.xml

@@ -23,6 +23,11 @@
             <version>0.1.0</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.nju.edu</groupId>
+            <artifactId>seecoder-logTracking-common</artifactId>
+            <version>0.1.0</version>
+        </dependency>
     </dependencies>
 
     <properties>

testConnect/src/main/java/Test.java

@@ -1,33 +1,19 @@
-import Utils.LogBuilder;
-import com.nju.edu.logTracking.enums.SeecSystem;
+import com.nju.edu.logTracking.LogConsumer;
 
 import java.io.IOException;
 
 public class Test {
-    public static void main(String[] args) throws IOException {
-        String data = "This is an example";
-        String log = LogBuilder
-                .getBuilder()
-                .target(SeecSystem.EVAL)
-                .source(SeecSystem.CODER)
-                .operationType(1)
-                .data(data)
-                .message("be careful")
-                .build();
-        System.out.println(log);
-
-//        //最简单使用方法，默认为medium级别
-//        LogTrackingClient
-//                .getClient()
-//                .log(log)
-//                .publish();
-//
-//        LogConsumer myConsumer = new LogConsumer() {
-//            @Override
-//            public void run(String value) {
-//                System.out.println(value);
-//            }
-//        };
-//        myConsumer.processLog();
+    public static void main(String[] args) throws IOException, InterruptedException {
+        LogConsumer myConsumer = new LogConsumer() {
+            @Override
+            public void run(String value) {
+                System.out.println(value);
+            }
+        };
+        myConsumer.processLog();
+        while(true){
+            System.out.println("running");
+            Thread.sleep(2000);
+        }
     }
 }