go获取项目内所有proto_gRPC学习之三:初试GO版gRPC开发

欢迎访问我的GitHub

https://github.com/zq2599/blog_demos

内容:所有原创文章分类和汇总,及配套源码,涉及Java、Docker、Kubernetes、DevOPS等;

本篇概览

  • 本文《gRPC学习》系列的第三篇,前文已准备好gRPC开发环境,今天一起来开发一个服务端应用以及远程gRPC调用它的客户端;
  • 今天实战的内容和步骤如下图所示:
3764fa18634e16857e647ac32d21a89c.png

源码下载

  • 如果您不想编码,可以在GitHub下载所有源码,地址和链接信息如下表所示:
35676691b2a21badd69ac855da24234a.png
  • 这个git项目中有多个文件夹,本章的应用在go-source文件夹下,如下图红框所示:
bc9892f127067d9c52082d721c4fc57c.png
  • go-source里面有多个子文件夹,本篇的源码在helloworld中,如下图红框:
fd7856a82340758626ddf287c747d2e9.png

环境相关

  • 接下来的开发都是在$GOPATH目录下进行的,我这里的真实目录是/home/golang/gopath;
  • 在/home/golang/gopath/src目录下新建helloworld目录,作为接下来的实战用到的目录;
  • 在完成本篇的所有开发后,最终$GOPATH/src/helloworld目录下的内容如下:
[golang@centos7 src]$ tree helloworld/helloworld/├── client│   └── client.go├── helloworld.pb.go├── helloworld.proto└── server    └── server.go2 directories, 4 files

编写proto文件

  • proto文件用来描述远程服务相关的信息,如方法签名、数据结构等,本篇的proto文件名为helloworld.proto,位置是$GOPATH/src/helloworld,内容如下:
// 协议类型syntax = "proto3";// 包名package helloworld;// 定义的服务名service Greeter {  // 具体的远程服务方法  rpc SayHello (HelloRequest) returns (HelloReply) {}}// SayHello方法的入参,只有一个字符串字段message HelloRequest {  string name = 1;}// SayHello方法的返回值,只有一个字符串字段message HelloReply {  string message = 1;}

根据proto生成go源码

  1. 在helloworld.proto所在的目录,执行以下命令:
protoc --go_out=plugins=grpc:. helloworld.proto
  1. 如果helloworld.proto没有语法错误,会在当前目录生成文件helloworld.pb.go,这里面是工具protoc-gen-go自动生成的代码,里面生成的代码在开发服务端和客户端时都会用到;
  2. 下面是helloworld.pb.go的代码片段,作用是服务注册,入参是GreeterServer是个接口,由此可以推测:在服务端,由具体的业务代码来实现GreeterServer接口,并且调用RegisterGreeterServer方法注册,这样客户端远程调用的服务就可以实现业务功能了:
func RegisterGreeterServer(s *grpc.Server, srv GreeterServer) {s.RegisterService(&_Greeter_serviceDesc, srv)}type GreeterServer interface {// 具体的远程服务方法SayHello(context.Context, *HelloRequest) (*HelloReply, error)}
  1. 借助GoLand的Structure面板,可以进一步观察helloworld.pb.go:
f4b80e47e984cf0d76e133cbe2f6c772.png

编写服务端代码server.go并启动

  1. 在$GOPATH/src/helloworld目录下新建文件夹server,在此文件夹下新建server.go,内容如下,已经添加详细注释:
package mainimport ("context""log""net""google.golang.org/grpc"pb "helloworld")const (port = ":50051")// 定义结构体,在调用注册api的时候作为入参,// 该结构体会带上SayHello方法,里面是业务代码// 这样远程调用时就执行了业务代码了type server struct {// pb.go中自动生成的,是个空结构体pb.UnimplementedGreeterServer}// 业务代码在此写,客户端远程调用SayHello时,// 会执行这里的代码func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {// 打印请求参数log.Printf("Received: %v", in.GetName())// 实例化结构体HelloReply,作为返回值return &pb.HelloReply{Message: "Hello " + in.GetName()}, nil}func main() {// 要监听的协议和端口lis, err := net.Listen("tcp", port)if err != nil {log.Fatalf("failed to listen: %v", err)}// 实例化gRPC server结构体s := grpc.NewServer()// 服务注册pb.RegisterGreeterServer(s, &server{})log.Println("开始监听,等待远程调用...")if err := s.Serve(lis); err != nil {log.Fatalf("failed to serve: %v", err)}}
  1. 在server.go所在目录执行go run server.go即可启动服务,控制台提示如下:
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 开始监听,等待远程调用...
  1. 此时gRPC的服务端已经启动,可以响应远程调用,接下来开发客户端代码;

编写客户端代码client.go并启动

  1. 再打开一个控制台;
  2. 在$GOPATH/src/helloworld目录下新建文件夹client,在此文件夹下新建client.go,内容如下,已经添加详细注释:
package mainimport ("context""log""os""time""google.golang.org/grpc"pb "helloworld")const (address     = "localhost:50051"defaultName = "world")func main() {// 远程连接服务端conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())if err != nil {log.Fatalf("did not connect: %v", err)}// main方法执行完毕后关闭远程连接defer conn.Close()// 实例化数据结构c := pb.NewGreeterClient(conn)// 远程调用的请求参数,如果没有从命令行传入,就用默认值name := defaultNameif len(os.Args) > 1 {name = os.Args[1]}// 超时设置ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()// 远程调用r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})if err != nil {log.Fatalf("could not greet: %v", err)}// 将服务端的返回信息打印出来log.Printf("Greeting: %s", r.GetMessage())}
  1. 在client.go所在目录执行go run client.go,会立即向服务端发起远程调用,控制台提示如下,可见得到了服务端的返回信息Hello world:
[golang@centos7 client]$ go run client.go2020/12/13 08:38:05 Greeting: Hello world
  1. 再去服务端的控制台看一下,通过日志发现业务代码被执行,收到了远程请求的参数:
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 开始监听,等待远程调用...2020/12/13 08:38:05 Received: world
  1. 回到客户端控制台,在命令行带参数试试,输入go run client.go abc,收到服务端响应如下:
[golang@centos7 client]$ go run client.go abc2020/12/13 08:56:36 Greeting: Hello abc
  1. 再去服务端的控制台看一下,成功收到了abc:
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 开始监听,等待远程调用...2020/12/13 08:38:05 Received: world2020/12/13 08:56:36 Received: abc
  • 至此,一次常规的gRPC开发实战就完成了,希望能给您一些参考,接下来的文章咱们会继续深入学习gRPC;

欢迎关注我的公众号:程序员欣宸

44d579b85d0d1f72518a66b4b4afaa3c.png

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

服务端架构中的“网关服务器”

这么一个场景:一个要承载高并发、具有高性能的后台服务,往往会有多个不同的应用服务。问题来了,你会怎样设计架构呢?如下图所示,为了共用一个稳定高效的网络处理功能,把所有服务写在一个进程里。接下来悲剧…

一起来庆祝 .NET 20 周年!

你知道吗?.NET 将要迎来 20 周年, 在 20 年前的 2002 年, 微软公布了下一代的软件、服务的愿景和路线,2 月 13 日,Visual Studio .NET 推出,.NET 开发平台的第一个版本正式向世界发布。而现在, .NET 6 成为统一的开发平台&#xf…

Python pip 国内镜像大全及使用办法

最近写了一篇关于“微软开源分布式高性能GB框架LightGBM安装使用”的文章,有小伙伴安装python环境遇到了问题。我个人也尝试安装了一下,确实遇到了很多问题。最关键的一个就是使用pip安装时,“https://pypi.python.org/simple/scipy/”访问不…

linux c之c语言符合标准的头文件和linux常用头文件

1.C语言符合标准的头文件 #include <assert.h> //设定插入点 #include <ctype.h> //字符处理 #include <errno.h> //定义错误码 #include <float.h> //浮点数处理 #include <fstream.h> //文件输入&#xff0f;输出 #include <iomanip.h…

为什么一点onclick按钮就提交表单?

下面是一个表单&#xff0c;有一个onclick按钮&#xff0c;点击后上面文本框的内容被添加到下面的文本域中&#xff0c;并可以一直添加&#xff0c;然后点击submit后提交到另一个页面。但是&#xff0c;在Ie9或者火狐浏览器中我一点onclick为什么总是提交表单&#xff0c;在搜狗…

不固定图片宽高瀑布流_APP设计学习:瀑布流式的产品UI设计

看到好的APP产品UI设计&#xff0c;真是忍不住想要停留几秒&#xff0c;慢慢来欣赏。今天学堂君收集了近期不错的优质的APP设计作品&#xff0c;看起来极舒服的UI界面&#xff0c;分享给大家。这一期的重点学习&#xff1a;在APP界面设计当中&#xff0c;如何应用瀑布流式的布局…

虚拟现实大潮渐近:Oculus VR、EA和Avegant等多家公司...

虚拟现实不是新词&#xff0c;上世纪的许多科幻小说中就描述过未来虚拟现实技术高度发达后的世界&#xff0c;但是这两年&#xff0c;虚拟现实真正在商业市场有了新的突破&#xff0c;代表者就是Oculus VR。近日&#xff0c;一众在虚拟现实领域有所建树的公司结成了“沉浸式技术…

【Blog.Core开源】网关自定义认证鉴权与传参

书接上文&#xff0c;上回咱们说到了《【Blog.Core开源】网关统一集成下游服务文档》&#xff0c;已经将多个下游服务统一集成到了网关里&#xff0c;并且也把接口文档Swagger给集成了&#xff0c;那今天就说一下认证和鉴权相关的话题。继续说下故事背景在平时开发的时候&#…

linux网络编程之inet_pton和inet_ntop函数

Linux下这2个IP地址转换函数,可以在将IP地址在“点分十进制”和“整数”之间转换 而且,inet_pton和inet_ntop这2个函数能够处理ipv4和ipv6。算是比较新的函数了。 1、inet_pton函数原型如下[将“点分十进制” -> “整数”] #include <sys/types.h>#include <sys…

私活利器,docker快速部署node.js应用

http://cnodejs.org/topic/53f494d9bbdaa79d519c9a4a 最近研究了几天docker的快速部署&#xff0c;感觉很有新意&#xff0c;非常轻量级和方便&#xff0c;打算在公司推广一下&#xff0c;解放运维&#xff0c;省得每次部署一台新服务器都去跑安装脚本了&#xff0c;对于我们开…

HDFS HA与QJM(Quorum Journal Manager)介绍及官网内容整理

问题导读1.HDFS HA与QJM解决了什么问题&#xff1f; 2.HDFS HA与QJM区别是什么&#xff1f; 3.在HA&#xff08;两个namenode&#xff09;架构下&#xff0c;如何访问hdfs文件&#xff1f;【使用QJM构建HDFS HA架构(2.2)】本文主要介绍HDFS HA特性&#xff0c;以及如何使用QJM(…

#时间预测算法_【时间序列】时序预测竞赛之异常检测算法综述

本文将介绍在时间序列预测相关问题中常见的异常检测算法&#xff0c;可以很大程度上帮助改善最终预测效果。异常分类时间序列的异常检测问题通常表示为相对于某些标准信号或常见信号的离群点。虽然有很多的异常类型&#xff0c;但是我们只关注业务角度中最重要的类型&#xff0…

监测利器cacti服务安装

1、Cacti原理及概述1Cacti是一款使用PHP语言开发的性能与流量监测工具。监测的对象可以是linux也可以是windows也可以是路由器交换机等网络设备主要基于SNMPsimple network managerprotocol简单网络管理协议来搜集cpu占用内存使用运行进程数磁盘空间网卡流量等各种网络数据。2实…

linux c之解决array subscript is not integer和AF_NET not undeclared

1、array subscript is not integer 我一开始写的代码是这样的写的 buf[strlen[buf] - 1] \0; 很明显写错了&#xff0c;以后不要再犯这样的错误了&#xff0c;切记 buf[strlen(buf) - 1] \0; 2、AF_NET not undeclared 这是我写的代码 inet.pton(AF_NET, buf 6, &add…

C#中的类型转换

前几篇文章中经常说到强制类型转换&#xff0c;就是可以将派生类对象强制转换为基类对象的做法或者通过as运算符进行的转换。今天我们就来一起简单了解复习下在C#中都有哪些类型的转换。要理解转换很容易&#xff0c;日常的开发编码过程中&#xff0c;由于变量类型的不同我们可…

Excel 用于批量把单元格设置为文本格式保存的数字的宏

首先把所有的数字录入&#xff08;或者导出为&#xff09;井号数字的格式&#xff0c;比如“#3333333323424234234234”&#xff0c;然后运行下面的宏&#xff1a; Sub Num2Text()If Not TypeOf Application.Selection Is Range ThenMsgBox "You must select cells!"…

ACM题解系列之一:刘汝佳:《算法竞赛入门经典》(第2版)

题是书中的题&#xff0c;解法参照了书中的解法&#xff0c;不少解法都做了简化和改进。 做程序&#xff0c;就要努力做到自己的程序是最好的&#xff01; 第3章例题 POJ1488 UVA272 UVALive5381 TEX Quote【输入输出】 POJ2538 ZOJ1884 UVA10082 WERTYU【输入输出】 HDU1318 P…

linux之快速过滤文本的关键字以及快速过滤目录下的关键字

1、快速过过滤文本的关键字 cat file | grep 关键字 比如Android日志文件很长&#xff0c;需要过滤Exception,就可以用这个办法&#xff0c;如下图 2、快速过滤目录下的关键字 grep -r 关键字 比如我们在linux上看目录下哪些关键字段&#xff0c;好像开发工具里面的 find usag…

hadoop使用

2019独角兽企业重金招聘Python工程师标准>>> 框架简介 Hadoop使用主/从&#xff08;Master/Slave&#xff09;架构&#xff0c;主要角色有NameNode&#xff0c;DataNode&#xff0c;secondary NameNode&#xff0c;JobTracker&#xff0c;TaskTracker组成。 其中Nam…

bigint hive java类型_详解Apache Hudi如何配置各种类型分区

1. 引入Apache Hudi支持多种分区方式数据集&#xff0c;如多级分区、单分区、时间日期分区、无分区数据集等&#xff0c;用户可根据实际需求选择合适的分区方式&#xff0c;下面来详细了解Hudi如何配置何种类型分区。2. 分区处理为说明Hudi对不同分区类型的处理&#xff0c;假定…