如何通过 http 实现 google 的协议缓冲区 [关闭]答案

【问题标题】：how to implement google's protocol buffers via http [closed]如何通过 http 实现 google 的协议缓冲区 [关闭]
【发布时间】：2018-11-22 13:55:24
【问题描述】：

我正在使用 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 将数据从客户端发送到服务器？

【问题讨论】：

您的代码建立了一个 tcp 连接（参见 net.Dial 中的文字 "tcp"）。那么问题是什么？
“Protocol Buffers”本质上是协议——它甚至在名称中包含协议 :)
我们可以通过 http 使用协议缓冲区
是的，你可以。但为什么呢？
我建议你谷歌“protobuf 是如何工作的？”并从那里开始。这里有工作示例，例如github.com/golang/protobuf

标签： go network-programming protocols protocol-buffers network-protocols

【解决方案1】：

我成功实现 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;
}

【讨论】：