目录结构 此系列文章主要阐述了kafka 1.1.1版本中：生产者批量提交，消费者分组协调，WAL数据刷盘与恢复，副本复制及异常场景分析，LEO与HW更新，controller选主与分区选主的实现，副本状态机与分区状态机的实现等等实现。 01.kafka源码阅读-导读提示 02.代码版本、编译与常用命令 03.生产者批量发送机制实现 04.消费者组机制实现 05.offset range查询的实

arthas进阶使用-1本篇主要记录arthas除了watch、trace、stack、sc、thread等常用命令之外的用法。 为什么琢磨这些“高级”用法，源于我在阅读一些其他代码(或者定位问题时)，我要分析诊断初始化过程，包括main方法刚刚启动时，如果是传统的attach玩法，main方法早已跑了多远下去了。好在arthas本身就支持agent模式，我改了两行代码加挖掘了他一些用法达成了

健壮的(robust)Java benchmarking 阅读笔记理解Java代码编写的benchmarking的陷阱(pitfalls) 采样与计时 对目标方法多次后计算平均耗时。 使用System.nanoTime,而不是System.currentTimeMillis（毫秒 由于一些操作系统差异，导致其精度有问题）。 代码预热大多数JVM实现有一个复杂难懂的性能生命周期，一般来讲，

01-01.工具类-注解相关AnnotationUtilsorg.springframework.core.annotation.AnnotationUtils findAnnotation与getAnnotation、getRepeatableAnnotations、findAnnotationDeclaringClass、findAnnotationDeclaringClassForTyp

[CVE]重现dubbo安全漏洞cve-2020-1948环境信息➜ ~ java -version java version "1.8.0_121" Java(TM) SE Runtime Environment (build 1.8.0_121-b13) Java HotSpot(TM) 64-Bit Server VM (build 25.121-b13, mixed mode) ➜

28.扩展支持HTTP协议关于dubbo对http协议的支持，要分几个维度说： 仅仅传输协议使用http，报文的组织方式没有要求，那么dubbo这个版本(2.5.3)原生提供的http协议就能满足。适当配置即可。此处报文指http请求体与响应体的报文。http协议本身规定了其报文规范，诸如method、url、content-type，header等等，但是其请求体与响应体中内容你可以随意放置。

27.各个filter分析以及和spring cloud对比主要阐述dubbo rpc的filter的实现，包括作用，用法，原理，与Spring Cloud在这些能力的对比。 共提供了多少个？是哪些?发布时默认装配了哪些给他自身的扩展点机制？从类与接口关系分析的结果文档中可以看到共20个：241 Filter–241.1 CacheFilter–241.2 MonitorFilter–241.

26.泛化调用实现看两个filter即可，剩下的filter下篇文章讲 GenericFilter作用先讨论一个问题，rpc，最简单的场景是consumer端调用provider端的一个服务，这个服务双方都遵循一个接口实现，按最简单的dubbo的demo玩法，是需要consumer和provider两段都要有这个接口声明的（包括接口参数的类型的相关类），比如：org.simonme.dubbo

25.TPS限流知识各种限流算法的称呼网上有很多文章介绍限流算法，但是对于这些算法的称呼与描述也是有点难以理解。不管那么多了。我先按我理解的维度梳理一下。主要维度是：是正向计数还是反向计数。是定点(时间点)重置当前计数器还是每次接口调用时按量调整当前还剩的可用请求数。 通俗理解正向计数且定点(时间点)重置的流程 +------------------

24.调用链如何构建的？ProtocolFilterWrapper分析调用链的构建，可以理解成多个invoker实例组成链的构建。 调用链构建在dubbo中分为两步骤： JavassistProxyFactory$1的构建。此步骤是将真正的业务方法同规避反射的手段包起来。 ProtocolFilterWrapper$1的构建。此步骤是将每个filter用Invoker实例包起来并串起来链来。