Go 服务器中出现"Connection Reset by Peer"错误的原因是什么？

从现在开始，努力学习吧！本文《Go 服务器中出现"Connection Reset by Peer"错误的原因是什么？》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

我用 go 编写了一个基本的 web 服务器，但它似乎无法正确处理任何请求，而我得到的只是“接收失败：连接被对等方重置”。

我很高兴服务器确实正确启动和停止，并且我可以看到它正在侦听我配置的端口 8080。我还排除了解析 yaml 配置文件的问题 - 它肯定会被解析到 http.server{}。

我不太确定还需要检查什么，并且正在努力寻找任何能指引我正确方向的东西。

我还要提前道歉，因为我知道我在下面粘贴了大量代码，但我真的不知道错误是从哪里来的。

鉴于服务器正在运行，当我点击“/”端点/路由时，我希望得到“hello from go！”回来了。

目录结构

❯ tree . | grep -ie 'cmd|server.go|go.mod|go.sum|server.yaml'
├── cmd
│   └── server.go
├── go.mod
├── go.sum
└── server.yaml

服务器.go

package main

import (
    "context"
    "errors"
    "fmt"
    "log"
    "net/http"
    "os"
    "os/signal"
    "syscall"
    "time"

    "gopkg.in/yaml.v3"
)

type config struct {
    port            string `yaml:"port"`
    readtimeout     int    `yaml:"readtimeout"`
    writetimeout    int    `yaml:"writetimeout"`
    idletimeout     int    `yaml:"idletimeout"`
    shutdowntimeout int    `yaml:"shutdowntimeout"`
    errorlog        string `yaml:"errorlog"`
}

func main() {
    if len(os.args) != 2 {
        log.fatal("missing arguments")
    }

    configfile, err := os.open(os.args[1])
    if err != nil {
        log.fatal(err)
    }
    defer configfile.close()

    // todo: implement a custom servemux + routes

    serverconfig := config{}
    yamldecoder := yaml.newdecoder(configfile)
    err = yamldecoder.decode(&serverconfig)
    if err != nil {
        log.fatal(err)
    }

    errorlogfile, err := os.openfile(serverconfig.errorlog, os.o_create|os.o_wronly|os.o_append, 0666)
    if err != nil {
        log.fatal(err)
    }
    defer errorlogfile.close()
    errorlog := log.new(errorlogfile, "error : ", log.lstdflags|log.lshortfile)

    server := &http.server{
        addr:         fmt.sprintf(":%s", serverconfig.port),
        readtimeout:  time.duration(serverconfig.readtimeout),
        writetimeout: time.duration(serverconfig.writetimeout),
        idletimeout:  time.duration(serverconfig.idletimeout),
        errorlog:     errorlog,
    }

    http.handlefunc("/", func(w http.responsewriter, r *http.request) {
        fmt.fprintln(w, "hello from go!")
    })

    log.println("starting the server...")
    go func() {
        err := server.listenandserve()
        if !errors.is(err, http.errserverclosed) {
            log.fatal(err)
        }
        log.println("stopped serving new connections")
    }()
    log.println("server started")

    sigchan := make(chan os.signal, 1)
    signal.notify(sigchan, syscall.sigint, syscall.sigterm)
    <-sigchan

    ctx, shutdown := context.withtimeout(context.background(), time.duration(serverconfig.shutdowntimeout)*time.second)
    defer shutdown()

    err = server.shutdown(ctx)
    if err != nil {
        log.fatal(err)
    }
    log.println("server gracefully stopped")
}

错误消息

❯ curl -v localhost:8080/
*   Trying ::1...
* TCP_NODELAY set
* Connected to localhost (::1) port 8080 (#0)
> GET / HTTP/1.1
> Host: localhost:8080
> User-Agent: curl/7.64.1
> Accept: */*
>
* Recv failure: Connection reset by peer
* Closing connection 0
curl: (56) Recv failure: Connection reset by peer

正确答案

正如评论中提到的，该问题与超时值太短有关 - 每个超时值 5 纳秒。这是因为 time.duration 表示为两个瞬间之间经过的时间（以 int64 纳秒计数表示）。所以我需要将其转换为秒，以获得我所期望的结果。

来自文档：

“duration 将两个瞬间之间经过的时间表示为 int64 纳秒 计数。该表示形式将最大可表示持续时间限制为大约 290 年。”

Reference

解决方案：

server := &http.Server{
    Addr:         fmt.Sprintf(":%s", serverConfig.Port),
    ReadTimeout:  time.Duration(serverConfig.ReadTimeout) * time.Second,
    WriteTimeout: time.Duration(serverConfig.WriteTimeout) * time.Second,
    IdleTimeout:  time.Duration(serverConfig.IdleTimeout) * time.Second,
    ErrorLog:     errorLog,
}

理论要掌握，实操不能落！以上关于《Go 服务器中出现"Connection Reset by Peer"错误的原因是什么？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！