Go网络编程：解决“unexpected EOF”错误

心靈之曲

发布时间：2025-08-14 17:56:16

970人浏览过

来源于php中文网

原创

go网络编程：解决“unexpected eof”错误

在Go语言的网络编程中，遇到“unexpected EOF”错误是很常见的。这个错误通常发生在尝试从一个连接中读取数据，但连接意外关闭时。原始代码尝试使用io.ReadFull来读取数据，但这种方法要求在读取操作完成之前，连接必须提供指定长度的数据。如果连接在提供足够的数据之前关闭，就会引发“unexpected EOF”错误。

让我们回顾一下原始代码片段：

package main

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

func die(msg string, s error) {
    fmt.Printf("%s crashed: %v\n", msg, s)
    os.Exit(1)
}

func main() {
    fd, err := net.Dial("tcp", "google.com:80")
    if err != nil {
        die("dial", err)
    }
    defer fd.Close() // 确保连接关闭

    req := []byte("GET /intl/en/privacy/ HTTP/1.0\r\nHost: www.google.com\r\n\r\n")
    _, err = fd.Write(req)
    if err != nil {
        die("dial write", err)
    }

    buf := make([]byte, 1024)
    nr := 1

    for nr > 0 {
        nr, err = io.ReadFull(fd, buf)
        if err != nil {
            die("dial read", err)
        }
        fmt.Printf("read %d\n", nr)
    }
}

这段代码的问题在于它使用了io.ReadFull(fd, buf)。io.ReadFull会尝试读取len(buf)个字节，如果读取到的字节数小于len(buf)，且没有遇到错误，它会返回一个io.ErrUnexpectedEOF错误。在网络编程中，我们通常不知道响应的准确长度，因此io.ReadFull并不适用。

正确的解决方案：使用 io.Copy

io.Copy函数会从一个io.Reader读取所有数据，直到遇到EOF或发生错误，然后将数据写入一个io.Writer。这非常适合从网络连接中读取数据，因为它可以处理连接在读取完所有数据后关闭的情况。

下面是修改后的代码：

新快购物系统

新快购物系统是集合目前网络所有购物系统为参考而开发，不管从速度还是安全我们都努力做到最好，此版虽为免费版但是功能齐全，无任何错误，特点有：专业的、全面的电子商务解决方案，使您可以轻松实现网上销售；自助式开放性的数据平台，为您提供充满个性化的设计空间；功能全面、操作简单的远程管理系统，让您在家中也可实现正常销售管理；严谨实用的全新商品数据库，便于查询搜索您的商品。

下载

package main

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

func die(msg string, s error) {
    fmt.Printf("%s crashed: %v\n", msg, s)
    os.Exit(1)
}

func main() {
    fd, err := net.Dial("tcp", "google.com:80")
    if err != nil {
        die("dial", err)
    }
    defer fd.Close() // 确保连接关闭

    req := []byte("GET /intl/en/privacy/ HTTP/1.0\r\nHost: www.google.com\r\n\r\n")
    _, err = fd.Write(req)
    if err != nil {
        die("dial write", err)
    }

    var buf bytes.Buffer

    _, err = io.Copy(&buf, fd)
    if err != nil {
        die("dial read", err)
    }

    fmt.Printf("Read %d bytes\n", buf.Len())
    // 可以将buf.Bytes() 用于后续处理
}

在这个修改后的版本中，我们使用bytes.Buffer作为io.Writer，并将从网络连接读取的所有数据写入到这个buffer中。io.Copy会一直读取数据直到连接关闭或发生错误。

更进一步：写入文件

如果需要将数据写入文件，可以使用os.File代替bytes.Buffer：

package main

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

func die(msg string, s error) {
    fmt.Printf("%s crashed: %v\n", msg, s)
    os.Exit(1)
}

func main() {
    fd, err := net.Dial("tcp", "google.com:80")
    if err != nil {
        die("dial", err)
    }
    defer fd.Close() // 确保连接关闭

    req := []byte("GET /intl/en/privacy/ HTTP/1.0\r\nHost: www.google.com\r\n\r\n")
    _, err = fd.Write(req)
    if err != nil {
        die("dial write", err)
    }

    file, err := os.Create("privacy_policy.html")
    if err != nil {
        die("create file", err)
    }
    defer file.Close()

    _, err = io.Copy(file, fd)
    if err != nil {
        die("dial read", err)
    }

    fmt.Println("Successfully downloaded privacy policy to privacy_policy.html")
}

总结与注意事项