资讯专栏INFORMATION COLUMN

由 log4j2日志发送到Elasticsearch引起的缓冲池的实现

Hwg / 798人阅读

摘要:在看的时候想到最近的一个问题,日志先发到,再由从输出到中,能否直接将日志发送到只是单纯想看看怎么直接操作,肯定是先发到的方案更靠谱找到如下项目,,只在上有,上啥的都没有,一定要看的,前几个版本看的有点晕菜,代码太长了,就不贴出来了主要涉

在看Elasticsearch的时候想到最近的一个问题,log4j日志先发到kafka,再由logstash从kafka输出到Elasticsearch中,能否直接将log4j日志发送到Elasticsearch(只是单纯想看看怎么直接操作Elasticsearch,肯定是先发到kakfa的方案更靠谱)

找到如下项目,utility-log4j2-elasticsearch,只在bitbucket上有,github上啥的都没有,一定要看3.0的,前几个版本看的有点晕菜,代码太长了500+,就不贴出来了

https://bitbucket.org/inemar/...

主要涉及的内容为日志发送到一个缓冲池中,本地另起一个线程去消费缓冲池中的内容,代码写的很多有值得借鉴的地方

还有一些不明白的,如果正好有同学感兴趣,在看并且能解答下面的几个问题的,请不惜赐教

代码283行 每次都生成了一个client,要怎么改造成一个连接池的形式

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/71860.html

相关文章

  • log4j2+ELK

    摘要:问题初衷最近有个项目需求,需要统计下用户的使用情况,比如什么时候登录的,查询了什么内容等信息。缺点扩展能力需要靠自己设计,统计展示画面需要自己做。可轻松应对分布式,数据量大的情况。通过,如下修改,在重启后又会恢复原值。 问题初衷 最近有个项目需求,需要统计下用户app的使用情况,比如:什么时候登录的,查询了什么内容等信息。 解决方案 1.定义用户轨迹模型,每步操作都写到数据库中,然后在...

    Sunxb 评论0 收藏0
  • Elasticsearch Java Low Level REST Client(读取响应)

    摘要:读取响应对象由同步方法返回或作为中的参数接收,它包装客户端返回的响应对象并公开一些其他信息。有关执行的请求的信息。返回响应的主机。响应体包含在对象中。对于返回状态码的请求,不会抛出,因为它是一个预期的响应,仅表示找不到该资源。 读取响应 Response对象由同步performRequest方法返回或作为ResponseListener#onSuccess(Response)中的参数接...

    wangxinarhat 评论0 收藏0

发表评论

0条评论

Hwg

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<