log4j2自定义Appender（输出到文件/RPC服务中）

栏目: 服务器 · 发布时间: 6年前

内容简介：虽然log4j很强大，可以将日志输出到文件、DB、ES等。但是有时候确难免完全适合自己，此时我们就需要自定义Appender，使日志输出到指定的位置上。本文，将通过两个例子说明自定义APPender，一个是将日志写入文件中，另一个是将日志发送到远程Thrift服务中。本文代码详见：

1、背景

虽然log4j很强大，可以将日志输出到文件、DB、ES等。但是有时候确难免完全适合自己，此时我们就需要自定义Appender，使日志输出到指定的位置上。

本文，将通过两个例子说明自定义APPender，一个是将日志写入文件中，另一个是将日志发送到远程Thrift服务中。

本文代码详见： https://github.com/hawkingfoo/log-demo

2、自定义文件Appender

2.1 定义文件Appender

先上代码：

@Plugin(name = "FileAppender", category = "Core", elementType = "appender", printObject = true)
public class FileAppender extends AbstractAppender {
private String fileName;
/* 构造函数 */
public FileAppender(String name, Filter filter, Layout<? extends Serializable> layout, boolean ignoreExceptions, String fileName) {
super(name, filter, layout, ignoreExceptions);
this.fileName = fileName;
}
@Override
public void append(LogEvent event) {
final byte[] bytes = getLayout().toByteArray(event);
writerFile(bytes);
}
/* 接收配置文件中的参数 */
@PluginFactory
public static FileAppender createAppender( @PluginAttribute( "name") String name,
@PluginAttribute( "fileName") String fileName,
@PluginElement( "Filter") final Filter filter,
@PluginElement( "Layout") Layout<? extends Serializable> layout,
@PluginAttribute( "ignoreExceptions") boolean ignoreExceptions) {
if (name == null) {
LOGGER.error( "no name defined in conf.");
return null;
}
if (layout == null) {
layout = PatternLayout.createDefaultLayout();
}
// 创建文件
if (!createFile(fileName)) {
return null;
}
return new FileAppender(name, filter, layout, ignoreExceptions, fileName);
}
private static boolean createFile(String fileName) {
Path filePath = Paths. get(fileName);
try {
// 每次都重新写文件，不追加
if (Files.exists(filePath)) {
Files.delete(filePath);
}
Files.createFile(filePath);
} catch (IOException e) {
LOGGER.error( "create file exception", e);
return false;
}
return true;
}
private void writerFile(byte[] log) {
try {
Files.write(Paths. get(fileName), log, StandardOpenOption.APPEND);
} catch (IOException e) {
LOGGER.error( "write file exception", e);
}
}
}

上面代码有几个需要注意的地方：

@Plugin.. 注解：这个注解，是为了在之后配置 log4j2.xml 时，指定的Appender Tag。
构造函数：除了使用父类的以外，也可以增加一些自己的配置。
重写 append() 方法：这里面需要实现具体的逻辑，日志的去向。
createAppender() 方法：主要是接收log4j2.xml中的配置项。

2.2 添加log4j2.xml配置

<?xml version= "1.0" encoding= "UTF-8" ?>
< configuration status= "INFO" monitorInterval= "30">
< appenders>
< console name= "Console" target= "SYSTEM_OUT">
< PatternLayout pattern= "%highlight{[ %p ] [%-d{yyyy-MM-dd HH:mm:ss}] [%l] %m%n}"/>
</ console>
< FileAppender name= "File" fileName= "log.log">
< PatternLayout pattern= "%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] [%-5p] {%F:%L} - %m%n" />
</ FileAppender>
</ appenders>
< loggers>
< logger name= "org.springframework" level= "INFO"> </ logger>
< logger name= "org.mybatis" level= "INFO"> </ logger>
< root level= "all">
< appender-ref ref= "Console"/>
< appender-ref ref= "File"/>
</ root>
</ loggers>
</ configuration>

备注：

<FileAppender>

2.3 测试

public class TestLogFile {
private static final Logger logger = LogManager.getLogger(TestLogFile.class);
public static void main (String[] args) {
logger.info( "1");
logger.info( "2");
logger.info( "3");
}
}

日志输出

可以看到，日志一共输出了2份，一份到终端中，一份到 log.log 中（具体的文件路径可在log4j2.xml中配置）。

3、自定义Thrift Appender

上一节，主要是日志的文件输出。有时我们需要将日志发送给日志收集服务，常见的方法可以写一个日志收集Agent，收集日志；或者将日志输出方当成客户端直接发送到远程。

下文，通过自定义Appender的方式，将日志输出到远程的RPC服务中。

3.1 Thrift RPC服务

假设现在有一个Thrift RPC服务，实时接收日志消息。它的定义是下面的样子：

namespace java thrift
service LogServer {
string getLogRes( 1: string log);
}

服务很简单，入参是log，返回值是String。

Thrift相关知识可以查看， Thrift RPC服务10分钟上手。

3.2 定义ThriftAppender

@Plugin(name = "ThriftAppender", category = "Core", elementType = "appender", printObject = true)
public class ThriftAppender extends AbstractAppender {
private LogServer.Client client;
private TTransport transport;
/* 构造函数 */
public ThriftAppender (String name, Filter filter, Layout<? extends Serializable> layout, boolean ignoreExceptions, String host) {
super(name, filter, layout, ignoreExceptions);
// 创建客户端
createThriftClient(host);
}
@Override
public void append (LogEvent event) {
final byte[] bytes = getLayout().toByteArray(event);
try {
String response = client.getLogRes( new String(bytes));
System.out.println(response);
} catch (TException e) {
e.printStackTrace();
}
}
/* 接收配置文件中的参数 */
@PluginFactory
public static ThriftAppender createAppender (@PluginAttribute( "name") String name,
@ PluginAttribute ( "host") String host,
@ PluginElement ( "Filter") final Filter filter,
@ PluginElement ( "Layout") Layout<? extends Serializable> layout,
@ PluginAttribute ( "ignoreExceptions") boolean ignoreExceptions) {
if (name == null) {
LOGGER.error( "no name defined in conf.");
return null;
}
if (layout == null) {
layout = PatternLayout.createDefaultLayout();
}
return new ThriftAppender(name, filter, layout, ignoreExceptions, host);
}
@Override
public void stop () {
if (transport != null) {
transport.close();
}
}
private void createThriftClient (String host) {
try {
transport = new TFramedTransport( new TSocket(host, 9000));
transport.open();
TProtocol protocol = new TBinaryProtocol(transport);
client = new LogServer.Client(protocol);
LOGGER.info( "create client success");
} catch (Exception e) {
LOGGER.error( "create file exception", e);
}
}
}

备注：

除了和文件Appender相同的外，这里需要注意两个地方。一个是Thrift Client的创建，另一个Thrift发送log。

具体的发送逻辑，在 append() 方法中实现。

3.3 添加log4j2.xml配置

<?xml version= "1.0" encoding= "UTF-8" ?>
< configuration status= "INFO" monitorInterval= "30">
< appenders>
< console name= "Console" target= "SYSTEM_OUT">
< PatternLayout pattern= "%highlight{[ %p ] [%-d{yyyy-MM-dd HH:mm:ss}] [%l] %m%n}"/>
</ console>
< ThriftAppender name= "Thrift" host= "127.0.0.1">
< PatternLayout pattern= "%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] [%-5p] {%F:%L} - %m%n" />
</ ThriftAppender>
</ appenders>
< loggers>
< logger name= "org.springframework" level= "INFO"> </ logger>
< logger name= "org.mybatis" level= "INFO"> </ logger>
< root level= "all">
< appender-ref ref= "Console"/>
< appender-ref ref= "Thrift"/>
</ root>
</ loggers>
</ configuration>

这里同样是定义了两个输出路径，一个是终端，一个是Thrift服务。

3.4 测试

public class TestThriftFile {
private static final Logger logger = LogManager.getLogger(TestThriftFile.class);
public static void main (String[] args) {
logger.info( "a");
logger.info( "b");
logger.info( "c");
}
}

Server端

Client端

可以看出，Server端成功接收到了log。

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

爆发

[美] 艾伯特-拉斯洛·巴拉巴西 / 马慧 / 中国人民大学出版社 / 2012-6 / 59.90元

1. 本书是一本超越《黑天鹅》的惊世之作。如果说塔勒布认为人类行为是随机的，都是小概率事件，是不可以预测的；那么全球复杂网络权威Barabasi则认为，人类行为93%是可以预测的。 2. Barabasi的研究是在人类生活数字化的大数据时代基础上进行的，移动电话、网络以及电子邮件使人类行为变得更加容易量化，将我们的社会变成了一个巨大的数据库。他认为，人类正处在一个聚合点上，在这里数据、科学......一起来看看《爆发》这本书的介绍吧!

码农工具