0

0

如何在Java中手写一个简单的RPC框架_基于Netty网络通信与动态代理的底层实战

P粉602998670

P粉602998670

发布时间:2026-03-11 13:06:48

|

337人浏览过

|

来源于php中文网

原创

不能直接用 new proxyinstance() 生成远程接口代理,因为 jdk 动态代理仅支持 interface 且需本地实现类,而 rpc 调用远端、本地无实现,否则抛 illegalargumentexception 或空指针;必须用 proxy.newproxyinstance() 配合自定义 invocationhandler 将调用转为网络请求。

如何在java中手写一个简单的rpc框架_基于netty网络通信与动态代理的底层实战

为什么不能直接用 new ProxyInstance() 生成远程接口代理

因为 JDK 动态代理只能代理 interface,且要求被代理对象存在本地实现类——而 RPC 的本质是“调用远端,本地连实现都没有”。强行套用会导致运行时抛 IllegalArgumentException: not an interface 或空指针。必须用 Proxy.newProxyInstance() 配合自定义 InvocationHandler,把方法调用转成网络请求。

实操建议:

立即学习Java免费学习笔记(深入)”;

  • 代理目标类型必须是纯接口(不能是 class),且所有方法需有明确的参数类型(避免泛型擦除后无法反序列化)
  • InvocationHandler#invoke() 中要提取 method.getName()method.getParameterTypes() 和实际参数值,封装为统一请求结构体
  • 别在 handler 里直接发 Netty 请求——Netty 的 Channel.writeAndFlush() 是异步的,需配合 DefaultPromise 或 CompletableFuture 拦截响应

Netty 客户端连不上服务端的三个高频原因

不是配置错端口就是 Channel 生命周期没管好。常见现象是 java.nio.channels.ClosedChannelException 或连接超时却无日志。

实操建议:

立即学习Java免费学习笔记(深入)”;

  • 检查服务端是否绑定了 0.0.0.0 而非 127.0.0.1,Docker 或防火墙常拦截回环外地址
  • 客户端 Bootstrap 必须复用同一个 EventLoopGroup,每次 new 一个 group 会导致连接未释放、线程泄漏
  • 别在 channelActive() 里立即发请求——此时 pipeline 可能还没初始化完;改用 channelFuture.addListener() 确保 channel 就绪后再写入

ObjectEncoderObjectDecoder 为什么在生产环境必须禁用

它们依赖 JDK 默认序列化,性能差、体积大、不跨语言、有严重安全风险(反序列化 gadget 可触发任意代码执行)。线上报 java.io.InvalidClassException 或 CPU 突增 90% 很可能就是它。

星月写作
星月写作

专为网络小说、 剧本创作者打造的AI增效工具

下载

实操建议:

立即学习Java免费学习笔记(深入)”;

  • 立刻换成 ProtobufEncoder/DecoderJsonEncoder/Decoder(如 Jackson + HttpObjectEncoder 变种)
  • 若坚持用 Java 序列化,至少重写 ObjectInputStream.resolveClass() 做白名单校验,但不推荐
  • 注意 ObjectDecoder 构造函数第二个参数是最大长度,设太小会丢包,设太大易被攻击;RPC 场景建议 ≤ 4MB

服务端收到请求但不返回响应,大概率卡在编解码或线程模型

典型表现:客户端等 timeout,服务端日志停在 “received request”,后续无 writeAndFlush() 日志。不是业务逻辑卡死,就是 Netty 的线程调度出问题。

实操建议:

立即学习Java免费学习笔记(深入)”;

  • 确认 handler 是否加了 @ChannelHandler.Sharable —— 如果没加又注册到多个 channel,会因状态共享导致响应写错 connection
  • 避免在 channelRead() 里做耗时操作(如 DB 查询、HTTP 调用),必须用 eventLoop().submit() 或单独线程池处理,否则阻塞 IO 线程
  • 响应 write 前务必检查 ctx.channel().isActive(),TCP 断连后继续 write 会静默失败,需捕获 exceptionCaught() 中的 IOException

真正难调的是跨线程回调和 Promise 状态竞争——比如异步业务结果回来时,原 ChannelHandlerContext 已不可用,得靠 requestId 关联并主动查找活跃 channel。这点多数人写到一半才意识到。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

490

2025.06.09

golang结构体方法
golang结构体方法

本专题整合了golang结构体相关内容,请阅读专题下面的文章了解更多。

202

2025.07.04

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1902

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

656

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2387

2025.12.29

java接口相关教程
java接口相关教程

本专题整合了java接口相关内容,阅读专题下面的文章了解更多详细内容。

47

2026.01.19

class在c语言中的意思
class在c语言中的意思

在C语言中,"class" 是一个关键字,用于定义一个类。想了解更多class的相关内容,可以阅读本专题下面的文章。

870

2024.01.03

python中class的含义
python中class的含义

本专题整合了python中class的相关内容,阅读专题下面的文章了解更多详细内容。

30

2025.12.06

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.1万人学习

Java 教程
Java 教程

共578课时 | 80.5万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号