通过PriorityBlockingQueue队列实现kafka数据高优先级的先处理功能
统计相关功能的实现
周期有(秒,分,时,天,周,月,季,年)
有时对数据的丢失是无法容忍的,但不可避免的会出现远程数据库无法使用(数据库宕机,连接数据库超时...)。
这时又不能将传输过来的数据忽略,所有需要先将数据在本地进行暂时缓存,待远程数据库恢复后在进行入库操作。
Esper 是一个高性能的复杂事件处理(CEP)和事件流处理(ESP)引擎,专为实时数据处理和分析设计。
spring cloud alibaba 系列开源组件使用例子
通过http接口的方式来收集服务器的运行状态(CPU、内存、磁盘、jvm、Bps)以及查询程序是否活着的功能
利用AOP技术使用注解@Log进行日志记录
特色:使用spEL表达式进行排除不需要记录的参数内容
Redis工具封装
包括:
1、Value、Hash、List、Set、ZSet 5种数据类型的常用方法封装
2、Lua脚本调用封装
3、使用protostuff技术自定义序列化方式
4、各种测试例子
使用BlockingQueue阻塞队列进行请求合并
hdfs工具
和springboot进行了整合 hdfs-tool-spring-boot-starter
使用Jacob、Open Office、Libre Office进行PDF转换