先看下consumer端发起调用时的链路流程： 1. 引入zookeeper作为注册中心后，服务查找过程 从建立spring到netty client建立连接的调用栈： NettyClient ...

broker消息接收，假设接收的是一个普通消息(即没有事务)，此处分析也只分析master上动作逻辑，不涉及ha。 1. 如何找到消息接收处理入口 可以通过broker的监听端口10911顺藤摸瓜 ...

限流是高可用服务需要具备的能力之一 ，粗暴简单的就像我们之前做的并发数控制。好一点的有tps限流，可用令牌桶等算法实现。《亿级流量网站架构核心技术》一书P67限流详解也有讲。dubbo提供了此机制，T ...

PooledByteBufAllocator buffer分配 buffer分配的入口： io.netty.buffer.PooledByteBufAllocator.newDirectBuffer ...