AbstractApplicationContext#refresh() AbstractApplicationContext#obtainFr...

顺序消息的实现 顺序消息进行消费时，若是第一次消费失败，可以返回SUSPEND_CURRENT_QUEUE_A_MOMENT，下一次会继续消费此...

提出疑问 第一次pullMessage时是不是根据offset去获取呢 offset从远程获取到还是存在本地呢 consumer端在启动时会开启...

客户端管理Channel 因为客户端要主动发起请求，以consumer为例，在对topic进行消费时，不同的topic可能在不同的broker上...

项目地址使用和rocket相似 后期准备做的 完善客户端channel管理。 broker分布式。这依赖于客户端的负载均衡，将topic分片存储...

netty在rocket中的使用 client和server都是使用netty通信 client在创建BootStrap时的简化代码如下 在处理...

raincat项目地址 源码分析 本地事务部分依赖于spring事务 @TxTransactional注解和spring自带的Transacti...

几个重要的类 DubboNamespaceHandler。该类继承NamespaceHandlerSupport，即通过spring对扩展标签的...

首先定义公共的接口 服务提供者进行接口的实现部分 实现rpc，主要为socket通信和协议的商定 服务提供者暴露需要调用的方法实现 服务消费者调...