最新消息:比度技术-是关注互联网技术的个人博客,大部分内容来自互联网,以作为笔记查阅。

在 go/golang语言中使用 google Protocol Buffer

编程开发 bidu 551浏览

怎么在go语言中实用google protocol Buffer呢?

现在的潮流趋势就是一键搞定,跟ubuntu安装软件一样

go get code.google.com/p/goprotobuf/{proto,protoc-gen-go}

go install  code.google.com/p/goprotobuf/proto

 

搞定,可以在 $GO_PATH/bin下找到 protoc-gen-go 这个程序,那么就可以实用protoc-gen-go 进行go语言的proto文件的自动生成了。

go1.0 使用: protoc-gen-go –go_out=. hellowrold.proto

go1.1 直接实用以下命令

protoc –go_out=. hellowrold.proto

 

proto文件:

package lm;
message helloworld
{
required int32     id = 1;  // ID
required string    str = 2;  // str
optional int32     opt = 3;  //optional field

}

 

package lm; 因此必须放到lm目录下(参考proto规范) ,在lm下面使用命令生成文件

protoc-gen-go –go_out=. hellowrold.proto

 

自动生存了helloworld.go文件:

 

复制代码

// Code generated by protoc-gen-go.
// source: helloworld.proto
// DO NOT EDIT!

package lm

import proto “code.google.com/p/goprotobuf/proto”
import json “encoding/json”
import math “math”

// Reference proto, json, and math imports to suppress error if they are not otherwise used.
var _ = proto.Marshal
var _ = &json.SyntaxError{}
var _ = math.Inf

type Helloworld struct {
Id               *int32  `protobuf:”varint,1,req,name=id” json:”id,omitempty”`
Str              *string `protobuf:”bytes,2,req,name=str” json:”str,omitempty”`
Opt              *int32  `protobuf:”varint,3,opt,name=opt” json:”opt,omitempty”`
XXX_unrecognized []byte  `json:”-“`
}

func (this *Helloworld) Reset()         { *this = Helloworld{} }
func (this *Helloworld) String() string { return proto.CompactTextString(this) }
func (*Helloworld) ProtoMessage()       {}

func (this *Helloworld) GetId() int32 {
if this != nil && this.Id != nil {
return *this.Id
}
return 0
}

func (this *Helloworld) GetStr() string {
if this != nil && this.Str != nil {
return *this.Str
}
return “”
}

func (this *Helloworld) GetOpt() int32 {
if this != nil && this.Opt != nil {
return *this.Opt
}
return 0
}

func init() {

复制代码

}

 

可以看到没有c++里面的set_xx、SerializeToOstream 之类的函数(可从下面的代码看到不同的方法)。

 

writer文件:

 

复制代码

package main

import proto “code.google.com/p/goprotobuf/proto”
import (
“./lm”
“fmt”
“os”
)

func main() {

msg := &lm.Helloworld{
Id:  proto.Int32(101),
Str: proto.String(“hello”),
} //msg init

path := string(“./log.txt”)
f, err := os.Create(path)
if err != nil {
fmt.Printf(“failed: %s\n”, err)
return
}

defer f.Close()
buffer, err := proto.Marshal(msg) //SerializeToOstream
f.Write(buffer)

复制代码

}

 

 

reader文件:

 

复制代码

package main

import proto “code.google.com/p/goprotobuf/proto”
import (
“./lm”
“fmt”
“io”
“os”
)

func CheckError(err error) {
if err != nil {
fmt.Println(err.Error())
os.Exit(-1)
}
}

func main() {
path := string(“./log.txt”)
file, err := os.Open(path)
if err != nil {
fmt.Printf(“failed: %s\n”, err)
return
}

defer file.Close()
fi, err := file.Stat()
CheckError(err)
buffer := make([]byte, fi.Size())
_, err = io.ReadFull(file, buffer) //read all content
CheckError(err)
msg := &lm.Helloworld{}
err = proto.Unmarshal(buffer, msg) //unSerialize
CheckError(err)
fmt.Printf(“read: %s\n”, msg.String())

复制代码

} http://www.cnblogs.com/zhangqingping/archive/2012/10/28/2743274.html

转载请注明:比度技术-关注互联网技术的个人博客 » 在 go/golang语言中使用 google Protocol Buffer