当前位置：首页 > news >正文

netty应用-手写RPC

news 2025/7/21 6:02:36

文章目录

手写RPC之案例定位与通信过程介绍
- - RPC框架案例定位
  - 服务端与客户端架构
  - 通信过程
  - - 1. 服务注册与发现
    - 2. 请求序列化与传输
    - 3. 请求处理与响应
    - 4. 响应反序列化与结果处理
  - 实现细节
  - - 1. 服务端
    - 2. 客户端
  - 技术选型
  - 关键挑战
  - 总结
手写RPC之请求响应通信协议定制
- - 协议结构
  - - 示例消息头格式
    - 示例消息体格式
  - 序列化与反序列化
  - 错误处理
  - 实现示例
  - - Protobuf定义
    - 发送请求
    - 接收响应
  - 总结
手写RPC之Hessian序列化与反序列化
- - 添加依赖
  - 序列化
  - 反序列化
  - 使用示例
  - 注意事项
手写RPC之Hessian序列化请求响应测试
- - 步骤1：定义请求和响应对象
  - 步骤2：实现Hessian序列化和反序列化
  - 步骤3：模拟服务端处理逻辑
  - 步骤4：客户端发送请求
  - 步骤5：服务端接收请求并响应
手写RPC之Netty编码器序列化封装
- - 1. 创建序列化工具类
  - 2. 创建解码器
  - 3. 配置Netty的`ChannelPipeline`
  - 4. 测试和调试
手写RPC之消息长度校验与读索引标记
- - 1. 消息长度校验
  - 2. 读索引标记与重置
  - 3. 使用标记和重置来处理半包读取
  - 总结
手写RPC之消息长度负值校验与拆包校验
- - 1. 消息长度负值校验
  - 2. 拆包校验
  - 3. 综合使用
手写RPC之拆包问题处理与读索引复位
- - 拆包问题处理
  - - 手动处理拆包
  - 读索引复位
  - 总结
手写RPC之拆包后等待下次数据输入分析
- - 1. 标记读索引
  - 2. 等待下次数据输入
  - 3. 重置读索引并继续读取
  - 4. 自定义解码器处理
  - 5. 使用`LengthFieldBasedFrameDecoder`
  - 总结
手写RPC之字节数组反序列化为指定类
- - 1. Hessian反序列化
  - 2. Java序列化反序列化
  - 3. Jackson JSON反序列化
  - 示例使用
手写RPC之服务提供端NettyServer搭建
- - 1. 引入Netty和Hessian依赖
  - 2. 创建服务端处理类
  - 3. 创建服务端初始化器
  - 4. 启动服务端
手写RPC之NettyServerHandler请求处理
- - 1. 引入必要的包
  - 2. 定义`NettyServerHandler`类
  - 3. 定义`Request`类
  - 4. 注册`NettyServerHandler`
手写RPC之基于反射调用目标类方法
- - 步骤概述
  - 定义请求类
  - 定义响应类
  - 编写服务器端
  - 编写客户端
  - 使用反射调用方法
  - - 示例服务接口
    - 示例服务实现
    - 客户端代码
手写RPC之log4i2日志框架与响应封装
- - 1. 引入Log4j2依赖
  - 2. 配置Log4j2
  - 3. 使用Log4j2记录日志
  - 4. 封装响应
  - - 定义响应类
    - 在`NettyServerHandler`中封装响应
  - 5. 客户端处理响应
手写RPC之服务调用端网络通信封装
- - 1. 引入Netty依赖
  - 2. 定义请求和响应类
  - 3. 创建客户端初始化器
  - 4. 创建客户端处理类
  - 5. 创建客户端启动类
手写RPC之服务调用端Bootstrap封装完毕
- - 1. 创建客户端启动类
  - 2. 创建客户端初始化器
  - 3. 创建客户端处理类
  - 4. 定义请求和响应类
  - 完整客户端启动类
手写RPC之远程调用方法实现与过程分析
- - 1. 定义请求和响应类
  - 2. 客户端初始化器
  - 3. 客户端处理类
  - 4. 客户端启动类
  - 5. 服务端初始化器
  - 6. 服务端处理类
  - 7. 服务端启动类
  - 过程分析
手写RPC之服务调用端Handler逻辑实现
- - 1. 客户端Handler类
  - 2. 请求和响应类
  - 3. 客户端初始化器
  - 4. 客户端启动类
  - 过程分析
手写RPC之服务调用端timeout功能实现
- - 1. 更新客户端Handler类
  - 2. 更新请求类
  - 3. 更新客户端启动类
  - 过程分析
手写RPC之响应返回时的timeout超时处理
- - 1. 更新客户端Handler类
  - 2. 更新请求类
  - 3. 更新客户端启动类
  - 过程分析
手写RPC之服务调用端响应结果封装
- - 1. 定义响应结果封装类
  - 2. 更新客户端Handler类
  - 3. 客户端启动类
  - 过程分析
手写RPC之服务提供端ServiceConfig
- - 1. ServiceConfig 类设计
  - 2. ServiceConfig 的使用示例
  - - 服务接口定义
    - 服务实现类
    - ServiceConfig 使用
  - 3. 服务注册和发布
  - 4. 示例代码
  - 过程分析
手写RPC之服务提供端代理多ServiceConfig
- - 1. ServiceConfig 类
  - 2. ServiceRegistry 类
  - 3. ServiceDispatcher 类
  - 4. 服务注册和发布
  - 5. 示例代码
  - 过程分析
手写RPC之服务调用端ReferenceConfig
- - 1. ReferenceConfig 类设计
  - 2. ReferenceConfig 的使用示例
  - - 服务接口定义
    - 服务调用端
  - 3. 完整的服务调用端代码
  - 4. RpcClientHandler 类
  - 过程分析
手写RPC之服务调用端接口动态代理实现
- - 1. 定义服务接口
  - 2. 实现动态代理
  - 3. 完整的服务调用端代码
  - - ReferenceConfig 类
    - NettyRpcClient 类
  - 4. RpcClientHandler 类
  - 5. 使用示例
  - 过程分析
手写RPC之发起连接与远程调用请求
- - 1. 定义服务接口
  - 2. 定义RPC请求和响应
  - 3. 实现动态代理
  - 4. 完整的服务调用端代码
  - - ReferenceConfig 类
    - NettyRpcClient 类
  - 5. RpcClientHandler 类
  - 6. 使用示例
  - 过程分析
手写RPC之远程调用流程测试与问题修复
- - 测试案例
  - 1. 成功调用远程服务
  - - 客户端测试
  - 2. 超时测试
  - - 客户端测试
  - 3. 异常处理测试
  - - 客户端测试
  - 4. 并发调用测试
  - - 客户端测试
  - 问题修复
  - 示例代码中的问题修复
  - 更新后的代码片段
  - 总结
手写RPC案例中发送RPC请求的字节数组
- - 序列化和反序列化的实现
  - - 1. 序列化
    - 2. 反序列化
  - 示例代码
  - - 客户端发送RPC请求
    - 服务器接收RPC请求
  - 注意事项
基于手写RPC案例分析字节流粘包拆包
- - 粘包和拆包的原因
  - 解决方案
  - 示例：基于长度前缀的消息拆分
  - - 1. 修改`RpcRequest`和`RpcResponse`
    - 2. 序列化和反序列化
    - 3. 发送端
    - 4. 接收端
  - 完整的Netty处理器链
  - - 5. Netty处理器链
  - 示例代码
  - - 客户端
    - 服务端
  - 总结
手写RPC案例中对粘包拆包问题的解决分析
- - 粘包和拆包问题
  - 解决方案
  - 实现步骤
  - 示例代码
  - - 1. 消息格式定义
    - 2. 编码器 - `RpcMessageEncoder`
    - 3. 解码器 - `RpcMessageDecoder`
    - 4. Netty处理器链配置
  - 完整的客户端和服务端示例
  - - 客户端
    - 服务端
  - 总结