zoukankan      html  css  js  c++  java
  • 在 Golang 中使用 Protobuf

    wget https://github.com/google/protobuf/releases/download/v2.6.1/protobuf-2.6.1.tar.gz
    tar zxvf protobuf-2.6.1.tar.gz cd protobuf-2.6.1
    ./configure make make install protoc   -h

    go get github.com/golang/protobuf/protoc-gen-go
    
    cd github.com/golang/protobuf/protoc-gen-go
    
    go build
    
    go install
    
    vi /etc/profile 将$GOPATH/bin 加入环境变量
    
    source profile

    go get github.com/golang/protobuf/proto
    cd github.com/golang/protobuf/proto
    go build
    go install

    使用 goprotobuf
    这里通过一个例子来说明用法。先创建一个 .proto 文件 test.proto:

    package example;

    enum FOO { X = 17; }; message Test { required string label = 1; optional int32 type = 2 [default=77]; repeated int64 reps = 3; optional group OptionalGroup = 4 { required string RequiredField = 5; } }

     


    编译此 .proto 文件:

    protoc --go_out=. *.proto

     

    这里通过 –go_out 来使用 goprotobuf 提供的 Protobuf 编译器插件 protoc-gen-go。这时候我们会生成一个名为 test.pb.go 的源文件。

    在使用之前,我们先了解一下每个 Protobuf 消息在 Golang 中有哪一些可用的接口:

    1. 每一个 Protobuf 消息对应一个 Golang 结构体

    2. 消息中域名字为 camel_case 在对应的 Golang 结构体中为 CamelCase

    3. 消息对应的 Golang 结构体中不存在 setter 方法,只需要直接对结构体赋值即可,赋值时可能使用到一些辅助函数,例如:

      msg.Foo = proto.String("hello")
    4. 消息对应的 Golang 结构体中存在 getter 方法,用于返回域的值,如果域未设置值,则返回一个默认值

    5. 消息中非 repeated 的域都被实现为一个指针,指针为 nil 时表示域未设置

    6. 消息中 repeated 的域被实现为 slice

    7. 访问枚举值时,使用“枚举类型名_枚举名”的格式(更多内容可以直接阅读生成的源码)

    8. 使用 proto.Marshal 函数进行编码,使用 proto.Unmarshal 函数进行解码


    现在我们编写一个小程序:

    package main
    
    import (    "log"
        // 辅助库
        "github.com/golang/protobuf/proto"
        // test.pb.go 的路径
        "example")
    
    func main() {    // 创建一个消息 Test
        test := &example.Test{        // 使用辅助函数设置域的值
            Label: proto.String("hello"),
            Type:  proto.Int32(17),
            Optionalgroup: &example.Test_OptionalGroup{
                RequiredField: proto.String("good bye"),
            },
        }    // 进行编码
        data, err := proto.Marshal(test)    
      if err != nil {         log.Fatal("marshaling error: ", err)     }    // 进行解码     newTest := &example.Test{}     err = proto.Unmarshal(data, newTest)    
      if err != nil {         log.Fatal("unmarshaling error: ", err)     }    // 测试结果     if test.GetLabel() != newTest.GetLabel() {         log.Fatalf("data mismatch %q != %q", test.GetLabel(), newTest.GetLabel())     } }
  • 相关阅读:
    CopyOnWriteArrayList 读写分离,弱一致性
    Java中定时器Timer致命缺点(附学习方法)
    排队打饭:公平锁和非公平锁(面试)
    母鸡下蛋实例:多线程通信生产者和消费者wait/notify和condition/await/signal条件队列
    volatile,synchronized可见性,有序性,原子性代码证明(基础硬核)
    Synchronized用法原理和锁优化升级过程(面试)
    Java中多线程安全问题实例分析
    iOS 相互引用引起内存泄露问题说明
    iOS app 集成友盟推送问题
    ios即时通讯客户端开发之-mac上基于XMPP的聊天客户端开发环境搭建
  • 原文地址:https://www.cnblogs.com/mhc-fly/p/7714611.html
Copyright © 2011-2022 走看看