为何带go关键字的log.Fatal(http.ListenAndServe)仍阻塞主进程？

首先澄清你的误解：go log.Fatal(http.ListenAndServe(*streamAddr, nil))并没有阻塞主函数——你看到控制台只打印到Println 5，是因为主函数执行完这行后，立刻进入了select语句并阻塞等待中断信号，Println(6)其实已经执行了，只是可能被后续的输出（或者无额外输出）掩盖，你可以仔细检查控制台的完整内容。

真正的核心问题是程序无法响应Ctrl+C终止，以及清理逻辑无法执行，根源在这几个地方：

1. log.Fatal的致命误用 #

log.Fatal()的本质是打印错误日志后直接调用os.Exit(1)终止整个程序。如果http.ListenAndServe因为任何原因返回（比如端口占用、启动失败），这个goroutine会立刻终止整个进程，导致主函数里的清理代码（关闭hub通道、等待hub清理完成）完全没机会运行。即使服务器正常启动，这个写法也埋下了隐患——一旦服务器出错，程序会直接崩掉，没有优雅退出的机会。

2. 中断信号处理与Hub清理的配合问题 #

你的主函数在收到中断信号后，执行close(hub.KillChan)然后等待<-hub.KilledChan，但如果你的hub.Run()逻辑里，没有在收到KillChan关闭的信号后向KilledChan发送数据（或者关闭KilledChan），主函数会一直阻塞在<-hub.KilledChan这一行，看起来就像程序无法响应Ctrl+C一样。

3. HTTP服务器没有优雅关闭 #

直接使用http.ListenAndServe无法优雅关闭服务器，当你触发中断时，HTTP服务器可能还在处理连接，导致程序无法快速退出，甚至忽略信号。

修复后的完整代码示例 #

我把你的代码重构为更健壮的版本，解决上述所有问题：

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

    // 导入你的socktools包
)

func main() {
    fmt.Println(1)
    flag.Parse()
    log.SetFlags(0)
    fmt.Println(2)

    interrupt := make(chan os.Signal, 1)
    signal.Notify(interrupt, os.Interrupt, syscall.SIGTERM)
    fmt.Println(3)

    hub := socktools.NewHub()
    go hub.Run()
    fmt.Println(4)

    http.HandleFunc("/stream", func(w http.ResponseWriter, r *http.Request) {
        socktools.ServeWs(hub, w, r)
    })
    fmt.Println(5)

    // 使用http.Server替代直接调用ListenAndServe，支持优雅关闭
    server := &http.Server{
        Addr:    *streamAddr,
        Handler: http.DefaultServeMux,
    }

    // 启动HTTP服务器，自己处理错误，避免用log.Fatal
    go func() {
        err := server.ListenAndServe()
        if err != nil && !errors.Is(err, http.ErrServerClosed) {
            log.Printf("HTTP server encountered error: %v", err)
            // 通知主函数服务器出错，需要退出
            interrupt <- syscall.SIGTERM
        }
    }()
    fmt.Println(6)

    select {
    case sig := <-interrupt:
        fmt.Printf("Received signal: %v, starting shutdown...\n", sig)

        // 优雅关闭HTTP服务器，等待现有连接处理完成
        ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
        defer cancel()
        if err := server.Shutdown(ctx); err != nil {
            log.Printf("HTTP server shutdown failed: %v", err)
        }

        // 触发Hub的清理逻辑
        close(hub.KillChan)
        // 等待Hub完成清理
        <-hub.KilledChan
        fmt.Println("Ending main function")
        return
    }
}

同时，请确保你的socktools.Hub实现正确处理关闭信号，比如：

// 示例Hub结构（根据你的实际代码调整）
type Hub struct {
    Clients    map[*Client]bool
    KillChan   chan struct{}
    KilledChan chan struct{}
    // 其他字段...
}

func (h *Hub) Run() {
    for {
        select {
        case <-h.KillChan:
            // 执行清理：关闭所有客户端连接
            for client := range h.Clients {
                close(client.Send)
                delete(h.Clients, client)
            }
            // 通知主函数清理完成
            h.KilledChan <- struct{}{}
            close(h.KilledChan) // 可选，关闭通道避免泄漏
            return
        // 处理其他Hub逻辑...
        }
    }
}

关键修复点总结 #

• 替换log.Fatal为自定义错误处理，避免在goroutine里直接终止程序
• 使用http.Server实现优雅关闭，确保现有连接正常处理完再退出
• 确保Hub的Run()方法在收到关闭信号后，向KilledChan发送信号，让主函数可以正常退出
• 添加对SIGTERM信号的监听，兼容更多终止场景

内容的提问来源于stack exchange，提问作者K. Rhoda