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

netty应用-手写RPC

news 文章来源：https://blog.csdn.net/qq_16038125/article/details/140667957 2024/12/30 3:42:45

文章目录

  • 手写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

计算机基础（Windows 10+Office 2016）教程 —— 第4章 计算机网络与Internet（下）

第4章 计算机网络与Internet 4.4 局域网4.4.1 局域网概述4.4.2 以太网4.4.3 令牌环网4.4.4 无线局域网 4.5 Internet4.5.1 Internet 概述4.5.2 Internet 的基本概念4.5.3 Internet 的接入4.5.4 万维网 4.6 Internet的应用4.6.1 电子邮件4.6.2 文件传输4.6.3 搜索引擎 4.4 局域网…...

编程日记 2024/8/3 18:51:36

机器学习用Python还是R？哪个更好一些？

选择使用Python还是R来进行机器学习取决于多个因素&#xff0c;包括个人偏好、项目需求以及可用的资源。这里我可以简要比较一下它们的优缺点&#xff1a; Python的优势&#xff1a; 通用性和灵活性&#xff1a; Python是一种通用编程语言&#xff0c;可以用于多种用途&#…...

编程日记 2024/8/3 18:49:33

4个自定义倒计时

<!DOCTYPE html> <html lang"zh-CN"><head><meta charset"UTF-8"><title>4个自定义倒计时</title><style>* {margin: 0;padding: 0;box-sizing: border-box;user-select: none;body {background: #0b1b2c;}}hea…...

编程日记 2024/8/3 18:48:32

linux系统编程中Shell脚本配置，及linux脚本中的man test

Shell脚本配置是指在脚本中设置各种参数、选项和环境&#xff0c;以确保脚本能够根据预期的需求和环境执行。配置可以包括变量设置、环境变量、命令选项和错误处理等。 1. 脚本开头的配置 Shebang 第一行通常是shebang&#xff0c;它告诉系统使用哪个解释器来执行脚本。例如…...

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

Win7虚拟机分享(已安装VMware Tools)

前言 之前写过VMware安装Win7并安装VMware tools的博客&#xff0c;但操作仍显繁琐。后来发现可以直接分享已经配置好的虚拟机&#xff0c;所有软件都是安装好的&#xff0c;解压即用。 一. VMware Win7虚拟机配置 已完成的配置和安装的软件 专业版Win7系统(已永久激活)VMware…...

编程日记 2024/8/3 18:45:28

CANOpen EMCY紧急报文介绍

什么是CANOpen紧急报文 CANOpen中的Emcy紧急报文用于当设备出现故障或警告时&#xff0c;向其它节点报告故障或警告使用的。如设备某个设备出现过压或过流时&#xff0c;就可以发送紧急报文。 紧急报文的格式 错误代码&#xff1a;是0x1003索引预定义错误字段的内容&#xff…...

编程日记 2024/8/3 18:44:27

JAVA项目

目录 一、前言 二、技术介绍 三、项目实现流程 四、论文流程参考 五、核心代码截图 专注于大学生实战开发、讲解和毕业答疑等辅导&#xff0c;获取源码后台 一、前言 在数字化音乐时代&#xff0c;个性化推荐已成为提升用户体验、促进音乐消费的重要手段。为此&#xff0…...

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

️ LangChain +Streamlit+ Llama ：将对话式人工智能引入您的本地设备（下篇）

引言&#xff1a;种下一棵树最好的时间是十年前,其次是现在 书接上回&#xff1a;将对话式人工智能引入您的本地设备成为可能CSDNhttps://mp.csdn.net/mp_blog/creation/editor/140865426 目的&#xff1a;在这个大模型横行的时候&#xff0c;我们常用电脑如何开展大模型的工作…...

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

Kafka实战（Scala操作）

Kafka基础讲解部分 Kafka基础讲解部分 Kafka实战&#xff08;Scala操作&#xff09; 1、引入依赖 版本&#xff1a; <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.report…...

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

Android Framework 之WMS详解

1.WMS说的就是 WindowManagerService&#xff1a;负责为Activity对应的窗口分配Surface&#xff0c;管理Surface的显示顺序以及位置尺寸&#xff0c;控制窗口动画 。 它是Android系统中为各个客户端即每个app来提供这样的服务的一个类。 在Android系统中在systemServer 进程和各…...

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

买完域名后怎么搭建个人网站/百搜网络科技有限公司

1.不要看到别人的回复第一句话就说&#xff1a;给个代码吧&#xff01;你应该想想为什么。当你自己想出来再参考别人的提示&#xff0c;你就知道自己和别人思路的差异。 2.初学者请不要看太多太多的书那会误人子弟的&#xff0c;先找本系统的学&#xff0c;很多人用了很久都是只…...

编程日记 2024/12/30 3:39:30

wordpress搜索框中的汉字怎么改/竞价网络推广托管

本文适合有 Java 基础知识的人群作者&#xff1a;HelloGitHub-Salieri引言HelloGitHub 推出的《讲解开源项目》[1]系列。项目地址&#xff1a;https://github.com/KFCFans/PowerJobPowerJob 的设计目标为企业级的分布式任务调度平台&#xff0c;即成为公司内部的调度中间件。整…...

编程日记 2024/12/30 3:16:09

wordpress火车头发布规则/找资源

Redis简介Redis是一个开源可基于内存也可持久化的日志型、Key-Value数据库&#xff0c;和memcached类似但是支持的数据类型更多&#xff0c;数据都缓存在内存中&#xff0c;和memecached区别在于reids可以定期持久化数据到磁盘&#xff0c;并可以利用该特性实现master-slave同步…...

编程日记 2024/12/30 1:51:58

网站建设行吗/小说搜索风云榜

1.更改背景图片 如果希望将登录放置在初始屏幕右侧&#xff0c;请按如下处理&#xff1a; 使用事务 SWM0 可以在数据库中创建自己的图像.选择选项"二进制数据". 可以按.GIF 格式保存图像. 使用表 SSM_CUST 中的关键字 "START_IMAGE" 创建数据记录. (使用…...

编程日记 2024/12/29 19:06:51

soho做网站多少钱/超云seo优化

目录 一、canvas简介 1.1 什么是canvas&#xff1f;&#xff08;了解&#xff09; 1.2 canvas主要应用的领域&#xff08;了解&#xff09; 二、canvas绘图基础 2.0 sublime配置canvas插件&#xff08;推荐&#xff09; 2.1 Canvas标签 2.1.1 canvas标签语法和属性 &…...

编程日记 2024/12/29 18:34:30

商城网站建设教学/cms系统

近日市调机构counterpoint公布的数据显示2021年Q4荣耀手机夺下国内市场第二名、国产手机第一名&#xff0c;小米则回落至国内市场第五名、国产第四名。市调机构counterpoint的这份数据显示&#xff0c;2021年Q4苹果冲上国内手机市场第一名&#xff0c;它的市场份额达到21.7%&am…...

编程日记 2024/12/29 17:19:53