【轻知识】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"
                }
            ]
        }
    ]
}

参考资料:


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

查看所有标签

猜你喜欢:

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

人件

人件

Tom DeMarco、Timothy Lister / UML China / 清华大学出版社 / 2003-6 / 35.00元

《人件(第2版)》专门讨论了软件开发和维护的团队管理问题,并向人们的传统认识提出了挑战。作者汤姆·迪马可,蒂姆·李斯特在书中推崇人本管理思想,指出知识型企业的核心是人,而不是技术。《人件(第2版)》于1987年首次出版后,曾在西方引起了轰动,被誉为“对美国软件业影响最大的一本书”。《人件(第2版)》还对大中型组织中的软件开发团队如何运作进行了深入探讨。《人件》已成为软件图书中的经典之作。它和《人月......一起来看看 《人件》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

JSON 在线解析
JSON 在线解析

在线 JSON 格式化工具

URL 编码/解码
URL 编码/解码

URL 编码/解码