go中的protobuf和grpc使用教程

更新時(shí)間：2024年08月13日 10:47:38 作者：卡卡舅舅

gRPC 是 Google 公司基于 Protobuf 開(kāi)發(fā)的跨語(yǔ)言的開(kāi)源 RPC 框架,這篇文章主要介紹了go中的protobuf和grpc使用教程,需要的朋友可以參考下

一、Protobuf

Protobuf是接口規(guī)范的描述語(yǔ)言，可以通過(guò)工具生成代碼，將結(jié)構(gòu)化數(shù)據(jù)序列化。

二、grpc

gRPC 是 Google 公司基于 Protobuf 開(kāi)發(fā)的跨語(yǔ)言的開(kāi)源 RPC 框架。

三、使用教程

3.1 student.proto

syntax = "proto3";
import "google/api/annotations.proto";
package main;
option go_package = "/main;student";
message Student {
  string name = 1;
  int32 age = 2;
  repeated int32 scores = 3;
}
service StudentService {
  rpc GetStudent(Student) returns (Student){
    option (google.api.http) = {
      post: "/v1/student/get"
      body: "*"
    };
  };
}

3.2 根據(jù)proto文件生成接口和結(jié)構(gòu)定義

third_party 存放annotations.proto

 protoc --proto_path=./third_party --proto_path=.  --go_out=.  --go-grpc_out=.   student.proto

編譯生成目標(biāo)文件

3.3 grpc provider 實(shí)現(xiàn)

// 定義提供者
type StudentService struct {
	student.UnimplementedStudentServiceServer `wire:"-"`
}
// 實(shí)現(xiàn)提供者方法
func (s *StudentService) GetStudent(context.Context, *student.Student) (*student.Student, error) {
	return &student.Student{
		Age:    18,
		Name:   "vicyor",
		Scores: []int32{1, 2, 3, 4, 5},
	}, nil
}

3.4 grpc server 實(shí)現(xiàn)

func main_grpc() {
	serverPort := 50051
	// 創(chuàng)造grpc服務(wù)端
	server := grpc.NewServer()
	// 創(chuàng)建listener
	lis, _ := net.Listen("tcp", fmt.Sprintf(":%d", serverPort))
	// 注冊(cè)grpc服務(wù)
	student.RegisterStudentServiceServer(server, &StudentService{})
	// grpc 啟動(dòng)
	server.Serve(lis)
}

3.5 grpc client 實(shí)現(xiàn)

func main_grpc() {
    <-time.NewTimer(time.Second * 2).C
	// 這里啟動(dòng)一個(gè)消費(fèi)者
	conn, _ := grpc.NewClient("127.0.0.1:50051", 
    grpc.WithTransportCredentials(insecure.NewCredentials()))
	defer conn.Close()
	cli := student.NewStudentServiceClient(conn)
    // 3秒讀超時(shí)
	ctx, _ := context.WithTimeout(context.Background(), time.Second*3)
	res, _ := cli.GetStudent(ctx, &student.Student{})
	fmt.Println(res)
}

到此這篇關(guān)于go中的protobuf和grpc的文章就介紹到這了,更多相關(guān)go protobuf和grpc內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: