📝 Writing docs.

dunwu · dunwu · commit c47bf4fe2ddf · 2017-12-29T10:33:19.000+08:00
diff --git a/codes/javatool/src/main/java/io/github/dunwu/javatool/ElasticDemo.java b/codes/javatool/src/main/java/io/github/dunwu/javatool/ElasticDemo.java
@@ -7,12 +7,9 @@
 import org.slf4j.LoggerFactory;
 
 /**
- * 向 Elastic 日志中心传输日志
- * Logback
- * logstash-logback-encoder jar 包会根据 logback 中的配置，将日志数据定向传输到 logstash 详见
- * src/main/resources/logback.xml appender 配置 使用 udp 方式传输时，有丢失日志的情况（ELK-UDP） 使用 tcp 方式传输时，不会丢失日志（ELK-TCP）
- * Log4j
- * 通过 org.apache.log4j.net.SocketAppender 发送 TCP 数据，Logstash 服务器使用 log4j input 插件 接收
+ * 向 Elastic 日志中心传输日志 Logback logstash-logback-encoder jar 包会根据 logback 中的配置，将日志数据定向传输到 logstash 详见
+ * src/main/resources/logback.xml appender 配置 使用 udp 方式传输时，有丢失日志的情况（ELK-UDP） 使用 tcp 方式传输时，不会丢失日志（ELK-TCP） Log4j 通过
+ * org.apache.log4j.net.SocketAppender 发送 TCP 数据，Logstash 服务器使用 log4j input 插件 接收
  * @author Zhang Peng
  */
 public class ElasticDemo {
@@ -21,20 +18,14 @@ public class ElasticDemo {
     private static volatile int index = 0;
 
     private static void sendLog4jLog() {
-        ExecutorService executorService = Executors.newFixedThreadPool(10);
         for (int i = 0; i < 100; i++) {
-            executorService.submit(new Runnable() {
-                @Override
-                public void run() {
-                    log4jLog.info(String.format("这是第 %d 条日志", ++index));
-                }
-            });
+            log4jLog.info(String.format("这是第 %d 条日志", ++index));
         }
     }
 
     private static void sendLogbackLog() {
-        ExecutorService executorService = Executors.newFixedThreadPool(10);
-        for (int i = 0; i < 100; i++) {
+        ExecutorService executorService = Executors.newFixedThreadPool(100);
+        for (int i = 0; i < 10000; i++) {
             executorService.submit(new Runnable() {
                 @Override
                 public void run() {
@@ -45,7 +36,7 @@ public void run() {
     }
 
     public static void main(String[] args) {
-        sendLog4jLog();
-//        sendLogbackLog();
+        // sendLog4jLog();
+        sendLogbackLog();
     }
 }
diff --git a/codes/javatool/src/main/resources/log4j.xml b/codes/javatool/src/main/resources/log4j.xml
@@ -35,7 +35,7 @@
     <param name="remoteHost" value="192.168.28.32" />
     <param name="port" value="9252" />
     <param name="Threshold" value="TRACE" />
-    <param name="ReconnectionDelay" value="1000" />
+    <param name="ReconnectionDelay" value="6000" />
     <param name="LocationInfo" value="true" />
   </appender>
 
@@ -49,7 +49,7 @@
 
   <!-- 根logger的设置-->
   <root>
-    <level value="warn"/>
+    <level value="trace"/>
     <appender-ref ref="STDOUT"/>
   </root>
 </log4j:configuration>
diff --git a/codes/javatool/src/main/resources/logback.xml b/codes/javatool/src/main/resources/logback.xml
@@ -39,8 +39,12 @@
     相当于和 logstash 建立了管道，将日志数据定向传输到 logstash
     -->
     <destination>192.168.28.32:9251</destination>
+    <keepAliveDuration>5 minutes</keepAliveDuration>
+    <reconnectionDelay>6 second</reconnectionDelay>
+    <writeBufferSize>16384</writeBufferSize>
     <encoder charset="UTF-8" class="net.logstash.logback.encoder.LogstashEncoder">
-      <customFields>{"appname":"javatool"}</customFields>
+      <customFields>{"appname":"metis"}</customFields>
+      <customFields>{"subappname":"metis-vdisk"}</customFields>
     </encoder>
   </appender>
 
