[toc]

ProtoBuf使用

安装

二进制流
语言无关描述来定义结构

安装ProtoBuf，然后需要配置环境变量

protoc帮助命令，运行成功表示安装成功。

去github搜索grpc-gateway有下面的安装教程

go install \
    github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-grpc-gateway \
    github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2 \
    google.golang.org/protobuf/cmd/protoc-gen-go \
    google.golang.org/grpc/cmd/protoc-gen-go-grpc

如果不行，就一个一个安装。

hello world

创建proto文件夹，创建trip.proto文件

在vscode安装proto3插件。

在trip.proto文件中写如下代码：

syntax = "proto3";
package coolcar;
option go_package="coolcar/proto/gen/g0;trippb";
//定义数据格式
message Trip{
	//1数字表示第一个字段
	string start = 1;
	string end = 2;
	int64 duration_sec = 3;
	int64 fee_cent = 4;
}

进入proto文件夹目录，命令行操作

1
2

-I表示输入目录=.表示当前目录go_out表示生成go语言的代码paths=source_relative:gen/go表示生成文件的存储路径，最后加上源文件trip.proto
protoc -I=. --go_out=paths=source_relative:gen/go trip.proto

import(
    trippb "coolcar/proto/gen/go"
    "fmt"
)
func main(){
    trip:= trippb.Trip{
        Start: "abc",
        End: "def",
        DurationSec: 3600,
        FeeCent: 10000,
    }
    //不加&表示复制，但是trip的一些状态和锁无法复制，所以不能复制。取地址就可以。
    fmt.Println(&trip)
}

序列化,反序列化二进制流

序列化

b, err := proto.Marshal(&trip)
if err !=nil {
	panic(err)
}
fmt.Printf("%X\n",b)

反序列化

var trip2 trippb.Trip
err = protp.Unmarshal(b, &trip2)
if err!= nil{
	panic(err)
}
fmt.Println(&trip2)

这也就是服务器和客户端通信的过程：通过Marshal出来的二进制流通过grpc服务的TCP端口发给客户端，客户端Unmarshal就可以获得数据

json.Marshal

转json数据

1	b,err = json.Marshal(&trip2)

补充

更多的数据字段

bytes就是和穿多媒体内容

syntax = "proto3";
package coolcar;
option go_package="coolcar/proto/gen/g0;trippb";
//定义数据格式
message Location{
	double latitude=1;
	double longtitude=2;
}
// 枚举类型
enum TripStatus{
	TS_NOT_SPECIFIDE = 0
	NOT_STARTED = 1;
	IN_PROGRESS = 2;
	FINISHED = 3;
	PAID = 4;
}
message Trip{
	//1数字表示第一个字段
	string start = 1;
	string end = 2;
	int64 duration_sec = 3;
	int64 fee_cent = 4;
	// 复合类型
	Location start_pos = 5;
	//repeated 被翻译成切片
	repeated Location path_locations= 7;
	TripStatus status = 8;
}

func main(){
    trip:= trippb.Trip{
        Start: "abc",
        End: "def",
        DurationSec: 3600,
        FeeCent: 10000,
        StartPos: &trippb.Location{
            Latitude: 32,
            Longtitude: 120,
        },
        EndPos: &trippb.Location{
            Latitude: 35,
            Longtitude: 111,
        },
        PathLocations: []*trippb.Location{
            {
                Latitude: 23,
            	Longtitude: 111,
            },
            {
                Latitude: 15,
            	Longtitude: 131,
            },
        },
        Status: trippb.TripStatus_IN_PROGRESS,
    }
    fmt.Println(&trip)
}