美文网首页通信
go语言grpc的基础使用

go语言grpc的基础使用

作者: xyt001 | 来源:发表于2018-12-15 15:50 被阅读0次

    前言:

    grpc 是谷歌推出的rpc 框架,使用http2.0来通讯的,性能算不上最优的,但是胜在 通用性很高.而且说实话 http2 性能真的不差了 ,它比 1.0多了两个很重要的概念 多路复用 和 长连接. 看此篇文章之前一定要先把grpc 环境搭建好。可以看我之前的文章 https://www.jianshu.com/p/3eafec6858c6 grpc的环境搭建

    1.长连接:这是http1.1 以后就加得特性,http1.0 每次请求一次 数据 就要重新 握手 ,1.1 版本 省略了这个过程。
    2.多路复用:传统得 http模式 是一问一答得,就是一定要 等当前 得请求 返回后 才能发起下一个 请求 。但是 http2 有了多路复用 这个概念 ,允许 一次性 使用一个连接 发起多个请求,不再阻塞了,速度就大大得提高了!(划重点这个要考)

    基本步骤:

    grpc 基本 有三个步骤:

    1. 首先 编写 protobuf文件,编译它。
    2. 服务端 引用编译后的 protobuf 的go文件,实现 该文件的 结构, 调用相应的 api, 监听端口,提供服务。
    3. 客户端 引用编译后的 protobuf的 go文件,调用相应的api ,调用服务端接口。

    编写protobuf 文件:

    syntax = "proto3";//声明proto的版本 只能 是3,才支持 grpc
    
    //声明 包名
    package pro;
    
    //声明grpc服务
    service Greeter {
       /*
       声名一个 sayhello 接口
       它的参数 是 HelloRequest
       它的返回参数是 HelloReply
       */
      rpc SayHello (HelloRequest) returns (HelloReply) {}
    }
    
    //参数结构
    message HelloRequest {
      string name = 1;
    }
    
    //参数结构
    message HelloReply {
      string message = 1;
    }
    
    //protoc --go_out=plugins=grpc:. helloworld.proto
    

    这段代码就是 声明了一个最简单的 grpc 服务,我都注释了,要是还看不懂,我也没法了(手动捂脸)。
    写好以后 。运行 protoc --go_out=plugins=grpc:. cs.proto 这段代码,cs.proto 是文件名。不出意外的话,它在 当前目录生成一个go文件。

    编写go-grpc服务端:

    package main
    
    import (
        "context"
        "google.golang.org/grpc"
        "grpc/pro"
        "net"
    )
    
    const PORT  = ":50051"
    
    type server struct {}
    
    func (s *server)SayHello(ctx context.Context, in *pro.HelloRequest)(*pro.HelloReply,error){
        return &pro.HelloReply{Message:"hello"},nil
    }
    
    func main(){
        //监听端口
        lis,err := net.Listen("tcp",PORT)
        if err != nil{
            return
        }
        //创建一个grpc 服务器
        s := grpc.NewServer()
        //注册事件
        pro.RegisterGreeterServer(s,&server{})
        //处理链接
        s.Serve(lis)
    }
    

    以上代码就是 监听 50051端口 实现 了刚刚protobuf 的结构,提供了一个grpc服务。主要逻辑我也都注释了。

    编写 go-grpc客户端:

    package main
    
    import (
        "google.golang.org/grpc"
        "grpc/pro"
        "log"
        "context"
    )
    
    const (
        ADDRESS = "localhost:50051"
    )
    func main(){
        //通过grpc 库 建立一个连接
        conn ,err := grpc.Dial(ADDRESS,grpc.WithInsecure())
        if err != nil{
            return
        }
        defer conn.Close()
    
        //通过刚刚的连接 生成一个client对象。
        c := pro.NewGreeterClient(conn)
        //直接通过 client对象 调用 服务端的函数
        r, err := c.SayHello(context.Background(), &pro.HelloRequest{Name: "namas"})
        if err != nil {
            log.Fatal("could not greet: %v", err)
        }
        log.Printf("Greeting: %s", r.Message)
    }
    

    以上代码就是通过已知的 服务端的ip和端口,建立grpc 客户端调用服务端的 函数的例子。

    注意点:

    1. 服务端 和客户端都是约定好了 出入参数和 输出参数, 一定要 之前 protobuf文件 生成的 go文件里面的格式。那个protobuf 文件其实就是 服务的约定!
    2. 祝大家愉快点个赞鼓励一下吧。嘿嘿

    相关文章

      网友评论

        本文标题:go语言grpc的基础使用

        本文链接:https://www.haomeiwen.com/subject/anuuhqtx.html