用go从零构建写一个RPC（仿gRPC，tRPC）--- 版本1（Client端）
这里我们来实现这个RPC的client端
为了实现RPC的效果，我们调用的Hello方法，即server端的方法，应该是由代理来调用，让proxy里面封装网络请求，消息的发送和接受处理。而上一篇文章提到的服务端的代理已经在.rpc.go文件中实现，我们将客户端的实现也写在这里
ClientProxy
// 客户端代理接口
type HelloClientProxy interface {Hello(ctx context.Context, in *HelloRequest, opts ...client.Option) (*HelloReply, error)
}// 客户端代理实现
type HelloClientProxyImpl struct {client client.Clientopts []client.Option
}// 创建客户端代理
func NewHelloClientProxy(opts ...client.Option) HelloClientProxy {return &HelloClientProxyImpl{client: client.DefaultClient,opts: opts,}
}- 这里的HelloClientProxyImpl其中的client类主要是负责invoke方法，抽象网络IO和编解码，opts主要是记录客户端启动时传入的配置项，如server的ip地址等
- 创建出客户端代理，我们就可以通过代理来调用Hello方法
// 实现Hello方法
func (c *HelloClientProxyImpl) Hello(ctx context.Context, req *HelloRequest, opts ...client.Option) (*HelloReply, error) {// 创建一个msg结构，存储service相关的数据，如serviceName等，并放到context中// 用msg结构可以避免在context中太多withValue传递过多的参数msg := internel.NewMsg()msg.WithServiceName("helloworld")msg.WithMethodName("Hello")ctx = context.WithValue(ctx, internel.ContextMsgKey, msg)rsp := &HelloReply{}// 这里需要将opts添加前面newProxy时传入的optsnewOpts := append(c.opts, opts...)err := c.client.Invoke(ctx, req, rsp, newOpts...)if err != nil {return nil, err}return rsp, nil
}
- 这里需要明确service的名字和对应方法，为了后续封装在协议数据里，到达server端才能正确路由。当代理类实现了这个Hello后，我们就可以通过proxy.Hello得到相应结果，Invoke方法隐藏了具体的网络处理，我们跟进Invoke方法
Client（clientTransPort）
上文提到，client类主要处理invoke方法，我们可以预见它的职责就是，
- 序列化请求体
- 编码
- 发送请求，接受响应
- 解码
- 反序列化响应体
- 返回客户端
为了代码的解耦，我们和server的处理一样，将以上操作放到clientTransPort上，client持有transPort，让transPort处理以上的逻辑
// 实现Send方法
func (c *clientTransport) Send(ctx context.Context, reqBody interface{}, rspBody interface{}, opt *ClientTransportOption) error {// 获取连接// TODO 这里的连接后续可以优化从连接池获取conn, err := net.Dial("tcp", opt.Address)if err != nil {return err}defer conn.Close()// reqbody序列化reqData, err := codec.Marshal(reqBody)if err != nil {return err}// reqbody编码，返回请求帧framedata, err := opt.Codec.Encode(ctx, reqData)if err != nil {return err}// 写数据到连接中err = c.tcpWriteFrame(ctx, conn, framedata)if err != nil {return err}// 读取tcp帧rspDataBuf, err := c.tcpReadFrame(ctx, conn)if err != nil {return err}// 获取msgctx, msg := internel.GetMessage(ctx)// rspDataBuf解码，提取响应体数据rspData, err := opt.Codec.Decode(msg, rspDataBuf)if err != nil {return err}// 将rspData反序列化为rspBodyerr = codec.Unmarshal(rspData, rspBody)if err != nil {return err}return nil
}
-
序列化是根据protobuf协议，编码的格式我们之间写Server的时候提到，我们需要将数据编码成以下格式：
-
当编码完成后，我们就需要写数据到连接中，并监听该连接的数据，当有数据后，我们再依次解码得到响应体，再将响应体反序列化，返回客户端。
-
写数据到连接和读连接中的数据也很简单，这里我们直接开启一个连接，调用Write写，而codec.ReadFrame在server端的时候已经介绍过
func (c *clientTransport) tcpWriteFrame(ctx context.Context, conn net.Conn, frame []byte) error {// 写入tcp_, err := conn.Write(frame)if err != nil {return fmt.Errorf("write frame error: %v", err)}return nil
}func (c *clientTransport) tcpReadFrame(ctx context.Context, conn net.Conn) ([]byte, error) {return codec.ReadFrame(conn)
}
效果测试
至此client端处理完毕，我们来看看效果：
//client端的测试main.go:
func main() {c := pb.NewHelloClientProxy(client.WithTarget("127.0.0.1:8000"))if c == nil {fmt.Println("Failed to create client")return}rsp, err := c.Hello(context.Background(), &pb.HelloRequest{Msg: "world"})if err != nil {fmt.Println("RPC call error:", err)return}fmt.Println("Response:", rsp.Msg)
}// server端的测试的main.go
func main() {// Create a new server instances := server.NewServer()// Register the HelloService with the serverpb.RegisterHelloServer(s, &HelloServerImpl{})// Start the server on port 50051if err := s.Serve(":8000"); err != nil {panic(err)}fmt.Print("启动成功")
}// 创建一个HelloServer的实现类
type HelloServerImpl struct{}
// 实现HelloServer接口的Hello方法
func (h *HelloServerImpl) Hello(req *pb.HelloRequest) (*pb.HelloReply, error) {// 这里可以实现具体的业务逻辑reply := &pb.HelloReply{Msg: "Hello " + req.Msg,}return reply, nil
}
server端启动：
server端接收到client的连接请求：
client收到响应：
现在version1开发完了，目前的版本主要是实现基础功能，并且为了考虑后续的扩展性做了比较多的解耦，在后面的版本，我们可以逐渐提升这个rpc的性能和融入更多的功能
相关文章：
用go从零构建写一个RPC（仿gRPC，tRPC）--- 版本1（Client端）
这里我们来实现这个RPC的client端 为了实现RPC的效果，我们调用的Hello方法，即server端的方法，应该是由代理来调用，让proxy里面封装网络请求，消息的发送和接受处理。而上一篇文章提到的服务端的代理已经在.rpc.go文件中…...
CentOS 安装 Zellij 终端复用器教程
CentOS 安装 Zellij 终端复用器教程 简介 Zellij 是一个现代化的终端复用器，使用 Rust 语言编写。它提供了类似 tmux 的功能，但具有更友好的用户界面和更现代化的特性。本教程将详细介绍如何在 CentOS 7.9 系统上安装 Zellij。 前置条件 CentOS 7.9 …...
基于 SpringBoot + Vue 的校园管理系统设计与实现
一、项目简介 本系统以校园组织管理为主线，结合用户权限分离机制与模块化设计，实现对“单位类别、单位、通知推送、投票信息、用户回复”等内容的全流程管理，广泛适用于教育局、高校及下属组织的信息管理工作。 🎯 项目亮点&…...
如何减少锁竞争并细化锁粒度以提高 Rust 多线程程序的性能？
在并发编程中，锁（Lock）是一种常用的同步机制，用于保护共享数据免受多个线程同时访问造成的竞态条件（Race Condition）。然而，不合理的锁使用会导致严重的性能瓶颈，特别是在高并发场景…...
【人工智能agent】--dify通过mcp协议调用工具
MCP Client 发起工具调用的实体，也就是 Dify 工作流或 Agent。它通过 Dify 平台提供的标准化接口（工具节点）来请求服务。 MCP Server / Host 提供实际服务的端点。在这个例子中，就是模拟 API 服务器 上的各个API (/api/pump/st…...
Review --- Redis
Redis redis是什么? Redis是一个开源的,使用C语言编写的,支持网络交互的，key-value数据结构存储系统,支持多种语言的一种非关系型数据库,它可以用作数据库（存储一些简单的数据，例如新闻点赞量），**缓存（秒…...
Sql刷题日志（day8）
一、笔试 1、right:提取字符串右侧指定数量的字符 right(string,length) /*string：要操作的字符串。length：要从右侧提取的字符数 */ 2、curdate():返回当前日期，格式通常为 YYYY-MM-DD 二、面试 1、自变量是不良体验反馈，因…...
【Science Advances】普林斯顿大学利用非相干光打造可重构纳米光子神经网络
(导读 ) 人工智能对计算性能需求剧增，电子微处理器发展受功耗限制。光学计算有望解决这些问题，光学神经网络（ONNs）成为研究热点，但现有 ONNs 因设计缺陷，在图像分类任务中精度远低于现代电子神经网络&#…...
2025-05-07 Unity 网络基础8——UDP同步异步通信
文章目录 1 UDP 概述1.1 通信流程1.2 TCP 与 UDP1.3 UDP 分包1.4 UDP 黏包 2 同步通信2.1 服务端2.2 客户端2.3 测试 3 异步通信3.1 Bgin / End 方法3.2 Async 方法 1 UDP 概述 1.1 通信流程 客户端和服务端的流程如下： 创建套接字 Socket。用 Bind() 方法将套…...
K8S - 金丝雀发布实战 - Argo Rollouts 流量控制解析
一、金丝雀发布概述 1.1 什么是金丝雀发布？ 金丝雀发布（Canary Release）是一种渐进式部署策略，通过逐步将生产流量从旧版本迁移至新版本，结合实时指标验证，在最小化风险的前提下完成版本迭代。其核心逻辑…...
手持小风扇方案解说---【其利天下技术】
春去夏来，酷暑时节，小风扇成为外出必备的解暑工具，近年来，随着无刷电机的成本急剧下降，小风扇也逐步从有刷变无刷化了。 数量最大的如一箱无刷马达，其次三相低压无刷电机也大量被一些中高端风扇大量采用。…...
Qt开发：枚举的介绍和使用
文章目录 一、概述二、Qt 中定义和使用枚举2.1 普通枚举的定义方式2.2 使用枚举 三、配合 Qt 元对象系统使用枚举3.1 使用 Q_ENUM（Qt 5.5 及以上）3.2 示例：枚举值转字符串3.4 示例：字符串转枚举值 四、枚举与字符串相互转换五、枚…...
HarmonyOS运动开发：如何集成百度地图SDK、运动跟随与运动公里数记录
前言 在开发运动类应用时，集成地图功能以及实时记录运动轨迹和公里数是核心需求之一。本文将详细介绍如何在 HarmonyOS 应用中集成百度地图 SDK，实现运动跟随以及运动公里数的记录。 一、集成百度地图 SDK 1.引入依赖 首先，需要在项目的文…...
“胖都来”商标申请可以通过注册不！
近日“胖都来”被网友认为是蹭“胖东来”品牌流量在互联网上引起争议，看到许多自媒体说浙江这家公司已拿到“胖都来”的注册商标，普推知产商标老杨经检索后发现是没有的，只是申请受理。 对于商城类主要类别是在35类广告销售，核心是…...
【Django】中间件
Django 中间件是 Django 框架里一个轻量级、可插拔的组件，它能在全局范围内对 Django 的请求和响应进行处理。中间件处于 Django 的请求处理流程之中，在请求抵达视图函数之前以及视图函数返回响应之后执行特定操作。以下是关于 Django 中间件的详细介绍&…...
电子电器架构 --- 48V架构的一丢丢事情
我是穿拖鞋的汉子，魔都中坚持长期主义的汽车电子工程师。 老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师： 钝感力的“钝”，不是木讷、迟钝，而是直面困境的韧劲和耐力，是面对外界噪音的通透淡然。 生活中有两种人，一种人格外在意别人的眼光;另一种人无论…...
什么是Blender？怎么获取下载Blender格式文件模型
glbxz.com glbxz.com 官方可以下载Blender格式文件模型 BlenderBlender 是一个免费的开源程序，用于建模和动画，最初由一家名为 Neo Geo 的动画工作室作为内部应用程序开发，后来作为自己的程序发布。这是一个称职的程序，近年来由于…...
Ubuntu安装pgsql
一、通过 APT 安装（推荐） 更新软件包列表 sudo apt update 安装 PostgreSQL 核心包及工具 sudo apt install postgresql postgresql-client postgresql-contrib • postgresql：数据库服务端 • postgresql-client：命令行…...
Qwen2-VL详解
一、引言 在人工智能领域，多模态大模型的发展备受关注。Qwen2-VL 作为一款先进的多模态模型，致力于克服现有方法在处理图像和视频数据时存在的不足，显著提升多模态信息的理解与交互能力。本文将全面且深入地阐述 Qwen2-VL 的创新理念、精妙的模型架构、严谨的训练流程、卓越…...
定长滑动窗口---初阶篇
目录 滑动窗口核心思想 定长滑动窗口套路 定长滑动窗口习题剖析 1456. 定长子串中元音的最大数目 643. 子数组最大平均数 I 1343. 大小为 K 且平均值大于等于阈值的子数组数目 2090. 半径为 k 的子数组平均值 2379. 得到 K 个黑块的最少涂色次数 2841. 几乎唯一子数组…...
以pytest_addoption 为例，讲解pytest框架中钩子函数的应用
钩子函数（Hook Function）的概念 钩子函数（Hook Function）是软件框架中预定义的回调接口，允许开发者在程序执行的特定阶段插入自定义逻辑，以扩展或修改框架的默认行为。在 pytest 中，钩子函数覆…...
数据智能重塑工业控制：神经网络在 MPC 中的四大落地范式与避坑指南
一、引言：工业控制的范式革命 在工业 4.0 的浪潮中，传统基于物理模型的控制方法（如 PID、线性二次型调节器 LQR）正面临前所未有的挑战。以石化行业为例，某炼油厂的催化裂化装置（FCCU）因反应机理…...
AB测试面试题
AB测试面试题 常考AB测试问答题（1）AB测试的优缺点是什么?（2）AB测试的一般流程/介绍一下日常工作中你是如何做A/B实验的？（3）第一类错误 vs 第二类错误 vs 你怎么理解AB测试中的第一、二类错误？（4）统计显著=实际显著？（5）AB测试效果统计上不显著？（6）实验组优于对…...
phpstudy升级新版apache
1.首先下载要升级到的apache版本，这里apache版本为Apache 2.4.63-250207 Win64下载地址：Apache VS17 binaries and modules download 2.将phpstudy中原始apache复制备份Apache2.4.39_origin 3.将1中下载apache解压， 将Apache24复制一份到ph…...
民宿管理系统6
普通管理员管理： 新增普通管理员： 前端效果： 前端代码： <body> <div class"layui-fluid"><div class"layui-row"><div class"layui-form"><div class"layui-f…...
——内存对齐原理)
【iOS】源码阅读(三)——内存对齐原理
文章目录 前言获取内存大小的三种常用方式sizeofclass_getInstanceSizemalloc_size 总结 前言 之前学习alloc相关源码，涉及到内存对齐的相关内容，今天笔者详细学习了一下相关内容并写了此篇博客。 获取内存大小的三种常用方式 获取内存大小的方式有很多…...
在 Ubuntu 中配置 Samba 实现「特定用户可写，其他用户只读」的共享目录
需求目标 所有认证用户可访问 Samba 共享目录 /path/to/home；**仅特定用户（如 developer）**拥有写权限；其他用户仅允许读取；禁止匿名访问。 配置步骤 1. 设置文件系统权限 将目录 /home3/guest 的所有权设为 develo…...
配置指定地址的conda虚拟Python环境
创建指定路径的 Conda 环境 在创建环境时，使用 --prefix 参数指定自定义路径： conda create --prefix/your/custom/path/my_env python3.8 说明： /your/custom/path/my_env：替换为你希望存放环境的路径（如 D:\projec…...
从彼得·蒂尔四象限看 Crypto「情绪变迁」：从密码朋克转向「标准化追求者」
作者：Techub 精选编译 撰文：Matti，Zee Prime Capital 编译：Yangz，Techub News 我又带着一篇受彼得蒂尔（Peter Thiel）启发的思想杂烩回来了。作为自封的「蒂尔学派」信徒，我常透过他…...
VS Code 常用插件
React Auto Import - ES6, TS, JSX, TSX Auto Rename Tag ES7 React/Redux/React-Native snippets Markdown Markdown All in One Markdown Preview Enhanced Other Prettier - Code formatter 格式化代码 Live Server 本地服务器实时预览与自动刷新...
深入探讨 UDP 协议与多线程 HTTP 服务器
深入探讨 UDP 协议与多线程 HTTP 服务器 一、UDP 协议：高效但“不羁”的传输使者 UDP 协议以其独特的特性在网络传输中占据一席之地，适用于对实时性要求高、能容忍少量数据丢失的场景。 1. UDP 的特点解析 无连接：无需提前建立连接&…...
Node.js入门指南：开启JavaScript全栈开发之旅
Hi，我是布兰妮甜 ！Node.js让JavaScript突破了浏览器的限制，成为全栈开发的利器。作为基于V8引擎的高性能运行时，它彻底改变了JavaScript只能做前端开发的局面。本文将带你快速掌握Node.js的核心用法：环境搭建与模块系统…...
【STM32F1标准库】理论——通信协议：串口
目录 一、简介 二、连接方式 三、串口参数与时序 1.参数 2.时序 四、STM32实现串口通信的方法 1.使用软件模拟 2.使用硬件外设 杂谈 1.通信的目的 2.常见可以使用串口通信的模块 3.串口常用电平标准 4.串口从波形反推数据 5.奇偶校验 一、简介 命名：USART&#…...
轻松管理房间预约——启辰智慧预约小程序端使用教程
欢迎您使用《启辰智慧预约》场所预约小程序，您可以通过本小程序预约会议室/活动室等，并在预约审批通过后，获取临时开锁密码，开锁密码会在预约时间前30分钟生效。以下是本程序的使用流程。 一、创建单位（新用户注册&am…...
如何在自己的服务器上部署静态网页并通过IP地址进行访问
文件放置 cd /var目录 新建www目录 进入www目录 新建html目录用于放置文件以及相关资源 修改配置文件 sudo nano /etc/nginx/sites-available/default修改index部分的html文件名 修改端口映射避免80冲突 重启Nginx sudo systemctl restart nginx打开浏览器访问即可 h…...
802.11s Mesh 组网框架流程
协议标准 使用 802.11s (标准 Mesh 协议) 基础流程框架 连接流程本质：Beacon → Peer Link → HWMP 路径发现 → 数据传输。mesh与easymesh的区别 阶段详解 阶段1:Beacon广播 作用：周期性宣告Mesh网络存在，同步参数（如Mesh …...
 in commit)
gitcode 上传文件报错文件太大has exceeded the limited size (10 MiB) in commit
登陆gitcoe，在项目设置->提交设置 ,勾选提交文件限制，修改限制的大小。 修改完后，重新提交代码。...
C++代码随想录刷题知识分享-----判断两个字符串是否为字母异位词（Anagram）【LeetCode 242】
✨ 题目描述 给定两个字符串 s 和 t，请判断 t 是否是 s 的字母异位词。 📌 示例 1： 输入：s "anagram", t "nagaram" 输出：true📌 示例 2： 输入：s "…...
Canal mysql to mysql 增加 online 库同步配置指南
Canal 增加新库 online 的配置指南 1. 停止 Canal Adapter 服务 ./bin/stop.sh2. 数据库备份与导入 备份源数据库 mysqldump -h 127.0.0.1 -P 3307 --single-transaction -uroot -p -B online > online.sql导入到目标数据库 mysql -h 127.0.0.1 -P 3308 -uroot -p <…...
Spring MVC中Controller是如何把数据传递给View的？
在 Spring MVC 中，Controller 负责请求的处理，准备需要展示的数据，并将这些数据传递给 View，由 View 负责最终的页面渲染。数据从 Controller 传递到 View 主要通过模型 (Model) 实现。 Spring MVC 提供了以下几种方式让 Control…...
FAST-LIO笔记
1.FAST-LIO FAST-LIO 是一个计算效率高、鲁棒性强的激光-惯性里程计系统。该系统通过紧耦合的迭代扩展卡尔曼滤波器（IEKF）将激光雷达特征点与IMU数据进行融合，使其在快速运动、噪声较大或环境复杂、存在退化的情况下仍能实现稳定的导航。 1…...
挑战用豆包教我学Java01天
今天是豆包教我学Java的第一天，废话不多说直接开始。 1.每日题目： 基础语法与数据类型 题目：编写一个 Java 程序，从控制台读取两个整数，然后计算它们的和、差、积、商，并输出结果。题目：编写…...
基于RT-Thread的STM32G4开发第二讲第二篇——ADC
文章目录 前言一、RT-Thread工程创建二、ADC工程创建三、ADC功能实现1.ADC.c2.ADC.h3.mian.c 四、效果展示和工程分享总结 前言 本文使用的是RT-Thread最新的驱动5.1.0，兼容下面的所有驱动。使用的开发板是蓝桥杯嵌入式国信长安的开发板，MCU是STM32G431…...
)
居民健康监测小程序|基于微信小程序的居民健康监测小程序设计与实现(源码+数据库+文档)
居民健康监测小程序 目录 基于微信小程序的居民健康监测小程序设计与实现 一、前言 二、系统设计 三、系统功能设计 1、用户信息管理 2、健康科普管理 5.3公告类型管理 3、论坛信息管理 四、数据库设计 五、核心代码 六、论文参考 七、最新计算机毕设选题推荐 …...
电商双11美妆数据分析
图中展示的是在Jupyter Notebook环境下的Python代码及运行结果。代码利用 seaborn 和 matplotlib 库，以 datal 数据集为基础，绘制上下两个子图。上方子图呈现各店铺中各大类的销售量，下方子图展示各店铺中各大类的销售额，通过条形…...
Spark-Core（双Value类型）
一、RDD转换算子（双Value类型） 1、intersection 函数签名： def intersection(other: RDD[T]): RDD[T] 函数说明：对源 RDD 和参数 RDD 求交集后返回一个新的 RDD 举栗： val dataRDD1 sparkContext.makeRDD(List(…...
【数据库原理及安全实验】实验六 角色访问控制
指导书原文 安全性管理二 【实验目的】 1) 通过语句设置登录用户的权限，实现对不同用户的操作权限的限定。 【实验原理】 1) 定义数据库角色，授予该角色特定权限，建立不同的用户将其置入不同的角色之下，即等于分配了该用户不…...
windows安装micromamba
windows安装 winget install Mamba.Micromamba Set-ExecutionPolicy RemoteSigned micromamba activate 第一次运行会报错，把报错中间那一句init代码跑一下 创建环境什么的和conda一样 把conda换成micromamba就行 绑定快捷键，winget安装&#x…...
vue-quill-editor的失焦事件
vue-quill-editor的用法再此就不再赘述了，只记录我在使用过程中踩的坑。 版本：Vue2 vue-quill-editor3.0.6 封装组件： <vue-quill-editorclass"editor":class"dynamicClasses"ref"myTextEditor"v-model&quo…...
【工具变量】最新华证ESG评级得分数据-含xlsx及dta格式（2009-2024.12）
参考《经济研究》中方先明（2023）的做法，将华证ESG评级进行赋值，指标包含C、CC、CCC、B、BB、BBB、A、AA、AAA共9个等级，将上市公司ESG等级从低到高分别赋值为1至9。将华证ESG评级得分数据更新至2024年12月31日…...