當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

010_logback中的SocketAppender

發(fā)布時間：2025/4/17 编程问答 41 豆豆

生活随笔收集整理的這篇文章主要介紹了 010_logback中的SocketAppender 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

1. SocketAppender被設計為通過序列化ILoggingEvent實例把記錄輸出到遠程實體。被序列化的事件的真實類型是LoggingEventVO, 它實現(xiàn)了ILoggingEvent接口。盡管如此, 就記錄事件而言, 遠程記錄仍然是無損的。在接收和反序列化后, 事件像是從本地產(chǎn)生的一樣被記錄。運行在不同機器上的多個SocketAppender實例可以把各自的記錄輸出到一個格式固定的中央記錄服務器。

2. SocketAppender不關(guān)聯(lián)layout, 因為它把序列化的事件發(fā)送到遠程服務器。SocketAppender運作在TCP層上, TCP層提供可靠、有序、流量控制的端到端的二進制流。因此, 如果遠程服務器可訪問, 則記錄事件最終會到達那里。否則, 如果遠程服務器關(guān)機或不可訪問, 那么記錄事件會被拋棄。當遠程服務器恢復可用時, 會透明地繼續(xù)傳輸事件。這種透明的重新連接是由一個連接器(connector)線程執(zhí)行的, 它定時嘗試連接服務器。

3. 記錄事件被本地TCP實現(xiàn)自動地緩沖。這意味著如果服務器連接很慢, 但快于客戶端生成事件的速度, 那么客戶端不會受網(wǎng)絡連接慢的影響。但是如果網(wǎng)絡連接慢于生成事件的速度, 那么客戶端只能按網(wǎng)絡速度執(zhí)行。特別是在服務器宕機這種極端情況下, 客戶端會被阻塞。

4. 如果連接器線程仍然存在, 即使SocketAppender不再關(guān)聯(lián)到任何logger, 也不會被垃圾回收。連接器線程只在當與服務器之間沒有連接時存在。為避免這個垃圾回收問題, 你應當顯式地關(guān)閉 SocketAppender。會創(chuàng)建/銷毀很多SocketAppender實例的長期運行的程序應當注意這個垃圾回收問題。多數(shù)其他程序可以安全地忽略這個問題。如果宿主JVM在SocketAppender關(guān)閉之前退出了, 不管 SocketAppender被顯式關(guān)閉還是交給垃圾回收, 都有可能在管道(pipe)里剩有一些未被傳輸?shù)臄?shù)據(jù), 這些數(shù)據(jù)會丟失。為避免數(shù)據(jù)丟失, 一般在退出程序之前顯式地調(diào)用SocketAppender的close()方法或調(diào)用LoggerContext的stop()方法就可以了。

5. SocketAppender的屬性見下表

6. Logback標準發(fā)行包含一個簡單的記錄服務器程序"ch.qos.logback.classic.net.SimpleSocketServer", 可以支持多個SocketAppender客戶端。它等待來自SocketAppender客戶端的記錄事件, 接收到事件后, 按照本地服務器的記錄策略進行記錄。

7. 例子

7.1. 新建一個名為ServerSocketAppender的Java項目, 同時添加相關(guān)jar包

7.2. 在src目錄下創(chuàng)建logback.xml

<configuration><appender name="stdout" class="ch.qos.logback.core.ConsoleAppender"><encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"><pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern></encoder></appender><appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender"><file>log/my.log</file><prudent>true</prudent> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><fileNamePattern>log/my.%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>10MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> </rollingPolicy><encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"><pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern></encoder></appender><root level="debug"><appender-ref ref="file" /><appender-ref ref="stdout" /></root></configuration>

7.3. 編輯MyServer.java

package com.zr.server;import org.slf4j.LoggerFactory; import ch.qos.logback.classic.LoggerContext; import ch.qos.logback.classic.net.SimpleSocketServer;public class MyServer {public static void main(String[] args) {LoggerContext lc = (LoggerContext) LoggerFactory.getILoggerFactory();SimpleSocketServer sss = new SimpleSocketServer(lc, 9999);sss.start();} }

7.4. 新建一個名為SocketAppender的Java項目, 同時添加相關(guān)jar包

7.5. 在src目錄下創(chuàng)建logback.xml

7.6. 編輯MyClient.java

package com.zr.client;import org.slf4j.Logger; import org.slf4j.LoggerFactory;public class MyClient {private static final Logger logger = LoggerFactory.getLogger(MyClient.class);public static void main(String[] args) {for(int i = 0; i < 1000; i++) {logger.debug("客戶端日志: " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} }

7.7. 運行MyServer.java

7.8. 運行MyClient.java, 可以多運行幾個客戶端

7.9. 運行的過程中可以更改系統(tǒng)時間, 服務端接收到客戶端的日志信息

8. SimpleSocketServer不是很強大不能打印客戶端的ip和端口信息。

總結(jié)

以上是生活随笔為你收集整理的010_logback中的SocketAppender的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。

上一篇： 009_logback本地Appende
下一篇： 011_logback中的SMTPApp