如何通过 http 实现谷歌的协议缓冲区

Question

我正在使用谷歌的协议缓冲区将数据从客户端发送到服务器。

客户端和服务器都是用 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)

    }

}

如何HTTP使用 Golang 中的协议缓冲区将数据从客户端发送到服务器？

Answer 1

我成功地实现了protobuff vai http。学分：https://jacobmartins.com/2016/05/24/practical-golang-using-protobuffs/示例_客户端：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;}