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

Go网络编程-RPC程序设计

gRPC 通信

RPC 介绍

RPC, Remote Procedure Call,远程过程调用。与 HTTP 一致,也是应用层协议。该协议的目标是实现:调用远程过程(方法、函数)就如调用本地方法一致。

如图所示:

说明:

  • ServiceA 需要调用 ServiceB 的 FuncOnB 函数,对于 ServiceA 来说 FuncOnB 就是远程过程

  • RPC 的目的是让 ServiceA 可以像调用 ServiceA 本地的函数一样调用远程函数 FuncOnB,也就是 ServieA 上代码层面使用:serviceB.FuncOnB() 即可完成调用

  • RPC 是 C/S 模式,调用方为 Client,远程方为 Server

  • RPC 把整体的调用过程,数据打包、网络请求等,封装完毕,在 C、S 两端的 Stub 中。Stub(代码存根)

  • 调用流程如下

    1. ServiceA 将调回需求告知 Client Sub

    2. Client Sub 将调用目标(Call ID)、参数数据(params)等调用信息进行打包(序列化),并将打包好的调用信息通过网络传输给 Server Sub

    3. Server Sub 将根据调用信息,调用相应过程。期间涉及到数据的拆包(反序列化)等操作。

    4. 远程过程 FuncOnB 运行,并得到结果,将结果告知 Server Sub

    5. Server Sub 将结果打包,并传输回给 Client Sub

    6. Client Sub 将结果拆包,把最终函数调用的结果告知 ServiceA

以上就是典型 RPC 的流程。

RPC 协议没有对网络层做规范,那也就意味着具体的 RPC 实现可以基于 TCP,也可以基于其他协议,例如 HTTP,UDP 等。RPC 也没有对数据传输格式做规范,也就是逻辑层面,传输 JSON、Text、protobuf 都可以。这些都要看具体的 RPC 产品的实现。广泛使用的 RPC 产品有 gRPC,Thrift 等。

gRPC 介绍

gPRC 官网(https://grpc.io/)上的 Slogan 是:A high performance, open source universal RPC framework。就是:一个高性能、开源的通用 RPC 框架。

支持多数主流语言:C#、C++、Dart、Go、Java、Kotlin、Node、Objective-C、PHP、Python、Ruby。其中 Go 支持 Windows, Linux, Mac 上的 Go 1.13+ 版本。

gRPC 是一个 Google 开源的高性能远程过程调用 (RPC) 框架,可以在任何环境中运行。它可以通过对负载平衡、跟踪、健康检查和身份验证的可插拔支持有效地连接数据中心内和跨数据中心的服务。它也适用于分布式计算的最后一步,将设备、移动应用程序和浏览器与后端服务接。

在 gRPC 中,客户端应用程序可以直接调用不同机器上的服务器应用程序的方法,就像它是本地对象一样,使您更容易创建分布式应用程序和服务。与许多 RPC 系统一样,gRPC 基于定义服务的思想,指定可以远程调用的方法及其参数和返回类型。在服务端,服务端实现这个接口并运行一个 gRPC 服务器来处理客户端调用。在客户端,客户端有一个存根(在某些语言中仅称为客户端),它提供与服务器相同的方法。

技术上,gRPC 基于 HTTP/2 通信,采用 Protocol Buffers 作数据序列化。

准备 gRPC 环境

使用 gRPC 需要:

  • Go

  • Protocol Buffer 编译器,protoc,推荐版本3

  • Go Plugin,用于 Protocol Buffer 编译器

安装 protoc:

可以使用 yum 或 apt 包管理器安装,但通常版本会比较滞后。因此更建议使用预编译的二进制安装。

下载地址:

 https://github.com/protocolbuffers/protobuf/releases

基于系统和版本找到合适的二进制下载并安装。

CentOS 演示:

 # 下载特定版本,当前(2022年08月)最新 21.4$ curl -LO https://github.com/protocolbuffers/protobuf/releases/download/v21.4/protoc-21.4-linux-x86_64.zip# 解压到特定目录$ sudo unzip protoc-21.4-linux-x86_64.zip -d /usr/local# 如果特定目录中的bin不在环境变量 path 中,手动加入 path​# 测试安装结果,注意版本应该是 3.x$ protoc --versionlibprotoc 3.21.4

Win 演示,下载,解压到指定目录,在 CMD 中运行:

 # 解压到指定目录即可,要保证 protoc/bin 位于环境变量 path 中,可以随处调用> protoc.exe --versionlibprotoc 3.21.4​

安装 Go Plugin:

 # 下载特定版本,当前(2022年08月)最新 v1.28.1> go install google.golang.org/protobuf/cmd/protoc-gen-go@latest# 下载特定版本,当前(2022年08月)最新 v1.2.0> go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest# 安装完毕后,要保证 $GOPATH/bin 位于环境变量 path 中​# 测试安装结果> protoc-gen-go --versionprotoc-gen-go.exe v1.28.1> protoc-gen-go-grpc --versionprotoc-gen-go-grpc 1.2.0
Protocol Buffer 的基础使用

默认情况下,gRPC 使用 Protocol Buffers,这是 Google 用于序列化结构化数据的成熟开源机制(尽管它可以与 JSON 等其他数据格式一起使用)。

Protocol Buffers 的文档:https://developers.google.com/protocol-buffers/docs/overview

使用 Protocol Buffers 的基本步骤是:

  1. 使用 protocol buffers 语法定义消息,消息是用于传递的数据

  2. 使用 protocol buffers 语法定义服务,服务是 RPC 方法的集合,来使用消息

  3. 使用 Protocol Buffer编 译工具 protoc 来编译,生成对应语言的代码,例如 Go 的代码

使用 Protocol Buffers 的第一步是在 .proto 文件中定义序列化的数据的结构,.proto 文件是普通的文本文件。Protocol Buffers 数据被结构化为消息,其中每条消息都是一个小的信息逻辑记录,包含一系列称为字段的 name-value 对。

除了核心内容外,.proto 文件还需要指定语法版本,目前主流的也是最新的 proto3 版本。在 .proto 文件的开头指定。

一个简单的产品信息示例:

product.proto

 syntax = "proto3";​// 定义 Product 消息message Product {string name = 1;int64 id = 2;bool is_sale = 3;}

第二步是在 .proto 文件中定义 gRPC 服务,将 RPC 方法参数和返回类型指定为 Protocol Buffers 消息,继续编辑 product.proto :

 syntax = "proto3";​// 为了生成 go 代码,需要增加 go_package 属性,表示代码所在的包。protoc 会基于包构建目录option go_package = "./proto-codes";​// 定义 ProductInfo 消息message ProductInfoResponse {string name = 1;int64 int64 = 2;bool is_sale = 3;}​// rpc 方法 ProductInfo 需要的参数消息message ProductInfoRequest {int64 int64 = 1;}​// 定义 Product 服务service Product {// 获取产品信息rpc ProductInfo (ProductInfoRequest) returns (ProductInfoResponse) {}}

第三步是使用 protoc 工具将 .proto 定义的消息和包含 rpc 方法的服务编译为目标语言的代码,我们选择 Go 代码。

 $ protoc --go_out=. --go-grpc_out=. product.proto# --go_out *.pb.go 目录# --go-grpc_out *_grpc.pb.go 目录

其中:

  • *.pb.go 包含消息类型的定义和操作的相关代码

  • *_grpc.pb.go 包含客户端和服务端的相关代码

生成的代码主要是结构上的封装,在继续使用时,还需要继续充实业务逻辑。

基于 gRPC 的服务间通信示例

示例说明,存在两个服务,订单服务和产品服务。其中:

  • 订单服务提供 HTTP 接口,用于完成订单查询。订单中包含产品信息,要利用 grpc 从产品服务获取产品信息

  • 产品服务提供 grpc 接口,用于响应微服务内部产品信息查询

本例中,对于 grpc 来说,产品服务为服务端、订单服务为客户端。

同时不考虑其他业务逻辑,例如产品服务也需要对外提供 http 接口等,仅在乎 grpc 的通信示例。同时不考虑服务发现和网关等。

image.png

编码实现:

一:基于之前定义的 .proto 文件生成 pb.go 文件

注意,客户端和服务端,都需要使用生成的 pb.go 文件

二:实现订单服务

orderService/httpService.go

 package main​import ("context""encoding/json""flag""fmt""google.golang.org/grpc""google.golang.org/grpc/credentials/insecure""log""net/http""orderService/protos/codes""time")​var (// 目标 grpc 服务器地址gRPCAddr = flag.String("grpc", "localhost:50051", "the address to connect to")// http 命令行参数addr = flag.String("addr", "127.0.0.1", "The Address for listen. Default is 127.0.0.1")port = flag.Int("port", 8080, "The Port for listen. Default is 8080."))​func main() {flag.Parse()// 连接 grpc 服务器conn, err := grpc.Dial(*gRPCAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))if err != nil {log.Fatalf("did not connect: %v", err)}defer conn.Close()// 实例化 grpc 客户端c := codes.NewProductClient(conn)​// 定义业务逻辑服务,假设为产品服务service := http.NewServeMux()service.HandleFunc("/orders", func(writer http.ResponseWriter, request *http.Request) {// 调用 grpc 方法,完成对服务器资源请求ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()r, err := c.ProductInfo(ctx, &codes.ProductInfoRequest{Int64: 42,})if err != nil {log.Fatalln(err)}​resp := struct {ID       int                          `json:"id"`Quantity int                          `json:"quantity"`Products []*codes.ProductInfoResponse `json:"products"`}{9527, 1,[]*codes.ProductInfoResponse{r,},}respJson, err := json.Marshal(resp)if err != nil {log.Fatalln(err)}writer.Header().Set("Content-Type", "application/json")_, err = fmt.Fprintf(writer, "%s", string(respJson))if err != nil {log.Fatalln(err)}})​// 启动监听address := fmt.Sprintf("%s:%d", *addr, *port)fmt.Printf("Order service is listening on %s.\n", address)log.Fatalln(http.ListenAndServe(address, service))}

三,实现产品服务

productService/grpcService.go

package mainimport ("context""flag""fmt""google.golang.org/grpc""log""net""productService/protos/compiles"
)//grpc 监听端口
var port = flag.Int("port", 50051, "The server port")// ProductServer 实现 UnimplementedProductServer
type ProductServer struct {compiles.UnimplementedProductServer
}func (ProductServer) ProductInfo(ctx context.Context, pr *compiles.ProductInfoRequest) (*compiles.ProductInfoResponse, error) {return &compiles.ProductInfoResponse{Name:   "马士兵 Go 云原生",Int64:  42,IsSale: true,}, nil
}func main() {flag.Parse()//设置 tcp 监听器lis, err := net.Listen("tcp", fmt.Sprintf(":%d", *port))if err != nil {log.Fatalf("failed to listen: %v", err)}// 新建 grpc Servers := grpc.NewServer()// 将 ProductServer 注册到 grpc Server 中compiles.RegisterProductServer(s, ProductServer{})log.Printf("server listening at %v", lis.Addr())// 启动监听if err := s.Serve(lis); err != nil {log.Fatalf("failed to serve: %v", err)}
}

测试,访问 order 的 http 接口。获取订单信息中,包含产品信息。

gRPC 核心概念

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • 前端路由History 和 Hash模式的区别以及Vue项目打包后显示白屏,路由router-view不加载问题
  • C语言之指针的奥秘(三)
  • 【python】OpenCV—Scanner
  • vue使用x6画流程图,简单使用
  • 鸿蒙语言基础类库:【@system.request (上传下载)】
  • 分布式搜索引擎ES-Elasticsearch进阶
  • Python酷库之旅-第三方库Pandas(032)
  • 食堂采购系统开发:从需求分析到上线实施的完整指南
  • npm install时报错 reason: connect ETIMEDOUT
  • 网络安全-等级保护制度介绍
  • 使用AJAX发起一个异步请求,从【api_endpoint】获取数据,并在成功时更新页面上的【target_element】
  • 详细分析Java中的6种请求方式(附Demo)
  • WPF TreeView 全选/反选/子级选中父级也选中
  • 降低芯片流片风险的几种方法
  • 算法第十天:leetcode203.移除链表元素
  • 【剑指offer】让抽象问题具体化
  • create-react-app做的留言板
  • IE报vuex requires a Promise polyfill in this browser问题解决
  • input实现文字超出省略号功能
  • Intervention/image 图片处理扩展包的安装和使用
  • iOS筛选菜单、分段选择器、导航栏、悬浮窗、转场动画、启动视频等源码
  • Javascript弹出层-初探
  • java中具有继承关系的类及其对象初始化顺序
  • JS变量作用域
  • Just for fun——迅速写完快速排序
  • Meteor的表单提交:Form
  • nodejs实现webservice问题总结
  • Otto开发初探——微服务依赖管理新利器
  • spring boot 整合mybatis 无法输出sql的问题
  • spring cloud gateway 源码解析(4)跨域问题处理
  • webpack项目中使用grunt监听文件变动自动打包编译
  • 如何在 Tornado 中实现 Middleware
  • 源码之下无秘密 ── 做最好的 Netty 源码分析教程
  • 看到一个关于网页设计的文章分享过来!大家看看!
  • kubernetes资源对象--ingress
  • ​Redis 实现计数器和限速器的
  • !$boo在php中什么意思,php前戏
  • #Datawhale AI夏令营第4期#AIGC文生图方向复盘
  • #多叉树深度遍历_结合深度学习的视频编码方法--帧内预测
  • #我与Java虚拟机的故事#连载03:面试过的百度,滴滴,快手都问了这些问题
  • (1)(1.13) SiK无线电高级配置(五)
  • (160)时序收敛--->(10)时序收敛十
  • (2)(2.10) LTM telemetry
  • (k8s)Kubernetes本地存储接入
  • (搬运以学习)flask 上下文的实现
  • (不用互三)AI绘画工具应该如何选择
  • (二十九)STL map容器(映射)与STL pair容器(值对)
  • (附源码)ssm考试题库管理系统 毕业设计 069043
  • (附源码)计算机毕业设计SSM教师教学质量评价系统
  • (每日一问)操作系统:常见的 Linux 指令详解
  • (免费分享)基于springboot,vue疗养中心管理系统
  • (最优化理论与方法)第二章最优化所需基础知识-第三节:重要凸集举例
  • .\OBJ\test1.axf: Error: L6230W: Ignoring --entry command. Cannot find argumen 'Reset_Handler'
  • .NET COER+CONSUL微服务项目在CENTOS环境下的部署实践
  • .NET Core IdentityServer4实战-开篇介绍与规划