@SoulBGM
SoulBGM 暂无简介
通过http接口的方式来收集服务器的运行状态(CPU、内存、磁盘、jvm、Bps)以及查询程序是否活着的功能
自研的监控服务端 意在快速搭建监控平台
统计相关功能的实现 周期有(秒,分,时,天,周,月,季,年)
使用Pcap4J抓取数据包
这是一个高性能的UDP组播转发代理服务器。它可以接收UDP组播数据包并将其转发到配置的后端服务器,支持负载均衡和动态配置重载。
使用RSA进行公钥私钥方式加解密
通过PriorityBlockingQueue队列实现kafka数据高优先级的先处理功能
有时对数据的丢失是无法容忍的,但不可避免的会出现远程数据库无法使用(数据库宕机,连接数据库超时...)。 这时又不能将传输过来的数据忽略,所有需要先将数据在本地进行暂时缓存,待远程数据库恢复后在进行入库操作。
Flink 使用例子
Flink 扩展
Esper 是一个高性能的复杂事件处理(CEP)和事件流处理(ESP)引擎,专为实时数据处理和分析设计。
批量插入数据程序
使用Java进行爬虫
spring cloud alibaba 系列开源组件使用例子
jdk1.8的stream的例子
利用AOP技术使用注解@Log进行日志记录 特色:使用spEL表达式进行排除不需要记录的参数内容
Redis工具封装 包括: 1、Value、Hash、List、Set、ZSet 5种数据类型的常用方法封装 2、Lua脚本调用封装 3、使用protostuff技术自定义序列化方式 4、各种测试例子
使用BlockingQueue阻塞队列进行请求合并
ExpiringMap的使用例子