繼續上篇文章java logback 向 EFK 寫入日誌， 此篇文章主要講述在docker環境下EFK與logback的整合，主要解決java專案在docker環境下，向EFK輸出日誌的問題：

1. 上篇文章中的方法雖然可以向EFK寫入日誌，但是在叢集環境中，無法區分容器，除非自己在日誌的msg中寫入相關資訊，然而往往會被分詞器分開，這點比較麻煩
2. 雖然上篇文章中的logback-more-appenders可以使用DataFluentAppender方式來向elasticsearch新增額外的fields，但是這裡也同時存在一個問題，就是msg中的部分資訊，會被拆分成多個field，導致msg資訊不再完整，以及從kibana上面檢視日誌非常不便

下面來一起看看我是如何解決的（部分內容跟上篇文章同）

部署一套EFK

打包日誌外掛（此處有不同）

原始碼地址：fluentd-logback-appender（此外掛是我基於logback-more-appenders原始碼進行的改進，使得在使用FluentLogbackAppender類的時候，也可以新增額外的fields）

關於此外掛的打包，這裡不多做說明，相應jar包可以在劉迎光的nexus中找到，搜尋“fluentd-logback-appender”即可

專案引用

pom.xml檔案新增依賴

<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/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.firewarm</groupId>
	<artifactId>testLogback4Fluentd</artifactId>
	<packaging>
 
war</packaging>
	<version>0.0.1-SNAPSHOT</version>
	<name>testLogback4Fluentd Maven Webapp</name>
	<url>http://maven.apache.org</url>
	<properties>
		<jetty.version>8.1.10.v20130312</jetty.version>
		<fluentd.logger.version>0.3.2</fluentd.logger.version>
	</properties>
	<dependencies>
		<!-- logback 配置 -->
		<dependency>
			<groupId>ch.qos.logback</groupId>
			<artifactId>logback-classic</artifactId>
			<version>1.1.7</version>
		</dependency>
		<dependency>
			<groupId>ch.qos.logback</groupId>
			<artifactId>logback-core</artifactId>
			<version>1.1.7</version>
		</dependency>
		<dependency>
			<groupId>com.firewarm</groupId>
			<artifactId>fluentd-logback-appender</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>org.fluentd</groupId>
			<artifactId>fluent-logger</artifactId>
			<version>${fluentd.logger.version}</version>
			<optional>true</optional>
		</dependency>
		<!-- logback 配置， end -->
	</dependencies>
	<build>
		<finalName>testLogback4Fluentd</finalName>
	</build>
</project>

配置logback-test.xml檔案

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
	<appender name="FLUENT_TEXT"
		class="com.firewarm.fluentd_logback_appender.FluentLogbackAppender">
		<!-- Tag for Fluentd. Farther information: http://docs.fluentd.org/articles/config-file -->
		<tag>${app.name}</tag>
		<!-- [Optional] Label for Fluentd. Farther information: http://docs.fluentd.org/articles/config-file -->
		<label>logback</label>
		<!-- Host name/address and port number which Flentd placed -->
		<remoteHost>${fluentd_host}</remoteHost>
		<port>${fluentd_port}</port><!-- ${fluentd_port} -->
		<!-- Max queue size of logs which is waiting to be sent (When it reach 
			to the max size, the log will be disappeared). -->
		<maxQueueSize>999</maxQueueSize>

		<additionalField>
			<key>container_id</key>
			<value>${hostname}</value>
		</additionalField>
		<layout class="ch.qos.logback.classic.PatternLayout">
			<pattern>%date [%thread] %-5level %logger{80}- %msg%n</pattern>
			<!-- <pattern><![CDATA[%date{HH:mm:ss.SSS} [%thread] %-5level %logger{15}#%line %msg]]></pattern> -->
		</layout>
	</appender>

	<logger name="com.firewarm" level="trace">
		<appender-ref ref="FLUENT_TEXT" />
	</logger>
	<root level="trace">
		<appender-ref ref="trace" />
	</root>
</configuration>

這裡有話說：

1. 為了方便使用，這裡的app.name、fluentd_host、fluentd_port、hostname全以環境變數方式配置（這裡不多講了，我在windows中配置了環境變數，做測試）
2. 這裡的hostname在docker應用中，如果沒有指定hostname的情況下（並且也沒必要指定，因為在實現scale的時候，這個hostname指定就沒有什麼實際意義了），預設是container_id

實測結果

這裡就拿寫入錯誤棧來看

# 源json串

{
  "_index": "testlogback-2016.10.25",
  "_type": "fluentd",
  "_id": "AVbuZYUTOf1yFl8aApQh",
  "_score": null,
  "_source": {
    "msg": "2016-10-25 09:51:12,090 [main] ERROR com.firewarm.test.TestLog- -->> Exception\r\njava.lang.NullPointerException: null\r\n\tat com.firewarm.test.TestLog.log(TestLog.java:23)\r\n\tat com.firewarm.test.TestLog.main(TestLog.java:16)\r\n",
    "container_id": "testLog1",
    "@timestamp": "2016-10-25T09:51:12+08:00"
  },
  "fields": {
    "@timestamp": [
      1477360272000
    ]
  },
  "sort": [
    1477360272000
  ]
}

顯示結果如圖所示（我們想要的都有了） 

在kibana的搜尋中，只需要填寫“container_id:testLog1”，即可搜尋到相關的日誌了

如此，即完成了測試