Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)
Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)
Log4j2的Appenders充分考虑了日志事件的输出、包装以及过滤转发的可能，包括最基本的输出到本地文件、输出到远程主机， 对文件进行封装、注入，并且还能按照日志文件的时间点、文件大小等条件进行自动封存。 例如，想要将几个不同源的日志汇集到一起，可以用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欢迎大家关注我的个人博客！！！！