grpc的例子使用

aside section ._1OhGeD · · 1622 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

前言:适用于刚入手的小白,本人学习过程也是来源于git项目的说明文档(就是github项目下面那些介绍,有介绍怎么用的),建议可以先去看看,先了解个大概,知道怎么回事,我说的就是简单直白一点,用大白话叫你明白是怎么回事。
一。获取package
学习groc,首先得先获取对应包

go get -u google.golang.org/grpc

如果下载不了,就去这个地址(https://github.com/grpc/grpc-go.git),自己手动下载,或者用官方的方法

git clone https://github.com/grpc/grpc-go.git $GOPATH/src/google.golang.org/grpc

他的这个git语句的意思是,克隆这个地址的项目,到你的gopath/src下面这个地方。其实和你自己下载(git clone或者download)一个道理(当然他这个比较高大上,比较符合程序员应该的操作)。

二。例子使用
这个项目本身就自带了一个例子。目录在项目下的examples/helloworld文件夹下.
该目录下有四个文件夹


image.png

1.helloworld
这个是使用protoc编译生成的一个go文件,你可以先删除他原来的go文件,然后执行protoc --go_out=. helloworld.proto去生成一下(不知道protoc的同学,可以看一下对应的git框架,或者看一下我的笔记https://www.jianshu.com/p/a7c03b8048eb),内容是一样的,只不过他为了例子的完整,提前给你生成好了。这里面写的是服务的数据结构等,是为了其他服务调用而是用的。为什么用这个,是因为golang本身的rpc是不支持其他语言调用的,grpc解决了这个问题,想详细了解的,请移步官方大佬的资料(https://github.com/astaxie/build-web-application-with-golang/blob/master/zh/08.4.md)。

2.greeter_server

package main

import (
    "context"
    "log"
    "net"

    "google.golang.org/grpc"
    pb "google.golang.org/grpc/examples/helloworld/helloworld"
)
const (
    port = ":50051" //监听的端口号
)

// server is used to implement helloworld.GreeterServer.
type server struct { //服务的结构类型
    pb.UnimplementedGreeterServer
}

// SayHello implements helloworld.GreeterServer
//这个方法就是你实际的逻辑方法,里面的参数是调用了helloworld下面,使用protoc生成的那个go文件的机构
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
    log.Printf("Received: %v", in.GetName())
    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)
    }
    s := grpc.NewServer()                  //新建一个grpc服务
    pb.RegisterGreeterServer(s, &server{}) //这个服务和上述的服务结构联系起来,这样你新建的这个服务里面就有那些类型的方法
    if err := s.Serve(lis); err != nil {   //这个服务和你的监听联系起来,这样外界才能访问到啊
        log.Fatalf("failed to serve: %v", err)
    }
}

这是服务文件,编译里面的main.go,并执行,就开始了监听服务

3.greeter_client

package main

import (
    "context"
    "log"
    "os"
    "time"

    "google.golang.org/grpc"
    pb "google.golang.org/grpc/examples/helloworld/helloworld"
)

const (
    address     = "localhost:50051"//服务地址
    defaultName = "world"
)

func main() {
    // Set up a connection to the server.
    conn, err := grpc.Dial(address, grpc.WithInsecure())//连接到你的服务地址
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()
    c := pb.NewGreeterClient(conn)//返回一个client连接,通过这个连接就可以访问到对应的服务资源,就像一个对象

    // Contact the server and print out its response.
    name := defaultName
    if len(os.Args) > 1 {//这两步不重要,就是执行的时候可以加个参数
        name = os.Args[1]
    }
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)//返回一个client,并设置超时时间
    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())
}

这是客户端文件,编译执行,就访问了一次上述的服务。


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:aside section ._1OhGeD

查看原文:grpc的例子使用

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1622 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传