今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《如何通过http实现google的协议缓冲区》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！
问题内容我正在使用 google 的协议缓冲区将数据从客户端发送到服务器。
客户端和服务器都是用 golang 编写的。
我认为它使用纯 tcp 将数据从 client 发送到 server。
示例客户端代码：
func getFakeTransaction() *proto.Transaction {
transaction := new(proto.Transaction)
transaction.ClientId = "client_1"
transaction.ClientName = "Europa"
items := new(proto.Items)
items.ItemId = 1
items.ItemName = "Space suite"
items.ItemValue = 2000
transaction.Items = items
return transaction
}
func readDataFromExternalDatasource() *proto.Transaction {
return getFakeTransaction()
}
func sentDataToServer(data []byte) {
conn, err := net.Dial("tcp", "localhost:8080")
defer conn.Close()
if err != nil {
fmt.Fprintf(os.Stderr, "Error while dialing server: %s\n", err.Error())
return
}
sentBytes, err := conn.Write(data)
if err != nil {
fmt.Fprintf(os.Stderr, "Error sending bytes to serve: %s\n", err.Error())
return
}
fmt.Printf("Sent %d bytes\n", sentBytes)
}
func main() {
fmt.Println("Starting client..")
data := readDataFromExternalDatasource()
dataInByteArr, err := protoc.Marshal(data)
if err != nil {
fmt.Fprintf(os.Stderr, "Error while Marshal data: %s", err.Error())
}
for {
sentDataToServer(dataInByteArr)
time.Sleep(1000)
}
}如何使用 golang 中的协议缓冲区通过 http 从客户端向服务器发送数据？
解决方案
我成功实现了 protobuff vai http。
鸣谢：https://jacobmartins.com/2016/05/24/practical-golang-using-protobuffs/
sample_client：
func getfaketransaction() *proto.transaction {
transaction := new(proto.transaction)
transaction.clientid = "client_1"
transaction.clientname = "europa"
items := new(proto.items)
items.itemid = 1
items.itemname = "space suite"
items.itemvalue = 2000
transaction.items = items
return transaction
}
func sendmessage(transaction *proto.transaction) {
message, err := protoc.marshal(transaction)
if err != nil {
fmt.fprintf(os.stderr, "error while marshaling message: %s", err.error())
os.exit(1)
}
_, err = http.post("http://localhost:8080", "", bytes.newbuffer(message))
if err != nil {
fmt.fprintf(os.stderr, "error while post request to server: %s", err.error())
os.exit(1)
}
fmt.printf("sent %d bytes to server\n", len(message))
}
func main() {
fmt.println("starting client..")
transaction := getfaketransaction()
for {
sendmessage(transaction)
// time.sleep(1 * time.second)
}
}示例服务器：
func printmessage(t *proto.transaction) {
clientid := t.getclientid()
clientname := t.getclientname()
items := t.getitems()
fmt.printf("clientid: %s, clientname: %s, items: %s\n", clientid, clientname, items)
}
func main() {
fmt.println("staring server..")
http.handlefunc("/", func(w http.responsewriter, r *http.request) {
message, err := ioutil.readall(r.body)
if err != nil {
fmt.fprintf(os.stderr, "error while reading data from client: ", err.error())
return
}
transaction := new(proto.transaction)
// protoc.unmarshal(message, &transaction)
if err = transaction.xxx_unmarshal(message); err != nil {
fmt.fprintf(os.stderr, "error while unmarshaling client message: %s", err.error())
return
}
printmessage(transaction)
})
http.listenandserve(":8080", nil)
}示例原型文件：
syntax="proto3";
package proto;
enum Status {
SUCCESS = 0;
INPROGRESS = 1;
FAILED = 2;
}
message Items {
int32 itemId = 1;
string itemName = 2;
int32 itemValue = 3;
Status status = 4;
}
message Transaction {
string clientId = 1;
string clientName = 2;
Items items = 3;
}今天关于《如何通过http实现google的协议缓冲区》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注编程网公众号！
