golang 关闭websocket

在Golang中，使用WebSocket进行实时通信是一种非常常见的做法。然而，当我们不再需要WebSocket连接时，我们需要优雅地关闭WebSocket以释放资源，避免资源泄漏和内存泄漏。本文将介绍如何在Golang中关闭WebSocket连接。

使用Context进行关闭

在Golang中，我们可以使用context来进行WebSocket的关闭。通过使用context，我们可以传递一个取消信号，告诉WebSocket连接关闭。下面是一个示例代码：

func handleWebSocket(conn *websocket.Conn) {
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()
    
    go func() {
        for {
            select {
            case <-ctx.Done():
                return
            default:
                // 处理WebSocket数据
            }
        }
    }()
    
    // 等待WebSocket关闭
    for {
        _, _, err := conn.ReadMessage()
        if err != nil {
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) {
                log.Printf("error: %v", err)
            }
            break
        }
    }
}

在上述代码中，我们首先创建了一个context，并使用defer语句调用了cancel函数，以确保在函数返回时取消context。接下来，我们启动了一个goroutine，在其中处理WebSocket的数据。在主goroutine中，我们使用conn.ReadMessage()等待WebSocket的关闭。当ReadMessage函数返回错误时，我们判断该错误是否是预期的关闭错误，如果不是，则打印错误日志并退出循环。

捕获系统信号关闭

除了使用context进行关闭外，我们还可以通过捕获系统信号来关闭WebSocket连接。下面是一个示例代码：

func handleWebSocket(conn *websocket.Conn) {
    // 定义一个通道用于接收系统信号
    signals := make(chan os.Signal, 1)
    signal.Notify(signals, os.Interrupt, syscall.SIGTERM)
    
    go func() {
        for _ = range signals {
            conn.Close()
            break
        }
    }()
    
    // 处理WebSocket数据
    for {
        _, _, err := conn.ReadMessage()
        if err != nil {
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) {
                log.Printf("error: %v", err)
            }
            break
        }
    }
}

在上述代码中，我们首先定义了一个通道来接收系统信号，并使用signal.Notify函数将指定的系统信号发送到该通道。接下来，我们启动了一个goroutine，在其中监听通道的消息，并当收到消息时关闭WebSocket连接。在主goroutine中，我们使用conn.ReadMessage()等待WebSocket的关闭，与前面的示例代码相同。

优雅地关闭WebSocket连接

在实际应用中，我们通常会有一些清理工作需要在关闭WebSocket连接之前完成。为了实现优雅地关闭WebSocket连接，我们可以使用sync.WaitGroup来等待所有清理工作完成。下面是一个示例代码：

func handleWebSocket(conn *websocket.Conn) {
    var wg sync.WaitGroup
    defer wg.Wait()
    
    // 处理清理工作
    defer func() {
        // 等待所有清理工作完成
        wg.Done()
        
        // 清理工作代码
        // ...
    }()
    
    // 处理WebSocket数据
    for {
        _, _, err := conn.ReadMessage()
        if err != nil {
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) {
                log.Printf("error: %v", err)
            }
            break
        }
    }
}

在上述代码中，我们首先定义了一个WaitGroup，并使用defer语句调用了Wait函数，以确保在函数返回时等待所有清理工作完成。接下来，我们在defer语句中定义了一个匿名函数，在其中实现清理工作，并令WaitGroup的计数减一。在主goroutine中，我们使用conn.ReadMessage()等待WebSocket的关闭，与前面的示例代码相同。

总而言之，关闭WebSocket连接是Golang开发中一个重要的技巧。通过使用Context、捕获系统信号和优雅地关闭方式，我们可以避免资源泄漏和内存泄漏，提高应用的稳定性和可靠性。