1.基于DockerCompose部署ELK+Kafka收集日志平台
2.使用Aop+BlockingQueue技术将日志信息投递到Kafka中
3.Logstash订阅Kafka将日志信息输出到ES中
ELK+Kafka收集日志平台原理
使用AOP技术环绕和异常通知拦截日志内容缓存到BlockingQueue中,单独线程从BlockingQueue中取出msg转化成json格式投递到Kafka主题中,Logstash订阅Kafka主题实时将日志信息输出到ES中,最后使用kibana调用ES接口以图形报表信息查询日志。