文章介绍将Netty RPC客户端接收服务端返回结果的方式,从阻塞的AttributeMap改为CompletableFuture,实现异步非阻塞调用,代码更清晰,使用更简单,并建议限制未处理请求Map容量防OOM。
文章剖析RPC框架的“其他模块”:用动态代理RpcClientProxy屏蔽网络细节,统一封装请求;借Spring BeanPostProcessor,通过@RpcService发布服务、@RpcReference注入代理,实现注解式注册与消费。
- 2025-11-01
- /
-
默认分类,Java
- /
- 971 阅读
- /
- 暂无评论
- /
- 全文约 1670 字
- /
- 阅读预计需要 9 分钟
数据冷热分离按访问频率与业务价值将数据分为热、冷两类,分别存于高性能与低成本介质,以提升查询速度、节省成本;常用时间或访问频率划分,迁移可定时任务或监听binlog,冷数据可选MySQL、Hbase等存储。
文章剖析自研RPC框架的注册中心模块:定义ServiceRegistry与ServiceDiscovery接口,基于ZooKeeper实现服务注册与发现,支持多版本、多分组、多实例,配合负载均衡策略完成地址选取。
- 2025-10-08
- /
-
默认分类,Java
- /
- 1046 阅读
- /
- 暂无评论
- /
- 全文约 6930 字
- /
- 阅读预计需要 35 分钟
Kafka 是分布式流平台,兼具高吞吐消息队列与实时流处理能力。核心概念:Producer、Consumer、Broker、Topic、Partition;多副本+ISR 保障高可用。2.8 起支持无 Zookeeper 的 KRaft。顺序性靠单分区或 key 路由;防丢需 acks=all、手动...