首页 > 数据库 >springboot2 搭建日志收集系统存入mongodb + redis+mq+线程池+xxljobs

springboot2 搭建日志收集系统存入mongodb + redis+mq+线程池+xxljobs

时间:2022-12-06 14:56:44浏览次数:59  
标签:收集 mongodb redis 线程 mq 日志

我们看到了高效批量插入mongodb速度还不错,那么我们的系统日志收集怎么做呢。

当然当前文件日志收集效果也不错,比如前面博文写的elkf搭建日志收集系统。

但我们系统中总是有不少重要的报文需要收集,比如订单信息,比如指定的客户信息。

思路:

1、在每个需要收集的服务上组建好要收集的日志信息。

2、通过mq发送出去。这个mq发送邮一定的耗时,所有mq发送时,采用线程池方式。

3、日志收集系统,订阅这个mq的队列,接收到消息后,存储到redis中。 

4、通过xxljob没秒钟到redis中全部捞出要存储的日志信息,根据其中的分类区分存储到不同的mongodb集合中。

 

 

这里涉及几个点:

1、mq如何发送。

2、mq如何接收。

3、线程池如何使用。

4、redis写入。

5、redis如何获取数据。

7、xxljob如何使用。

8、mongodb如何批量写入。

9、如何让这个服务通用起来。

标签:收集,mongodb,redis,线程,mq,日志
From: https://www.cnblogs.com/a393060727/p/16955204.html

相关文章

  • 踩坑记录:Redis的lettuce连接池不生效
    踩坑记录:Redis的lettuce连接池不生效一、lettuce客户端lettuce客户端Lettuce和Jedis的都是连接RedisServer的客户端程序。Jedis在实现上是直连redisserver,多线程环......
  • Redis如何模糊匹配Key值
    Redis模糊匹配Key值使用Redis的scan代替Keys指令:publicSet<String>scan(StringmatchKey){Set<String>keys=(Set<String>)redisTemplate.execute((RedisC......
  • springboot2 mongodb 高效批量入库--环境搭建
    当今使用微服务越来越多,每个服务都需要记录日志,那么记录到mysql中已完全不合适了。那么就记录到mongo中吧。想要速度快,那么一定要使用批量保存,做过尝试入库10万数据,逐条插......
  • Redis原理 - 对象的数据结构(SDS、Inset、Dict、ZipList、QuickList、SkipList、RedisO
    Redis数据结构1.SDSRedis是用C语言写的,但是对于Redis的字符串,却不是C语言中的字符串(即以空字符’\0’结尾的字符数组),它是自己构建了一种名为简单动态字符串(sim......
  • Redis
    Redis缓存一、关于缓存缓存的定义:缓存(Cache),就是数据交换的缓冲区,俗称的缓存就是缓冲区内的数据,一般从数据库中获取,存储于本地代码举个例子:越野车,山地自行车,都......
  • 【数据库数据恢复】MongoDB数据库无法启动服务的数据恢复案例
    关于MongoDB数据库:MongoDB数据库存储方式是将文档存储在集合之中,而不是像Oracle、MySQL一样的关系型数据库。MongoDB数据库是开源数据库,也提供具有附加功能的商业版本。M......
  • Redis 缓存击穿问题
    解决方案一:互斥锁假设一个热门产品的缓存时间到期了,那么将会有大量的请求查询不到缓存,就只能去查询数据库然后再把数据添加到缓存中。但是如果在缓存时间到期的瞬间有很多......
  • java线程研究---(6)暂停Thread:join
    暂停Threadjoin方法,会让线程线程暂停,具体如下:调用方法:Thread对象.join()比如,当前有一个线程对象son,当调用了son.join()方法之后(不是child.start()方法哦),会让线程对象son的父......
  • MongoDB Compass SQL语句
    MongoDBCompassSQL语句MongoDBCompass是MongoDB的一个图形管理的数据库管理系统,对于新手可以快速上手,所见即所得。操作数据内容:{"id":1001,"name":"ZhangSan","age"......
  • 剖析java中几种创建线程的几种方式
    文章目录​​继承Thread​​​​实现Runnable接口​​​​实现Callable接口​​​​newThread方式的缺点​​​​通过线程池创建​​​​newSingleThreadExecutor​​​​n......