使用 net.Conn 连接正确处理读写

Question

我正在尝试使用网络连接进行读写。似乎正在发生的事情是，如果数据进入服务器的速度过快，一些数据将被丢弃或丢失。客户端连接，协商连接，然后我让它快速连续发送 3 个命令来更新状态页面。每个通信都是一个 JSON 字符串，它被转换为一个结构并使用存储的密钥进行解码。如果我多次单击客户端上的请求（每次生成 3 个以 \n 结尾的 JSON 有效负载），服务器有时会抛出 ERROR: invalid character X after the top-level value。我转储了客户端发送的信息，看起来客户端上有 3 个格式正确的 JSON 条目；在服务器端，似乎其中一个 JSON 有效负载完全丢失，其中一个丢失了前 515 个字符。由于缺少前 515 个字符，因此 JSON 格式不正确，因此封送处理失败。我的问题是，我能做些什么来防止从连接中读取的数据丢失？我是否遇到某种竞争条件或错误处理如何在连接上读取和发送？下面基本上是我用于客户端连接处理程序的内容。客户端和服务器协商加密连接，因此有多个对模式和 RSA 状态的引用，并且在正确设置密钥时使用模式 4，以便服务器和客户端可以交换命令和结果。在高层次上，处理程序衍生出一个从连接中读取并将其发送到通道的 goroutine。该字符串被读取并转换为结构。会话的第一部分专门用于“握手”以协商加密密钥并保存会话信息；一旦到达第 4 阶段，该结构就会携带来自客户端的加密命令并将结果发送回，直到连接出错或关闭。

Answer 1

应用程序将数据发送到缓冲的读取器，然后丢弃读取器和它可能缓冲超过第一行的任何数据。

在连接的生命周期内保留缓冲的阅读器：

    rdr := bufio.NewReader(conClient)

    for {

        netData, err := rdr.ReadString('\n')

        ...

您可以通过消除 goroutine 来简化代码（并修复与缓冲区问题无关的其他问题）。使用读取期限来处理无响应的服务器。

func HandleClientConnection(conClient net.Conn) {

    defer conClient.Close()

    chnLogging <- "Connection from " + conClient.RemoteAddr().String()

    conClient.SetReadDeadline(time.Minute * SERVER_INACTIVITY_TIMEOUT_MINUTES)

    scanner := bufio.NewScanner(conClient)

    for scanner.Scan() {

        var strctNetEncrypted stctNetEncrypted

        err := json.Unmarshal(scanner.Bytes(), &strctNetEncrypted)

        CheckErr(err)

        switch strctNetEncrypted.IntMode {

             // Insert contents of switch statement from

             // question here with references to 

             // chnCloseConn removed.

        }

        conClient.SetReadDeadline(time.Minute * SERVER_INACTIVITY_TIMEOUT_MINUTES)

    }

    if scanner.Err() != nil {

        chnLogging <- "Error from client " + conClient.RemoteAddr().String() + ": " + err.Error()

    } else {

        chnLogging <- "Client " + conClient.RemoteAddr().String() + " disconnected"

    }

}