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的方法是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
当前文章:loh4j整合flume的方法是什么
文章链接:http://myzitong.com/article/gesepo.html