@SoulBGM
SoulBGM 暂无简介
自研的监控服务端 意在快速搭建监控平台
通过http接口的方式来收集服务器的运行状态(CPU、内存、磁盘、jvm、Bps)以及查询程序是否活着的功能
统计相关功能的实现 周期有(秒,分,时,天,周,月,季,年)
使用Pcap4J抓取数据包
这是一个高性能的UDP组播转发代理服务器。它可以接收UDP组播数据包并将其转发到配置的后端服务器,支持负载均衡和动态配置重载。
使用RSA进行公钥私钥方式加解密
通过PriorityBlockingQueue队列实现kafka数据高优先级的先处理功能
有时对数据的丢失是无法容忍的,但不可避免的会出现远程数据库无法使用(数据库宕机,连接数据库超时...)。 这时又不能将传输过来的数据忽略,所有需要先将数据在本地进行暂时缓存,待远程数据库恢复后在进行入库操作。
Flink 使用例子