Go语言初探gRPC服务
原文链接:https://www.jianshu.com/p/20ed82218163
环境:2018-05-12 protoc 3.5.1 go1.10.1 windows
gRPC: Google主导开发的RPC框架,这里不再赘述。
准备工作
先安装Protobuf 编译器 protoc,下载地址:https://github.com/google/protobuf/releases
我的是windows,将压缩包bin目录下的exe放到环境PATH目录中即可。
然后获取插件支持库
// gRPC运行时接口编解码支持库go get -u github.com/golang/protobuf/proto// 从 Proto文件(gRPC接口描述文件) 生成 go文件 的编译器插件go get -u github.com/golang/protobuf/protoc-gen-go
获取go的gRPC包(网络问题可参阅https://www.jianshu.com/p/6392cb9dc38f)
go get google.golang.org/grpc
接口文件 /src/
新建test.proto
示例:
syntax = "proto3";// 定义包名package test;// 可以定义多个服务,每个服务内可以定义多个接口service Waiter {// 定义接口 (结构体可以复用)// 方法 (请求消息结构体) returns (返回消息结构体) {}rpc DoMD5 (Req) returns (Res) {}}// 定义 Req 消息结构message Req {// 类型 字段 = 标识号string jsonStr = 1;}// 定义 Res 消息结构message Res {string backJson = 1;}
// PS:jsonStr和backJson只是随手写的名字,并没有用json
proto文件语法详解参阅:https://blog.csdn.net/u014308482/article/details/52958148
然后将proto文件编译为go文件
// protoc --go_out=plugins=grpc:{输出目录} {proto文件}protoc --go_out=plugins=grpc:./test/ ./test.proto
注意:原则上不要修改编译出来的*.bp.go
文件的代码,因为双方接口基于同一个proto文件编译成自己的语言源码,此文件只作为接口数据处理,业务具体实现不在*.bp.go
中。
服务端 /src/server/
本人也是刚接触Go,基于https://github.com/freewebsys/grpc-go-demo的Demo在修改中理解gRPC
其中中文注释均为个人理解笔记,若有不严谨的地方,还望指正。
package mainimport ("log""net""golang.org/x/net/context""google.golang.org/grpc""test""google.golang.org/grpc/reflection""fmt""crypto/md5")// 业务实现方法的容器type server struct{}// 为server定义 DoMD5 方法 内部处理请求并返回结果// 参数 (context.Context[固定], *test.Req[相应接口定义的请求参数])// 返回 (*test.Res[相应接口定义的返回参数,必须用指针], error)func (s *server) DoMD5(ctx context.Context, in *test.Req) (*test.Res, error) {fmt.Println("MD5方法请求JSON:"+in.JsonStr)return &test.Res{BackJson: "MD5 :" + fmt.Sprintf("%x", md5.Sum([]byte(in.JsonStr)))}, nil}func main() {lis, err := net.Listen("tcp", ":8028") //监听所有网卡8028端口的TCP连接if err != nil {log.Fatalf("监听失败: %v", err)}s := grpc.NewServer() //创建gRPC服务/**注册接口服务* 以定义proto时的service为单位注册,服务中可以有多个方法* (proto编译时会为每个service生成Register***Server方法)* 包.注册服务方法(gRpc服务实例,包含接口方法的结构体[指针])*/test.RegisterWaiterServer(s, &server{})/**如果有可以注册多个接口服务,结构体要实现对应的接口方法* user.RegisterLoginServer(s, &server{})* minMovie.RegisterFbiServer(s, &server{})*/// 在gRPC服务器上注册反射服务reflection.Register(s)// 将监听交给gRPC服务处理err = s.Serve(lis)if err != nil {log.Fatalf("failed to serve: %v", err)}}
客户端 /src/client/
package mainimport ("log""os""golang.org/x/net/context""google.golang.org/grpc""test")func main() {// 建立连接到gRPC服务conn, err := grpc.Dial("127.0.0.1:8028", grpc.WithInsecure())if err != nil {log.Fatalf("did not connect: %v", err)}// 函数结束时关闭连接defer conn.Close()// 创建Waiter服务的客户端t := test.NewWaiterClient(conn)// 模拟请求数据res := "test123"// os.Args[1] 为用户执行输入的参数 如:go run ***.go 123if len(os.Args) > 1 {res = os.Args[1]}// 调用gRPC接口tr, err := t.DoMD5(context.Background(), &test.Req{JsonStr: res})if err != nil {log.Fatalf("could not greet: %v", err)}log.Printf("服务端响应: %s", tr.BackJson)}
启动服务端监听,运行客户端即可达成远程调用
Go语言初探gRPC服务相关推荐
- spring boot 配置网关时404错误_Kong中使用grpcweb插件代理grpc服务时遇到的坑
在大型分布式系统中,有很多的微服务对外提供服务,也会有各种微服务的协议需要集成,比如http,https,grpc的,这时就需要一个API网关提供高性能.高可用的API托管服务,帮助服务的开发者便捷地 ...
- 使用Golang搭建gRPC服务提供给.NetCore客户端调用
gRPC概述 RPC 说到gRPC就不得不提RPC,所谓RPC(remote procedure call 远程过程调用)框架实际是提供了一套机制,使得应用程序之间可以进行通信,简单点来说就是我A机器 ...
- 如何在.NET Core中为gRPC服务设计消息文件(Proto)
如何在.NET Core中为gRPC服务设计消息 使用协议缓冲区规范定义gRPC服务非常容易,但从需求转换为.NET Core,然后管理服务的演变时,需要注意几件事. 创建gRPC服务的核心是.pro ...
- .NET Core 3.0中用 Code-First 方式创建 gRPC 服务与客户端
.NET Core ❤ gRPC 千呼万唤的 .NET Core 3.0 终于在 9 月份正式发布,在它的众多新特性中,除了性能得到了大大提高,比较受关注的应该是 ASP.NET Core 3.0 对 ...
- 聊聊 Docker Swarm 部署 gRPC 服务的坑
gRPC 是一个高性能.开源和通用的 RPC 框架,面向移动和 HTTP/2 设计,也是目前流行的微服务架构中比较突出的跨语言 RPC 框架. 一直以来,我们的微服务都是基于 gRPC 来开发,使用的 ...
- ASP.NET Core 3.0 上的gRPC服务模板初体验(多图)
早就听说ASP.NET Core 3.0中引入了gRPC的服务模板,正好趁着家里电脑刚做了新系统,然后装了VS2019的功夫来体验一把.同时记录体验的过程.如果你也想按照本文的步骤体验的话,那你得先安 ...
- 基于gRPC服务发现与服务治理的方案
重温最少化集群搭建,我相信很多朋友都已经搭建出来,基于Watch机制也实现了出来,相信也有很多朋友有了自己的实现思路,但是,很多朋友有个疑问,我API和服务分离好了,怎么通过服务中心进行发现呢,这个过 ...
- assembly 输出ab中所有数_.NET Core中批量注入Grpc服务
(给DotNet加星标,提升.Net技能) 转自:张子浩cnblogs.com/ZaraNet/p/12167517.html GRPC 是谷歌发布的一个开源.高性能.通用RPC服务,尽管大部分 RP ...
- 用Golang构建gRPC服务
本教程提供了Go使用gRPC的基础教程 在教程中你将会学到如何: 在.proto文件中定义一个服务. 使用protocol buffer编译器生成客户端和服务端代码. 使用gRPC的Go API为你的 ...
最新文章
- 过去的一年,我在读研
- 多种冒泡算法时间和效率比较
- (百度云服务器的)域名不加www可以访问,添加就不能访问 (添加域名绑定)- 解决篇
- html+input改变图标,JS Input里添加小图标的两种方法
- vuejs切换导航条高亮路由高亮做法
- c#二叉树 取叶子节点个数_「leetcode」222.完全二叉树的节点个数
- qt的opengl开发(qopenglwidget)(初始化,画线,平移,局部缩放)2d开发
- ISO/IEC 27701:2019(隐私信息安全管理扩展要求和指南)解读(一)
- qt 两界面类操作另外一个界面的的ui控件;以及会出现的the class containing “ui::XXX”cound not be found...Please verify the .
- sis新地址_坚若磐石不掉速,老平台升级新选择,入手昱联Asint 500G SSD
- 计算机如何执行(运行)程序
- 安卓Android的手机微博平台设计与开发
- 前端人应该知道的 Centos/Docker/Nginx/Node/Jenkins 的基本操作
- java企业级应用开发项目总结报告,基于Java软件项目开发岗位的企业实践总结报告...
- 移动端UI一致性解决方案
- Windows系统必备的软件
- 微信小程序怎么上架和发布商品?
- 地质灾害监测预警系统解决方案
- 2018区块链顶尖论文及学者榜单:50个顶级学术团队,带你探索区块链学术研究最前沿...
- 从翻译到产品本地化 Airbnb语言经理的出海建议