Golang TCPConn Gob 通信答案

【问题标题】：Golang TCPConn Gob CommunicationGolang TCPConn Gob 通信
【发布时间】：2017-11-26 01:39:47
【问题描述】：

我遇到了 gob 协议的问题（或者可能是一般的网络，我的知识很薄弱），我不明白为什么下面的代码不能正常工作。它只是一个维护开放 TCP 连接并通过它发送多个 gob 的简单示例。该代码将发送和接收，但通常会破坏其数据。提前谢谢你。

package main

import (
    "encoding/gob"
    "fmt"
    "net"
    "strconv"
    "time"
)

type Message struct {
    Msg string
}

func main() {
    gob.Register(new(Message))

    clientAddr, err := net.ResolveTCPAddr("tcp", "localhost:12346")
    if err != nil {
        fmt.Println(err)
    }
    serverAddr, err := net.ResolveTCPAddr("tcp", "localhost:12345")
    if err != nil {
        fmt.Println(err)
    }

    serverListener, err := net.ListenTCP("tcp", serverAddr)
    if err != nil {
        fmt.Println(err)
    }
    conn, err := net.DialTCP("tcp", clientAddr, serverAddr)
    if err != nil {
        fmt.Println(err)
    }
    serverConn, err := serverListener.AcceptTCP()
    if err != nil {
        fmt.Println(err)
    }
    done := false
    go func() {
        for !done {
            recieveMessage(serverConn)
        }
    }()
    for i := 1; i < 1000; i++ {
        sent := Message{strconv.Itoa(i)}
        sendMessage(sent, conn)
    }
    time.Sleep(time.Second)
    done = true
}

func sendMessage(msg Message, conn *net.TCPConn) {
    enc := gob.NewEncoder(conn)
    err := enc.Encode(msg)
    if err != nil {
        fmt.Println(err)
    }
}

func recieveMessage(conn *net.TCPConn) {
    msg := new(Message)
    dec := gob.NewDecoder(conn) // Will read from network.
    err := dec.Decode(msg)
    if err != nil {
        fmt.Println(err)
    }
    fmt.Println("Client recieved:", msg.Msg)
}

【问题讨论】：

以何种方式损坏其数据？ “经常”是多久？
该示例的输出曾经是：gob：未知类型 id 或损坏的数据客户端收到：客户端收到：979 客户端收到：981 gob：未知类型 id 或损坏的数据客户端收到：gob：未知类型客户收到的 id 或损坏的数据：...
这个例子是本地可执行的（运行它自己看看）:)
我问是因为大概您已经运行过它并获得了信息 - 如果您需要社区的帮助，最好包含尽可能多的细节，而不是期望其他人来完成这项工作。
很公平（我应该自己制作一个游乐场链接，但@Cerise-Limón 已经修复了一个。）

标签： go tcp gob

【解决方案1】：

问题在于解码器可以缓冲来自下一条消息的数据。发生这种情况时，下一个新解码器会在消息中间开始。解决方法是使用单个编码器和解码器。

func main() {
    ...
    dec := gob.NewDecoder(conn) // Will read from network.
    enc := gob.NewEncoder(serverConn)
    go func() {
        for !done {
            recieveMessage(dec)
        }
    }()

    for i := 1; i < 1000; i++ {
        sent := Message{strconv.Itoa(i)}
        sendMessage(sent, enc)
    }
    ...
}

func sendMessage(msg Message, enc *gob.Encoder) {
    err := enc.Encode(msg)
    if err != nil {
        fmt.Println(err)
    }
}

func recieveMessage(dec *gob.Decoder) {
    msg := new(Message)
    err := dec.Decode(msg)
    if err != nil {
        fmt.Println(err)
    }
    fmt.Println("Client recieved:", msg.Msg)
}

Run it in the playground

【讨论】：

很好的例子。还有一个问题，当客户端暂停一段时间而不是发送新消息（gob）时，如何检测 gob 消息在服务器端是新的消息