首页 > 代码库 > Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)
Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)
对文件进行封装、注入,并且还能按照日志文件的时间点、文件大小等条件进行自动封存。
例如,想要将几个不同源的日志汇集到一起,可以用FlumeAppender;想要在LogEvent中注入信息,
可以用RewriteAppender;想要让系统按照设定的时间间隔自动封存日志信息,可以用RollingFileAppender
(每隔一定时间自动保存一份新增的日志文件,并按照时间戳等指定格式命名);当产生安全级别达ERROR或FATAL的LogEvent时,
给维护人员发送邮件可用SMTPAppender;希望将日志信息写到远程主机的,可用SocketAppender;希望能够按照RFC5424格式向远程主机发送日志信息,
可用SyslogAppender等等。
SocketAppender
将log event输出到一个远程服务器上(需指定服务器名和端口号),数据可以以任意指定的格式经由TCP或UDP协议发送。
SocketAppender中比较重要的参数有:
⑴ host,String,指定服务器的主机名。(必需)
⑵ immediateFlush,boolean,是否立即flush,还是等待缓存到一定大小后在flush。
⑶ layout,Layout,log event输出的格式。
⑷ port,integer,远程服务器坚挺log event的应用的端口号。
⑸ protocol,String,发送log event所使用的协议,"TCP" 或"UDP"。
⑹ reconnectionDelay,integer,当连接断开时,延迟等待的ms数。
⑺ name,String ,Appender的名称。
⑻ protocol,String,通讯协议 默认TCP。可选值 "TCP" (default), "SSL" or "UDP".
⑼ SSL,SslConfiguration,包含密钥存储库和信任存储库的配置.
⑽ filter,Filter,一个过滤器来确定事件应该由这个Appender。 不止一个过滤器 可以通过使用一个CompositeFilter。
⑾ immediateFail,boolean,设置为true时,日志事件不会等待尝试重新连接,将立即如果失败 套接字是不可用的。
⑿ immediateFlush,boolean, 当该值设置成真时,默认情况下,每个写将冲洗。 这将保证写的数据 到磁盘,但可能会影响性能。
⒀ layout,Layout,LogEvent ,布局使用格式。 缺省值是SerializedLayout。
⒁ reconnectionDelay,integer ,如果设置为值大于0,一个错误后SocketManager将尝试重新连接 在指定的毫秒数后的服务器。 如果连接失败 将抛出一个异常(可以被应用程序如果ignoreExceptions是 设置为假)。
⒂ ignoreExceptions,boolean,默认值是真正的添加事件时,遇到了引起异常 内部记录,然后忽略。 当设置为假将传播到异常 调用者。 你必须设置这个假当包装这个AppenderFailoverAppender。
日志服务器代码(main方法):
package com.herman.log4j2.server; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; public class TestServer { public static void main(String[] args) throws IOException { ServerSocket socket = new ServerSocket(5000); while (true) { Socket client = socket.accept(); Thread t = new Thread(new LogRunner(client)); t.start(); } } }日志服务器代码(Runnable线程):
package com.herman.log4j2.server; import java.io.IOException; import java.io.InterruptedIOException; import java.io.ObjectInputStream; import java.net.Socket; public class LogRunner implements Runnable{ private ObjectInputStream ois; public LogRunner(Socket client) { try { this.ois = new ObjectInputStream(client.getInputStream()); } catch (Exception e) { e.printStackTrace(); } } public void run() { try { while (true) { Object obj= ois.readObject(); System.out.println(obj.toString()); } } catch(java.io.EOFException e) { //读取的时候到达尾端抛出的异常,屏蔽掉 } catch(java.net.SocketException e) { } catch(InterruptedIOException e) { Thread.currentThread().interrupt(); } catch(IOException e) { } catch (Exception e) { e.printStackTrace(); } finally { } } }客户端xml配置(log4j2.xml):
<?xml version="1.0" encoding="UTF-8"?> <Configuration> <!-- Appenders 输出目的地 --> <Appenders> <!-- 配置日志输出文件名字 追加读写 host地址 端口 --> <Socket name="A1" host="localHost" port="5000"> <!-- 输出格式 序列布局--> <SerializedLayout/> </Socket> <!-- 控制台输出 --> <Console name="STDOUT" target="SYSTEM_OUT"> <!-- 输出格式 布局--> <PatternLayout pattern="%d %-5p [%t] %C{2} (%F:%L) - %m%n"/> </Console> </Appenders> <Loggers> <!-- debug级别 --> <Root level="debug"> <AppenderRef ref="A1"/> <AppenderRef ref="STDOUT"/> </Root> </Loggers> </Configuration>客户端测试代码:
package com.herman.log4j2.test; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @see log4j 2.0 简单的配置使用一个文件Appender * @author Herman.Xiong * @date 2014年7月21日 14:32:55 */ public class Test2 { /** * 配置日志级别为debug,输出位置为控制台和文件 */ private static Logger log = LogManager.getLogger(Test2.class); public static void main(String[] args) { log.trace("trace"); log.debug("debug"); log.info("info"); log.warn("warn"); log.error("error"); log.fatal("fatal"); log.trace("trace"); log.debug("debug"); log.info("info"); log.warn("warn"); log.error("error"); log.fatal("fatal"); log.exit(); } }输出效果:
Logger=com.herman.log4j2.test.Test2 Level=DEBUG Message=debug Logger=com.herman.log4j2.test.Test2 Level=INFO Message=info Logger=com.herman.log4j2.test.Test2 Level=WARN Message=warn Logger=com.herman.log4j2.test.Test2 Level=ERROR Message=error Logger=com.herman.log4j2.test.Test2 Level=FATAL Message=fatal Logger=com.herman.log4j2.test.Test2 Level=DEBUG Message=debug Logger=com.herman.log4j2.test.Test2 Level=INFO Message=info Logger=com.herman.log4j2.test.Test2 Level=WARN Message=warn Logger=com.herman.log4j2.test.Test2 Level=ERROR Message=error Logger=com.herman.log4j2.test.Test2 Level=FATAL Message=fatal欢迎大家关注我的个人博客!!!!
如有不懂,疑问或者欠妥的地方,请加QQ群:135430763 进行反馈,共同学习!
Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)