TCP 客户端或服务器卡在处理数据上

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《TCP 客户端或服务器卡在处理数据上》，主要介绍了golang，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

问题内容

我正在尝试编写一个简单的 tcp 服务器和客户端程序。

当我同时运行下面的服务器和客户端代码时，客户端将简单地从服务器接收时间消息并退出，服务器继续接受新连接。我预期的程序行为是我希望服务器也从客户端接收“hello world”消息并关闭连接，客户端使用“responseConnection”函数也是如此。

但问题是当我启动客户端时，服务器似乎卡在“responseConnection”函数内的conn.Read函数上，并且当我首先停止客户端时出现错误“EOF exit status 1”，这对于调试来说真的很模棱两可。当我首先停止服务器时，客户端将接收来自服务器的时间数据。

如果您有任何想法，请帮忙回答，因为我完全是 Golang 的新手。太感谢了！

服务器.go

package main

import (
    "fmt"
    "io"
    "log"
    "net"
    "time"
)

type connection struct {
    host    string
    port    string
    network string
}

func checkError(err error) {
    if err != nil {
        log.Fatalln(err)
    }

}

func responseConnection(conn net.Conn) {
    defer conn.Close() //  ", string(buf))
    // c 
客户端.go
package main

import (
    "bytes"
    "fmt"
    "io"
    "log"
    "net"
    "os"
)

func checkError(err error) {
    if err != nil {
        log.Fatalln(err)
    }
}

var buf bytes.Buffer

func main() {
    if len(os.Args) != 2 {
        fmt.Fprintf(os.Stderr, "Usage: %s host:port ", os.Args[0])
        os.Exit(1)
    }
    service := os.Args[1]
    
    tcpAddr, err := net.ResolveTCPAddr("tcp", service)
    checkError(err)
    

    conn, err := net.DialTCP("tcp", nil, tcpAddr)
    checkError(err)
    
    message := "Hello world from client"
    conn.Write([]byte(message))

    
    io.Copy(&buf, conn)
    buf.Cap()
    fmt.Printf("Data from server =======>: %s\n Buffer length: %d\n", buf.String(), buf.Len())

    defer conn.Close()
}


    正确答案

我认为您的问题是相当标准的问题：不注意 TCP 没有实现消息边界 并且仅通过连接传输两个不透明的字节流这一事实。
这意味着，当您将一串字节“Hello world from client”发送到连接的套接字（已建立的 TCP
连接）时，连接的另一端不知道客户端的消息在哪里 结束 ，除非客户端以某种方式自己传达该消息；根本没有办法使用 TCP 本身来划分单个消息。
输入“应用程序级协议”：除非您打算使用 TCP
的数据交换任务自然地传输单个“消息”——想象一个服务器将单个文件的内容转储到每个连接的客户端并关闭连接——您必须为客户端发明一些方法来告诉服务器它发送的每条消息实际结束的位置。
考虑您的示例：在读取过程中，您基本上有一个循环，它从套接字重复读取数据块，只有一个退出条件：到达该套接字上的文件结尾。只有当远程端（在我们的例子中是客户端）关闭它的连接端时才会报告
EOF，而客户端从不这样做：它发送一个字符串，然后等待服务器发回一些东西，但是服务器从不回复，因为它永远不会读完。
有多种方法可以解决问题。

• 发明一个自定义协议（例如，在TLV 系列中），它可以实现消息帧。

比如说，以最简单的形式，协议可以定义为一个无符号字节，其中包含以下消息的长度，以字节为单位。
然后，服务器将有一个两步过程来读取每个客户端的消息：

1. 读取单个字节；
2. 如果成功，则读取由前导字节的值定义的尽可能多的后续字节；
3. 成功后，返回步骤 1 阅读以下消息。

• 想出一个消息分隔符，例如ASCII LF字符“可以编码为\nGo 的字符串文字，“颅”，并使服务器继续读取，直到遇到 LF；一旦它发现了一个 LF，它就知道它应该处理该消息然后开始阅读另一个消息。

Gobufio.Reader在其标准包中有一个方便的类型，可以读取io.Reader由 LF 分隔的任何单独的行。

• 有一个更复杂的消息框架，例如使用JSON 流发送 JSON 文档。

stock 包实现的解码器的一个经常被监督的特性encoding/json是它可以很好地解码 JSON 对象流，以这个为例。

可能性实际上 有很多， 所以我只是在摸索表面，我认为你应该明白这一点。

好了，本文到此结束，带大家了解了《TCP 客户端或服务器卡在处理数据上》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！