通信

go语言grpc的基础使用

2018-12-15  本文已影响0人  xyt001

前言:

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. 祝大家愉快点个赞鼓励一下吧。嘿嘿
上一篇下一篇

猜你喜欢

热点阅读