240 发简信
IP属地:湖北
  • 利用分区概念增强阻塞队列吞吐量

    LinkedBlockingQueue 是很优秀的阻塞队列实现,某些资料显示可以达到50w QPS左右,其读写使用两把锁,但底层使用Reentr...

  • Spring-KafkaListener使用

    1.导包 2.Kafka配置类 3.配置文件(application.properties) 3.定义Consumer类 4.定义kafka-t...

  • ElasticSearch DSL 简单梳理

    声明:本文为方便日后部分DSL结构速查,由于索引设计不同,语法会有差异,本文默认String 保存为keyword类型,详细了解移步Elasti...

  • Resize,w 360,h 240
  • KafkaListener 批量消费异常时回退偏移量

    1.实现BatchErrorHandler 2.注册进KafkaListenerContainerFactory中

  • 重写fastjson序列化方法实现自定义key&value

    一个特殊需求,需要数据库实体对象转换成json的时候,key为数据库原表字段,value Date 转String,找了找博客,看了看fastj...

  • mybatis-plus代码生成器配置

    包含*字符的自己替换

  • Resize,w 360,h 240
    Presto多协调者实现

    写在前面:Presto 是facebook开发的一款开源大数据OLAP引擎,基于内存计算和作业分发,直接使用sql分析,不需要数据预处理,类似于...

  • springboot单元测试

    1.pom中映入starter 2.启动类