Go net/http 服务器错误：accept tcp [::]:443:accept4:打开文件太多；重试

Question

这是我的服务器：

package main

import (
        "my-project/pkg/configuration"
        "my-project/pkg/logger"
        "my-project/pkg/server/appConfig"
        "my-project/pkg/server/handlers"
        "net/http"
        "os"
        "strings"
)

func main() {

        if len(os.Args) < 2 {
                logger.Log("error", "main", "Missing config.json file path as argument")
                return
        }

        configuration := configuration.Configuration{}
        appConfig.InitConfig(os.Args[1], &configuration)

        // download file
        http.HandleFunc("/file-download", handlers.DownloadFile(&configuration))

        // upload file
        http.HandleFunc("/file-upload", handlers.UploadFile(&configuration))

        // Get url
        http.HandleFunc("/file-url", handlers.GetUrl(&configuration))

        // Delete
        http.HandleFunc("/delete", handlers.DeleteHandler(&configuration))

        // file system
        fs := http.FileServer(http.Dir(configuration.RootStoragePath))
        corsFS := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
                if strings.HasSuffix(r.URL.Path, "/") {
                        http.NotFound(w, r)
                        return
                }
                w.Header().Add("Access-Control-Allow-Origin", "*")
                fs.ServeHTTP(w, r)
        })

        http.Handle("/", corsFS)

        err := http.ListenAndServeTLS(":443", "crt/server.crt", "crt/server.key", nil)
        if err != nil {
                logger.Log("error", "ListenAndServeTLS", err.Error())
        }
}

服务器负载中等。 服务器运行一天后崩溃了， 我收到以下错误：

http: Accept error: accept tcp [::]:443: accept4: too many open files; retrying

命令：

ls -ltr /proc/{PROCESS_ID}/fd

文件列表和套接字：[XXXXXX] 一直在增长。 我不想更改 ulimit (1024)，我不认为这是一个长期修复...

我真的不明白问题可能来自哪里...在处理程序中，我操作文件，但我注意延迟 Close()... 我必须设置超时吗？如果是的话在哪里？

预先感谢您的所有帮助...

Answer 1

我终于找到了解决方案。

事实上，net/http 包的 http.ListenAndServe 方法默认没有超时。这是 Go 团队自愿的。因此，对于生产中的服务，有必要声明一个 http.Server{} 并配置它。 Go 文档。
来源：Cloudflare 博客文章

        srv := &http.Server{
                Addr:         ":443",
                ReadTimeout:  30 * time.Second,
                WriteTimeout: 120 * time.Second,
        }   
        srv.SetKeepAlivesEnabled(false)

        err := srv.ListenAndServeTLS("crt/server.crt", "crt/server.key")

http.DefaultServeMux 是默认的请求多路复用器，HandleFunc 在 DefaultServeMux 中注册给定模式的处理函数。
这是实现：

func main() {

        if len(os.Args) < 2 { 
                logger.Log("error", "main", "Missing config.json file path as argument")
                return
        }

        configuration := configuration.Configuration{}
        appConfig.InitConfig(os.Args[1], &configuration)

        // download file
        http.HandleFunc("/file-download", handlers.DownloadFile(&configuration))

        // upload file
        http.HandleFunc("/file-upload", handlers.UploadFile(&configuration))

        // Get url
        http.HandleFunc("/file-url", handlers.GetUrl(&configuration))

        // Delete
        http.HandleFunc("/delete", handlers.DeleteHandler(&configuration))

        // file system
        fs := http.FileServer(http.Dir(configuration.RootStoragePath))
        corsFS := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
                if strings.HasSuffix(r.URL.Path, "/") {
                        http.NotFound(w, r)
                        return
                }   
                w.Header().Add("Access-Control-Allow-Origin", "*")
                fs.ServeHTTP(w, r)
        })

        http.Handle("/", corsFS)

        srv := &http.Server{
                Addr:         ":443",
                ReadTimeout:  30 * time.Second,
                WriteTimeout: 120 * time.Second,
        }   
        srv.SetKeepAlivesEnabled(false)

        err := srv.ListenAndServeTLS("crt/server.crt", "crt/server.key")
        if err != nil {
                logger.Log("error", "ListenAndServeTLS", err.Error())
                os.Exit(1)
        }
}

如果您有任何其他建议，我显然很感兴趣。