loh4j整合flume的方法是什么

这篇文章主要讲解了“loh4j整合flume的方法是什么”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“loh4j整合flume的方法是什么”吧！

成都创新互联公司坚信：善待客户，将会成为终身客户。我们能坚持多年，是因为我们一直可值得信赖。我们从不忽悠初访客户，我们用心做好本职工作，不忘初心，方得始终。十年网站建设经验成都创新互联公司是成都老牌网站营销服务商,为您提供成都网站建设、成都做网站、网站设计、H5技术、网站制作、成都品牌网站建设、成都小程序开发服务,给众多知名企业提供过好品质的建站服务。

一、配置启动flume

    ①flume的配置文件  conf/flume-conf.properties（这个文件一般是flume-conf.properties.default），复制修改后缀即可；

    配置文件如下：

    agent1.channels = ch2
    agent1.sources = avro-source1
    agent1.sinks = log-sink1


    # 定义channel
    agent1.channels.ch2.type = memory    #mem channel


    # 定义source
    agent1.sources.avro-source1.channels = ch2
    agent1.sources.avro-source1.type = avro        #avro source
    agent1.sources.avro-source1.bind = 0.0.0.0
    agent1.sources.avro-source1.port = 41414


    # 定义sink
    agent1.sinks.log-sink1.channel = ch2
    agent1.sinks.log-sink1.type = logger                #logger sink

    启动flume

    bin/flume-ng agent --conf conf --conf-file conf/flume-conf.properties --name agent1 -Dflume.root.logger=INFO,console

二、log4j的配置

    ①在log4j.properties文件中添加flume appender

    log4j.rootLogger=INFO,flume   #日志级别，info和flume

    log4j.appender.flume = org.apache.flume.clients.log4jappender.Log4jAppender
    log4j.appender.flume.Hostname = 192.168.57.133    #flume地址
    log4j.appender.flume.Port = 41414                          #flume source监听的端口
    log4j.appender.flume.UnsafeMode = true
    log4j.appender.flume.layout=org.apache.log4j.PatternLayout 
    log4j.appender.flume.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c] [%p] - %m%n

三、测试

 

    在maven中添加flume appender依赖

org.apache.flume.flume-ng-clients
flume-ng-log4jappender
1.6.0

    编写简单的测试类：

public class Log4jTest {
	Logger logger = LoggerFactory.getLogger(Log4jTest.class);	/**
	 * 测试flume
	* @Title: flumeTest 
	* @Description: TODO
	* @param @throws Exception    
	* @return void    
	* @throws
	 */
	@Test
	public void flumeTest() throws Exception {
		while(true){
			logger.info("spider", System.currentTimeMillis());
			try {
				Thread.sleep(1000);
			} catch (Exception e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}
	}

    运行测试类，可以看到flume在控制台的输出

感谢各位的阅读，以上就是“loh4j整合flume的方法是什么”的内容了，经过本文的学习后，相信大家对loh4j整合flume的方法是什么这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！