flume源码分析--Log4j日志直接发送到Flume过程分析（二）

一、环境介绍

参见这里

二、分析方法

1、在物理主机上编写代码用来记录日志信息，代码如下：

public class log4jAppendTest {

private static final Log logger = LogFactory.getLog(log4jAppendTest.class);

public static void main(String[] args) throws InterruptedException {
// TODO Auto-generated method stub
while(true){
logger.info(new Date().getTime());
Thread.sleep(2000);
}
}
}

2、在虚拟机上启动flume，相关的配置文件信息的修改参见这里。

3、本机启动客户端，位于虚拟机上的flume能够接收日志并能够显示到控制台。

4、开启远程调试功能开始进行跟踪调试分析。

三、调试分析

1、由于log4j发送日志到flume涉及到源码的多个类，将相关的源码都添加到路径中，如下图所示。



2、调试过程中首先需要启动node中的Application.java文件，注意不要设置断点，然后在相关的AvroLegacySource、NettyAvroRpcClient等源码文件中设置断点，在本地对log4jAppendTest进行普通调试，调试过程中将自动跑到设置断点的位置，如下图所示。



六、存在的问题

（1）LF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder”. in a Maven Project；参见这里

（2）ERROR RPC client creation failed! NettyAvroRpcClient { host: 192.168.1.11, port: 44446 }: RPC connection error。

将agent1.sources.source1.bind = localhost修改为agent1.sources.source1.bind = 192.168.1.11。这里Flume在解析localhost时可能存在问题。