Go网络编程-RPC程序设计

news2024/9/20 9:38:03

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 --version
 libprotoc 3.21.4

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

 # 解压到指定目录即可，要保证 protoc/bin 位于环境变量 path 中，可以随处调用
 > protoc.exe --version
 libprotoc 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 --version
 protoc-gen-go.exe v1.28.1
 > protoc-gen-go-grpc --version
 protoc-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 main

import (
	"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 Server
	s := 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 核心概念

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1935013.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

将iPad 作为Windows电脑副屏的几种方法（二）

将iPad 作为Windows电脑副屏的几种方法（二）

将iPad 作为Windows电脑副屏的几种方法（二） 1. 前言2. EV 扩展屏2.1 概述2.2 下载、安装、连接教程2.3 遇到的问题和解决方法2.3.1 平板连接不上电脑 3. Twomon SE3.1 概述3.2 下载安装教程 4. 多屏中心（GlideX）4.1 概述4.2 下载安…
阅读更多...
均值滤波算法及实现

均值滤波算法及实现

均值滤波器的使用场景： 均值滤波器使用于处理一些如上述蓝色线的高斯噪声场景 红色曲线是经过均值滤波处理后的数据。主要因为均值滤波设置数据缓冲区（也即延时周期），使得测量值经过缓冲不会出现特别大的变化。 黄色曲线为高斯噪声…
阅读更多...
[003-02-10].第10节：Docker环境下搭建Redis主从复制架构

[003-02-10].第10节：Docker环境下搭建Redis主从复制架构

我的博客大纲 我的后端学习大纲 我的Redis学习大纲 1.cluster（集群）模式-docker版 哈希槽分区进行亿级数据存储 1.1.面试题：1~2亿条数据需要缓存，请问如何设计这个存储案例 1.回答：单机单台100%不可能，肯…
阅读更多...
第十届能源材料与电力工程国际学术会议（ICEMEE 2024)

第十届能源材料与电力工程国际学术会议（ICEMEE 2024)

第十届能源材料与电力工程国际学术会议（ICEMEE 2024) 2024 10th International Conference on Energy Materials and Electrical Engineering 重要信息 ICEMEE 2024已通过SPIE - The International Society for Optical Engineering (ISSN: 0277-786X)单独出版…
阅读更多...
beego框架_golang web框架_使用介绍

beego框架_golang web框架_使用介绍

beego简介 beego是一个用于快速开发Go应用的http框架，由Go语言方面的技术大牛设计。beego可以用来快速开发API、Web、后端服务等各种应用，是一个RESTful的框架，主要设计灵感来源于tornado、sinatra、flask这三个框架，但结合了Go本…
阅读更多...
Postfix+Dovecot+Roundcube开源邮件系统搭建系列5：Roundcube安装配置（含Nginx+PHP部署配置）

Postfix+Dovecot+Roundcube开源邮件系统搭建系列5：Roundcube安装配置（含Nginx+PHP部署配置）

1. PHP安装配置 参考wordpress 6.5.2版本安装记录 中关于PHP安装方法，此处不再详述。 修改php-fpm的启动用户和组为vmail，这一步是和nginx配置相呼应。配置文件/etc/opt/remi/php83/php-fpm.d/www.conf 下面几个配置： user vmail group vm…
阅读更多...
Typora 1.5.8 版本安装下载教程 (轻量级 Markdown 编辑器)，图文步骤详解，免费领取

Typora 1.5.8 版本安装下载教程 (轻量级 Markdown 编辑器)，图文步骤详解，免费领取

文章目录 软件介绍软件下载安装步骤激活步骤 软件介绍 Typora是一款基于Markdown语法的轻量级文本编辑器，它的主要目标是为用户提供一个简洁、高效的写作环境。以下是Typora的一些主要特点和功能： 实时预览：Typora支持实时预览功能&#xff0…
阅读更多...
CrossKD: Cross-Head Knowledge Distillation for Dense Object Detection

CrossKD: Cross-Head Knowledge Distillation for Dense Object Detection

CrossKD：用于密集目标检测的交叉头知识蒸馏 论文链接：https://arxiv.org/abs/2306.11369v2 项目链接：https://github.com/jbwang1997/CrossKD Abstract 知识蒸馏(Knowledge Distillation, KD)是一种有效的学习紧凑目标检测器的模型压缩技术…
阅读更多...
微服务:nacos

微服务:nacos

Nacos 由Alibaba推出的集成于SpringCloudAlibaba中的一款开源注册中心框架 主要功能: 注册中心 配置管理 nacos的安装和部署 nacos默认访问端口8848 docker pull nacos/nacos-server:1.2.0 docker run --env MODEstandalone --name nacos --restartalways -d -p 8848:8…
阅读更多...
模型训练中出现loss为NaN怎么办？

模型训练中出现loss为NaN怎么办？

文章目录 一、模型训练中出现loss为NaN原因1. 学习率过高2. 梯度消失或爆炸3. 数据不平衡或异常4. 模型不稳定5. 过拟合 二、 针对梯度消失或爆炸的解决方案1. 使用torch.autograd.detect_anomaly()2. 使用 torchviz 可视化计算图3. 检查梯度的数值范围4. 调整梯度剪裁 三、更具…
阅读更多...
鸿蒙语言基础类库：【@system.request (上传下载)】

鸿蒙语言基础类库：【@system.request (上传下载)】

上传下载 说明： 从API Version 6开始，该接口不再维护，推荐使用新接口[ohos.request]。本模块首批接口从API version 4开始支持。后续版本的新增接口，采用上角标单独标记接口的起始版本。 导入模块 import request from system.re…
阅读更多...
C语言之指针的奥秘（三）

C语言之指针的奥秘（三）

一、字符指针变量 在指针的类型中&#xff0c;有字符指针char*&#xff0c;一般使用&#xff1a; #include<stdio.h> int main() {char ch w;char* p &ch;*p w;return 0; } 还有一种方式&#xff1a; #include<stdio.h> int main() {const char* p &qu…
阅读更多...
Android 10.0 Launcher3拖拽图标进入hotseat自适应布局功能实现一

Android 10.0 Launcher3拖拽图标进入hotseat自适应布局功能实现一

1.前言 在10.0的系统rom定制化开发中&#xff0c;在对于launcher3的一些开发定制中&#xff0c;在对hotseat的一些开发中&#xff0c;需要实现动态hotseat居中 的功能&#xff0c;就是在拖拽图标进入和拖出hotseat&#xff0c;都可以保持hotseat居中的功能&#xff0c;接下来分…
阅读更多...
html2canvas + jspdf 纯前端HTML导出PDF的实现与问题

html2canvas + jspdf 纯前端HTML导出PDF的实现与问题

前言 这几天接到一个需求&#xff0c;富文本编辑器的内容不仅要展示出来&#xff0c;还要实现展示的内容导出pdf文件。一开始导出pdf的功能是由后端来做的&#xff0c;然后发现对于宽度太大的图片&#xff0c;导出的pdf文件里部分图片内容被遮盖了&#xff0c;但在前端是正常显…
阅读更多...
S参数入门

S参数入门

一、说明 S参数全称为散射参数&#xff0c;主要用来作为描述线性无源互联结构的一种行为模型&#xff0c;来源于网络分析方法。网络分析法是一种频域方法&#xff0c;在一组离散的频率点上&#xff0c;通过在输入和输出端口得到的参量完全描述线性时不变系统&#xff08;定义参…
阅读更多...
园区AR导航系统构建详解：从三维地图构建到AR融合导航的实现

园区AR导航系统构建详解：从三维地图构建到AR融合导航的实现

随着现代园区规模的不断扩大与功能的日益复杂&#xff0c;传统的二维地图导航已难以满足访客高效、精准定位的需求。园区内部错综复杂的布局、频繁变更的商户位置常常让访客感到迷茫&#xff0c;造成寻路上的时间浪费。园区AR导航系统以创新的技术手段&#xff0c;破解了私域地…
阅读更多...
对redis进行深入学习

对redis进行深入学习

目录 1. 什么是redis&#xff1f;1.1 为什么使用redis作为缓存&#xff1f;1.1.0 数据库&#xff08;MySQL&#xff09;与 redis1. 存储介质不同&#xff08;408选手应该都懂hh&#xff09;2. 数据结构优化3. I/O模型差异4. CPU缓存友好性5. 单线程与多线程差异6. 持久化与缓存…
阅读更多...
Volatility:分析MS10-061攻击

Volatility:分析MS10-061攻击

1、概述 # 1&#xff09;什么是 Volatility Volatility是开源的Windows&#xff0c;Linux&#xff0c;MaC&#xff0c;Android的内存取证分析工具。基于Python开发而成&#xff0c;可以分析内存中的各种数据。Volatility支持对32位或64位Wnidows、Linux、Mac、Android操作系统…
阅读更多...
2024算力基础设施安全架构设计与思考（免费下载）

2024算力基础设施安全架构设计与思考（免费下载）

算网安全体系是将数据中心集群、算力枢纽、一体化大数据中心三个层级的安全需求进行工程化解耦&#xff0c;从国家安全角度统筹设计&#xff0c;通过安全 服务化方式&#xff0c;依托威胁情报和指挥协同通道将三层四级安全体系串联贯通&#xff0c;达成一体化大数据安全目标。 …
阅读更多...
插画插件：成都亚恒丰创教育科技有限公司

插画插件：成都亚恒丰创教育科技有限公司

【插画插件&#xff1a;数字创意时代的艺术加速器】 在数字化浪潮汹涌的今天&#xff0c;视觉艺术以其独特的魅力穿梭于互联网的每一个角落&#xff0c;成为连接人心、传递情感与信息的桥梁。而在这股创意洪流中&#xff0c;插画插件以其高效、便捷、个性化的特点&#xff0c;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023