【轻知识】Go grpc的实现

栏目: Go · 发布时间: 5年前

内容简介:继上篇《【轻知识】(糙译)Go使用proto3、官方示例代码》,我根据官方demo生成了一个文件正好grpc的实现,也别浪费了这个demo。还记得那个proto文件么?温馨提示:

前情回顾

继上篇《【轻知识】(糙译)Go使用proto3、官方示例代码》,我根据官方demo生成了一个文件 addressbook.data

正好grpc的实现,也别浪费了这个demo。还记得那个proto文件么? addressbook.proto 。实现rpc呢?我需要简单的更改下文件。增加Service

贴代码

温馨提示:

记得 go get -u google.golang.org/grpc

protoc addressbook.proto --go_out=plugins=grpc:./ 如果不加grpc就没有rpc代码实现

不加grpc跟加了的对比

【轻知识】Go grpc的实现

image.png

proto 文件如下

syntax = "proto3";
package tutorial;

import "google/protobuf/timestamp.proto";

message Person {
    string name  = 1;
    int32 id = 2;
    string email = 3;

    enum PhoneType {
        MOBILE = 0;
        HOME = 1;
        WORK = 2;
    }
    message PhoneNumber {
        string number = 1;
        PhoneType type =2;
    }
    repeated PhoneNumber phones = 4;
    google.protobuf.Timestamp last_updated = 5;
}

message AddressBook {
    repeated Person people = 1;
}

message AddressListRequest {
    int32 page = 1;
}
message AddressListResponse {
    AddressBook book_list = 1;
}
service AddressListService {
    rpc AddressList (AddressListRequest) returns (AddressListResponse);
}

接着看服务器端代码:

读取addressbook.data(正好没浪费)

package main

import (
    "context"
    "fmt"
    "io/ioutil"
    "log"
    "net"
    pb "rpc/tutorial"

    "github.com/golang/protobuf/proto"
    "google.golang.org/grpc"
    "google.golang.org/grpc/reflection"
)

type server struct{}

func (s *server) AddressList(ctx context.Context, in *pb.AddressListRequest) (*pb.AddressListResponse, error) {
    fileData, err := ioutil.ReadFile("./addressbook.data")
    if err != nil {
        log.Fatalln("Error reading file:", err)
    }
    book := &pb.AddressBook{}
    if err := proto.Unmarshal(fileData, book); err != nil {
        log.Fatalln("Failed to parse address book:", err)
    }
    fmt.Printf("%v\n", book)
    return &pb.AddressListResponse{BookList: book}, nil
}

func main() {
    s := grpc.NewServer()
    pb.RegisterAddressListServiceServer(s, &server{})
    reflection.Register(s)
    lis, err := net.Listen("tcp", ":9555")
    if err != nil {
        log.Println(err)
    }
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %s", err)
    }
}

client端代码

package main

import (
    "context"
    "encoding/json"
    "fmt"
    "log"
    pb "rpc/tutorial"
    "time"

    "google.golang.org/grpc"
)

func main() {
    conn, err := grpc.Dial("127.0.0.1:9555", grpc.WithInsecure())
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()
    c := pb.NewAddressListServiceClient(conn)
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()
    r, err := c.AddressList(ctx, &pb.AddressListRequest{Page: 1})
    if err != nil {
        log.Fatalf("could not greet: %v", err)
    }
    json, err := json.Marshal(r.BookList)
    if err != nil {
        panic(err)
    }
    fmt.Printf("%v", string(json))

}

执行client端代码输出

{
    "people":[
        {
            "name":"mike",
            "id":123,
            "email":"mike@gmail.com",
            "phones":[
                {
                    "number":"178933"
                }
            ]
        },
        {
            "name":"mike",
            "id":123434,
            "email":"mike@gmail.com",
            "phones":[
                {
                    "number":"178933",
                    "type":1
                },
                {
                    "number":"98783",
                    "type":2
                },
                {
                    "number":"123333"
                }
            ]
        }
    ]
}

参考资料:


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

程序员的呐喊

程序员的呐喊

[美]Steve Yegge / 徐旭铭 / 人民邮电出版社 / 2014-5-1 / 45.00元

《程序员的呐喊》的作者是业界知名的程序员—来自google的steve yegge,他写过很多颇富争议的文章,其中有不少就收录在这本书中。本书是他的精彩文章的合集。 《程序员的呐喊》涉及编程语言文化、代码方法学、google公司文化等热点话题。 对工厂业界的各种现象、技术、趋势等,作者都在本书中表达了自己独特犀利的观点。比如java真的是一门优秀的面向对象语言吗?重构真的那么美好吗?强......一起来看看 《程序员的呐喊》 这本书的介绍吧!

HTML 编码/解码
HTML 编码/解码

HTML 编码/解码

MD5 加密
MD5 加密

MD5 加密工具

HEX CMYK 转换工具
HEX CMYK 转换工具

HEX CMYK 互转工具