登录
首页 >  Golang >  Go问答

Go 客户端程序生成大量处于 TIME_WAIT 状态的套接字

来源:Golang技术栈

时间:2023-03-09 15:08:56 333浏览 收藏

欢迎各位小伙伴来到golang学习网,相聚于此都是缘哈哈哈!今天我给大家带来《Go 客户端程序生成大量处于 TIME_WAIT 状态的套接字》,这篇文章主要讲到golang等等知识,如果你对Golang相关的知识非常感兴趣或者正在自学,都可以关注我,我会持续更新相关文章!当然,有什么建议也欢迎在评论留言提出!一起学习!

问题内容

我有一个 Go 程序,它从多个 goroutine 生成大量 HTTP 请求。运行一段时间后,程序吐出错误:连接:无法分配请求的地址。

与 检查时netstat,我在 中获得大量 (28229) 连接TIME_WAIT

TIME_WAIT当我的 goroutine 数量为 3 时,会出现大量套接字,并且当它为 5 时严重到足以导致崩溃。

我在 docker 下运行 Ubuntu 14.4 并运行 1.7 版

这是围棋程序。

package main

import (
        "io/ioutil"
        "log"
        "net/http"
        "sync"
)
var wg sync.WaitGroup
var url="http://172.17.0.9:3000/";
const num_coroutines=5;
const num_request_per_coroutine=100000
func get_page(){
        response, err := http.Get(url)
        if err != nil {
                log.Fatal(err)
        } else {
                defer response.Body.Close()
                _, err =ioutil.ReadAll(response.Body)
                if err != nil {
                        log.Fatal(err)
                }
        }

}
func get_pages(){
        defer wg.Done()
        for i := 0; i 

这是服务器程序:

package main

import (
    "fmt"
    "net/http"
    "log"
)
var count int;
func sayhelloName(w http.ResponseWriter, r *http.Request) {
    count++;
    fmt.Fprintf(w,"Hello World, count is %d",count) // send data to client side
}

func main() {
    http.HandleFunc("/", sayhelloName) // set router
    err := http.ListenAndServe(":3000", nil) // set listen port
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

正确答案

默认的 http.Transport 太快地打开和关闭连接。由于所有连接都指向相同的主机:端口组合,因此您需要增加MaxIdleConnsPerHost以匹配num_coroutines. 否则,传输将经常关闭额外的连接,只是让它们立即重新打开。

您可以在默认传输上全局设置:

http.DefaultTransport.(*http.Transport).MaxIdleConnsPerHost = numCoroutines

或者在创建自己的交通工具时

t := &http.Transport{
    Proxy: http.ProxyFromEnvironment,
    DialContext: (&net.Dialer{
        Timeout:   30 * time.Second,
        KeepAlive: 30 * time.Second,
    }).DialContext,
    MaxIdleConnsPerHost:   numCoroutines,
    MaxIdleConns:          100,
    IdleConnTimeout:       90 * time.Second,
    TLSHandshakeTimeout:   10 * time.Second,
    ExpectContinueTimeout: 1 * time.Second,
}

类似问题:[Go http.Get, concurrency, and "Connection reset by peer"](https://stackoverflow.com/questions/37774624/go-http-get-concurrency- and-connection-reset-by-peer)

本篇关于《Go 客户端程序生成大量处于 TIME_WAIT 状态的套接字》的介绍就到此结束啦,但是学无止境,想要了解学习更多关于Golang的相关知识,请关注golang学习网公众号!

声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表