文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

从0到1:带你完整写一个 Golang Grpc 服务

2024-12-03 00:45

关注

前往 protobuf,下载最新版的 protoc ,我下载的是 win 64

安装 protoc-gen-go

前往 protobuf-go ,同样下载最新版的 protoc,同样下载的是 win 64

将下载后的 protoc.exe 和 protoc-gen-go 放到 %GOPATH%\bin\ 目录下。

或者更简单的方法,直接执行如下命令就可以安装

  1. go install google.golang.org/grpc/cmd/protoc-gen-go-grpc 

下载 grpc

  1. # 安装 grpc  
  2. go get -u google.golang.org/grpc 
  3.  
  4. # gRPC运行时接口编解码支持库 
  5. go get -u github.com/golang/protobuf/proto  

# 2. 项目目录结构

在 $GOPATH/src 下新建 iswbm.com 目录及三个子目录(client,server,proto),在终端上进入该目录,执行如下命令创建 go.mod

  1. mkdir $GOPATH/src/iswbm.com/{client,server,proto} 
  2. cd mkdir $GOPATH/src/iswbm.com/ 
  3.  
  4. # 设置环境变量,确保 GO111MODULE 是开启的 
  5. go env -w GO111MODULE=auto 
  6.  
  7. # 初始化项目 
  8. go mod init 

# 3. 编写 proto 文件

编写 proto/simple.proto

  1. syntax = "proto3"
  2.  
  3. package proto; 
  4. option go_package ="/proto"
  5.  
  6. // 定义发送请求信息 
  7. message SimpleRequest{ 
  8.   // 参数类型 参数名称 标识号 
  9.   string data = 1; 
  10.  
  11. // 定义响应信息 
  12. message SimpleResponse{ 
  13.   int32 code = 1; 
  14.   string value = 2; 
  15.  
  16. // 定义我们的服务(可以定义多个服务,每个服务可以定义多个接口) 
  17. service Simple{ 
  18.   rpc GetSimpleInfo(SimpleRequest) returns (SimpleResponse){}; 

在 iswbm.com 目录下,执行如下命令

  1. protoc --go_out=. ./proto/simple.proto 
  2. protoc --go-grpc_out=. ./proto/simple.proto 

完成后,会在当前目录下生成一个 simple 目录,该目录下有一个 simple.pb.go 和 simple_grpc.pb.go

# 4. 编写 server.go

  1. package main 
  2.  
  3. import ( 
  4.     "context" 
  5.     pb "iswbm.com/proto" 
  6.     "google.golang.org/grpc" 
  7.     "log" 
  8.     "net" 
  9.  
  10. const ( 
  11.     Address string = ":8000" 
  12.     Network string = "tcp" 
  13.  
  14. // 定义我们的服务 
  15. type SimpleService struct{ 
  16.     pb.UnimplementedSimpleServer 
  17.  
  18. // 实现 GetSimpleInfo 方法 
  19. func (s *SimpleService) GetSimpleInfo(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) { 
  20.     data := req.Data 
  21.     log.Println("get from client: ", data) 
  22.     resp := &pb.SimpleResponse{ 
  23.         Code:  8888, 
  24.         Value: "grpc"
  25.     } 
  26.     return resp, nil 
  27.  
  28. func main() { 
  29.  
  30.     // 1.监听端口 
  31.     listener, err := net.Listen(Network, Address) 
  32.     if err != nil { 
  33.         log.Fatalf("net.listen err: %v", err) 
  34.     } 
  35.     log.Println(Address, " net listening..."
  36.     // 2.实例化gRPC服务端 
  37.     grpcServer := grpc.NewServer() 
  38.  
  39.     // 3.注册我们实现的服务 SimpleService 
  40.     pb.RegisterSimpleServer(grpcServer, &SimpleService{}) 
  41.  
  42.     // 4.启动gRPC服务端 
  43.     err = grpcServer.Serve(listener) 
  44.     if err != nil { 
  45.         log.Fatalf("grpc server err: %v",err) 
  46.     } 
  47.  

完成后,先安装依赖包

  1. go install 

执行如下命令运行服务端

  1. > go run server/server.go 
  2. 2021/07/28 18:31:42 :8000  net listening... 

# 5. 编写 client.go

  1. package main 
  2.  
  3. import ( 
  4.     "context" 
  5.     "google.golang.org/grpc" 
  6.     "log" 
  7.     pb "iswbm.com/proto" 
  8.  
  9. const ( 
  10.     Address string = ":8000" 
  11.  
  12. func main() { 
  13.     // 1.创建于gRPC服务端的连接 
  14.     conn, err := grpc.Dial(Address, grpc.WithInsecure()) 
  15.     if err != nil { 
  16.         log.Fatalf("dial conn err: %v", err) 
  17.     } 
  18.     defer conn.Close() 
  19.  
  20.     // 2.创建grpc客户端 
  21.     client := pb.NewSimpleClient(conn) 
  22.  
  23.     // 3.调用服务端提供的服务 
  24.     req := pb.SimpleRequest{ 
  25.         Data: "Hello,Server"
  26.     } 
  27.     resp, err := client.GetSimpleInfo(context.Background(), &req) 
  28.     if err != nil { 
  29.         log.Fatalf("resp err: %v", err) 
  30.     } 
  31.     log.Printf("get from server,code: %v,value: %v", resp.Code, resp.Value) 
  32.  

执行如下命令运行,立马就能收到来自 server 返回的消息

  1. > go run client/client.go 
  2. 2021/07/28 18:54:35 get from server,code: 8888,value: grpc 

同时,在 server 端也会打印来自 client 端的消息

  1. > go run server/server.go 
  2. 2021/07/28 18:51:59 :8000  net listening... 
  3. 2021/07/28 18:54:35 get from client:  Hello,Server 
本文转载自微信公众号「Go编程时光」,可以通过以下二维码关注。转载本文请联系Go编程时光公众号。

 

来源:Go编程时光内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯