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

netty应用-手写RPC

news 2025/7/3 18:07:10

文章目录

  • 手写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处理器链配置
      • 完整的客户端和服务端示例
        • 客户端
        • 服务端
      • 总结

手写RPC之案例定位与通信过程介绍

设计和实现一个自己的远程过程调用（RPC）框架是一个既挑战又具有教育意义的项目，它不仅帮助加深对分布式系统原理的理解，还能锻炼在实际场景下的编程技能。下面，我将概述一个简单的RPC框架的设计思路和通信过程，以及如何通过一个案例来定位和实现这一过程。

RPC框架案例定位

假设我们要实现一个简单的计算器服务，该服务能够执行加法、减法、乘法和除法操作。我们的目标是让客户端能够远程调用这个服务，就像调用本地方法一样。

服务端与客户端架构

  1. 服务端：定义服务接口和实现，例如 CalculatorService 接口和相应的实现类。

  2. 客户端：定义服务接口的相同版本，并提供一个代理类来远程调用服务端的方法。

通信过程

1. 服务注册与发现
  • 服务注册：服务端启动时，向注册中心（如Zookeeper或Consul）注册服务信息，包括服务名、地址和端口。
  • 服务发现：客户端通过注册中心查找服务端的信息，以建立连接。
2. 请求序列化与传输
  • 客户端：客户端调用代理方法时，将方法名、参数类型和参数值序列化成字节流（如

相关文章：

netty应用-手写RPC

文章目录 手写RPC之案例定位与通信过程介绍RPC框架案例定位服务端与客户端架构通信过程1. 服务注册与发现2. 请求序列化与传输3. 请求处理与响应4. 响应反序列化与结果处理实现细节1. 服务端2. 客户端技术选型关键挑战总结手写RPC之请求响应通信协议定制协议结构示例消息头格式…...

编程日记 2024/8/3 19:26:33

私域流量变迁与精细移动化趋势下的AI智能名片小程序源码应用探索

摘要：随着移动互联网技术的飞速发展，私域流量的价值日益凸显，成为企业营销战略的重要组成部分。私域流量的精细化和移动化趋势不仅改变了传统的营销格局，也为新兴技术的应用提供了广阔空间。本文深入探讨了私域流量的变迁历程&…...

编程日记 2024/8/3 19:23:27

数据结构初阶之排序（下）

前言 上一期内容中我们了解了基本排序中的插入与选择排序，今天我将为大家带来剩下的几种排序算法 快速排序 快速排序是Hoare于1962年提出的⼀种⼆叉树结构的交换排序⽅法，其基本思想为：任取待排序元素序列中的某元素作为基准值，…...

编程日记 2024/8/3 19:21:23

RGB图像的读取与保存

目录 1、安装imageio 2、读取照片 3、保存照片 4、resize 5、示例代码 1、安装imageio pip install imageio -i https://pypi.tuna.tsinghua.edu.cn/simple 2、读取照片 import imageio img imageio.imread(image_path) 3、保存照片 import imageio import numpy as…...

编程日记 2024/8/3 19:20:22

江协科技51单片机学习- p35 AD/DA模拟/数字采样

🚀write in front🚀 🔎大家好，我是黄桃罐头，希望你看完之后，能对你有所帮助，不足请指正！共同学习交流 🎁欢迎各位→点赞👍 收藏⭐️ 留言📝​…...

编程日记 2024/8/3 19:16:17

C#裁剪图像的几种方法总结

前言 我们在上位机软件开发过程中经常需要裁剪图像，本文就是对c#中常见的裁剪图像方法进行总结。 1、克隆 直接调用Bitmap的Clone函数，然后指定需要裁剪的区域即可裁剪图像，该种方法不会损失精度 public static Bitmap CropImage_Clone(Bi…...

编程日记 2024/8/3 19:14:13

被遗忘的哑终端 —— 键盘键位演变的启发者

注：机翻，未校对。 The Forgotten World of Dumb Terminals 被遗忘的哑终端世界 A quick journey through the lost age of “glass teletypes.” 快速穿越失落的“玻璃电传打字机”时代。 From the earliest days of digital computers, researchers o…...

编程日记 2024/8/3 19:13:12

APACHE安装与应用

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:Linux运维老纪的首页…...

编程日记 2024/8/3 19:11:09

预警器件控制思考

预警器件控制思考 最小示例思想 当读取到环境信息与环境阈值的时候, 我们预警系统就要根据这些信息做出判断,是否要启动器件。 最简单的就是， 举温度temp的例子, temp(温度)与temp_th(阈值), 通过判断, 得出是否要启动器件. 如果在一段时间内, 一直是环境异常, 我…...

编程日记 2024/8/3 19:10:08

[Day 43] 區塊鏈與人工智能的聯動應用：理論、技術與實踐

區塊鏈的隱私保護機制 隨著區塊鏈技術的廣泛應用，隱私保護成為了一個至關重要的問題。區塊鏈以其去中心化和透明性的特點，為數據管理和交易提供了新的方法。然而，這些特點也帶來了新的挑戰，尤其是在隱私保護方面。本文將深入探討…...

编程日记 2024/8/3 19:08:02

【星海随笔】路由器的启动过程

路由器的启动过程 1.加电之后，ROM运行加电自检程序（Post），检查路由器的处理器、接口、内存等硬件设备。2.执行路由器中的启动程序(Bootstrap),搜索操作系统。路由器操作系统扩张部分可以从Flash RAM中装入，也可从 TFT…...

编程日记 2024/8/3 19:05:56

[翻译] Asset Administration Shells

关于资产管理外壳 (AAS) 资产管理外壳 (AAS) 是工业4.0中的关键概念，为产品、资源（如设备）和过程提供信息隐藏和更高层次的抽象。AAS 是技术和设备无关的机器可读描述，提供访问资产属性和功能的统一接口。与现有解决方案不同&…...

编程日记 2024/8/3 19:03:53

linux 常用磁盘维护命令

badblocks 功能说明&#xff1a;检查磁盘装置中损坏的区块。 语 法&#xff1a;badblocks [-svw][-b <区块大小>][-o <输出文件>][磁盘装置][磁盘区块数][启始区块] 补充说明&#xff1a;执行指令时须指定所要检查的磁盘装置&#xff0c;及此装置的磁盘区块数。…...

编程日记 2024/8/3 19:02:52

滑动窗口大总结！！！妈妈以后再也不担心我不会做滑动窗口啦~

写在前面&#xff1a;全部题都源于力扣 讲解题目一&#xff1a;最小覆盖子串题目二&#xff1a;字符串排列题目三&#xff1a;找所有字母异位词题目四&#xff1a;无重复字符的最长子串题目五&#xff1a;滑动窗口的最大值 讲解 滑动窗口算法技巧主要用来解决子数组问题&#…...

编程日记 2024/8/3 19:01:51

从地铁客流讲开来：客流统计与清分释义

一、常见的客流统计 1. 进站客流 定义&#xff1a;指在某个时间段内&#xff0c;乘客进入地铁站的数量。示例&#xff1a;如果某天早上8点到9点之间有5000人次进入地铁站&#xff0c;则这段时间内的进站客流为5000人次。 2. 出站客流 定义&#xff1a;指在某个时间段内&…...

编程日记 2024/8/3 19:00:49

《Excelize权威指南》新书发布

在数据洪流涌动的数字化时代&#xff0c;数据处理与分析已跃升为解锁无限洞察力的金钥匙&#xff0c;赋能商业智慧、重塑医疗健康版图、驱动教育科研创新。然而&#xff0c;当数据量级爆炸式增长&#xff0c;传统工具如 Excel 虽被誉为数据处理领域的常青树&#xff0c;其手动操…...

编程日记 2024/8/3 18:59:47

Go语言加Vue3零基础入门全栈班11 Go语言+gorm用户管理系统实战 2024年08月03日 课程笔记

概述 如果您没有Golang的基础&#xff0c;应该学习如下前置课程。 Golang零基础入门Golang面向对象编程Go Web 基础Go语言开发REST API接口_20240728Go语言操作MySQL开发用户管理系统API教程_20240729Redis零基础快速入门_20231227GoRedis开发用户管理系统API实战_20240730Mo…...

编程日记 2024/8/3 18:56:43

【设计模式】代理模式详解

1.简介 代理模式是常用的Java设计模式&#xff0c;该模式的特点是代理类与委托类共享相同的接口。代理类主要负责预处理消息、过滤消息、将消息转发给委托类&#xff0c;并在事后处理消息等。代理类与委托类之间通常存在关联关系&#xff0c;一个代理类对象与一个委托类对象关…...

编程日记 2024/8/3 18:55:41

Python变量和简单的数据类型

1、变量 massageHello python world! print(massage) massageHello world print(massage) 运行这个代码发现&#xff0c;同一个变量出现两个不同的结果 Hello python world! Hello world 在程序中&#xff0c;可随时修改变量的值&…...

编程日记 2024/8/3 18:54:39

切比雪夫距离

切比雪夫距离&#xff08;Chebyshev Distance&#xff09;&#xff0c;又称棋盘距离或最大值距离&#xff0c;是一种用于测量两个点之间距离的度量方法。在二维平面上&#xff0c;切比雪夫距离定义为两个点之间的最大坐标差值。其公式如下&#xff1a; DChebyshevmax⁡(∣x2−…...

编程日记 2024/8/3 18:53:38

idea大量爆红问题解决

问题描述 在学习和工作中&#xff0c;idea是程序员不可缺少的一个工具&#xff0c;但是突然在有些时候就会出现大量爆红的问题&#xff0c;发现无法跳转&#xff0c;无论是关机重启或者是替换root都无法解决 就是如上所展示的问题&#xff0c;但是程序依然可以启动。 问题解决…...

编程新知 2025/6/30 6:24:25

质量体系的重要

质量体系是为确保产品、服务或过程质量满足规定要求&#xff0c;由相互关联的要素构成的有机整体。其核心内容可归纳为以下五个方面&#xff1a; &#x1f3db;️ 一、组织架构与职责 质量体系明确组织内各部门、岗位的职责与权限&#xff0c;形成层级清晰的管理网络&#xf…...

编程新知 2025/6/27 1:45:53

镜像里切换为普通用户

如果你登录远程虚拟机默认就是 root 用户&#xff0c;但你不希望用 root 权限运行 ns-3&#xff08;这是对的&#xff0c;ns3 工具会拒绝 root&#xff09;&#xff0c;你可以按以下方法创建一个 非 root 用户账号 并切换到它运行 ns-3。 一次性解决方案&#xff1a;创建非 roo…...

编程新知 2025/6/25 0:51:27

什么是EULA和DPA

文章目录 EULA&#xff08;End User License Agreement&#xff09;DPA&#xff08;Data Protection Agreement&#xff09;一、定义与背景二、核心内容三、法律效力与责任四、实际应用与意义 EULA&#xff08;End User License Agreement&#xff09; 定义&#xff1a; EULA即…...

编程新知 2025/6/21 12:01:35

html css js网页制作成品——HTML+CSS榴莲商城网页设计（4页）附源码

目录 一、&#x1f468;‍&#x1f393;网站题目 二、✍️网站描述 三、&#x1f4da;网站介绍 四、&#x1f310;网站效果 五、&#x1fa93; 代码实现 &#x1f9f1;HTML 六、&#x1f947; 如何让学习不再盲目 七、&#x1f381;更多干货 一、&#x1f468;‍&#x1f…...

编程新知 2025/7/1 23:52:59

C++.OpenGL （14/64）多光源（Multiple Lights）

多光源（Multiple Lights） 多光源渲染技术概览 #mermaid-svg-3L5e5gGn76TNh7Lq {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-3L5e5gGn76TNh7Lq .error-icon{fill:#552222;}#mermaid-svg-3L5e5gGn76TNh7Lq .erro…...

编程新知 2025/6/11 3:15:20

七、数据库的完整性

七、数据库的完整性 主要内容 7.1 数据库的完整性概述 7.2 实体完整性 7.3 参照完整性 7.4 用户定义的完整性 7.5 触发器 7.6 SQL Server中数据库完整性的实现 7.7 小结 7.1 数据库的完整性概述 数据库完整性的含义 正确性 指数据的合法性 有效性 指数据是否属于所定…...

编程新知 2025/6/28 14:04:35

RabbitMQ入门4.1.0版本（基于java、SpringBoot操作）

RabbitMQ 一、RabbitMQ概述 RabbitMQ RabbitMQ最初由LShift和CohesiveFT于2007年开发&#xff0c;后来由Pivotal Software Inc.&#xff08;现为VMware子公司&#xff09;接管。RabbitMQ 是一个开源的消息代理和队列服务器&#xff0c;用 Erlang 语言编写。广泛应用于各种分布…...

编程新知 2025/7/2 15:22:03

Unity中的transform.up

2025年6月8日&#xff0c;周日下午 在Unity中&#xff0c;transform.up是Transform组件的一个属性&#xff0c;表示游戏对象在世界空间中的“上”方向&#xff08;Y轴正方向&#xff09;&#xff0c;且会随对象旋转动态变化。以下是关键点解析&#xff1a; 基本定义 transfor…...

编程新知 2025/6/28 0:00:55

GraphQL 实战篇：Apollo Client 配置与缓存

GraphQL 实战篇&#xff1a;Apollo Client 配置与缓存 上一篇&#xff1a;GraphQL 入门篇&#xff1a;基础查询语法 依旧和上一篇的笔记一样&#xff0c;主实操&#xff0c;没啥过多的细节讲解&#xff0c;代码具体在&#xff1a; https://github.com/GoldenaArcher/graphql…...

编程新知 2025/7/1 1:20:36