Go 언어 웹소켓 개발 실습: 예외를 처리하고 연결을 닫는 방법-Golang-php.cn

Go 언어 웹소켓 개발 실습: 예외를 처리하고 연결을 닫는 방법

王林

풀어 주다： 2023-12-14 13:40:21

원래의

1462명이 탐색했습니다.

Go 언어 웹소켓 개발 실습: 예외를 처리하고 연결을 닫는 방법

Go 언어 웹소켓 개발 실습: 비정상적인 연결 종료 처리 방법

소개:
웹 개발에서 웹소켓 프로토콜은 일반적으로 실시간 데이터 전송에 사용되는 양방향 통신을 구현하는 데 사용할 수 있습니다. 채팅 애플리케이션 및 기타 시나리오. 그러나 Websocket을 사용하면 네트워크 변동, 비정상적인 클라이언트 종료 등 예상치 못한 연결 중단이 발생하기 쉽습니다. 이러한 경우 비정상적인 연결 종료를 어떻게 처리할 것인지, 그리고 애플리케이션의 안정성과 신뢰성을 확보할 것인지는 개발 과정에서 중점을 두어야 할 문제가 되었습니다. 이 기사에서는 샘플 코드를 결합하고 Go 언어를 예로 들어 예외를 처리하고 연결을 닫는 방법을 소개합니다.

1. Websocket 서버 생성:
먼저 간단한 Websocket 서버를 생성해야 합니다. 다음은 기본 샘플 코드입니다.

package main

import (
    "fmt"
    "github.com/gorilla/websocket"
    "net/http"
)

// 定义Websocket读写的缓冲区大小
const bufferSize = 1024

// Websocket处理函数
func wsHandler(w http.ResponseWriter, r *http.Request) {
    // 升级HTTP连接为Websocket连接
    conn, err := websocket.Upgrade(w, r, nil, bufferSize, bufferSize)
    if err != nil {
        fmt.Println("Failed to upgrade the connection to websocket: ", err)
        return
    }

    for {
        // 读取客户端发送的消息
        messageType, message, err := conn.ReadMessage()
        if err != nil {
            fmt.Println("Failed to read message from client: ", err)
            break
        }

        // 处理接收到的消息
        handleMessage(conn, messageType, message)
    }

    // 关闭连接
    defer conn.Close()
}

// 处理接收到的消息
func handleMessage(conn *websocket.Conn, messageType int, message []byte) {
    // 处理消息的逻辑
    fmt.Println("Received message: ", string(message))
}

로그인 후 복사

2. 비정상적인 연결 종료 처리:
클라이언트가 비정상적으로 종료되면 서버는 연결이 종료되었음을 올바르게 감지하고 그에 따라 처리할 수 있어야 합니다. 다음은 비정상적으로 종료된 연결을 처리하는 방법에 대한 샘플 코드입니다.

// Websocket处理函数
func wsHandler(w http.ResponseWriter, r *http.Request) {
    // 升级HTTP连接为Websocket连接
    conn, err := websocket.Upgrade(w, r, nil, bufferSize, bufferSize)
    if err != nil {
        fmt.Println("Failed to upgrade the connection to websocket: ", err)
        return
    }

    // 异常关闭连接处理协程
    go handleCloseConnection(conn)

    for {
        // 读取客户端发送的消息
        messageType, message, err := conn.ReadMessage()
        if err != nil {
            // 检测到连接异常关闭的错误
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
                fmt.Println("Connection closed unexpectedly: ", err)
                break
            }
            // 其他错误处理
            fmt.Println("Failed to read message from client: ", err)
            break
        }

        // 处理接收到的消息
        handleMessage(conn, messageType, message)
    }

    // 关闭连接
    conn.Close()
}

// 异常关闭连接处理协程
func handleCloseConnection(conn *websocket.Conn) {
    // 读取关闭消息，表示客户端主动关闭连接
    _, _, err := conn.ReadMessage()
    if err != nil {
        fmt.Println("Failed to read close message from client: ", err)
    }

    // 处理连接关闭后的逻辑
    fmt.Println("Connection closed by client")
}

로그인 후 복사

위의 샘플 코드에서는 IsUnexpectedCloseError 함수를 호출하여 연결이 비정상적으로 종료되었는지 여부를 확인합니다. 연결이 비정상적으로 닫히면 해당 오류 메시지가 기록되고 루프가 점프되어 연결이 닫힙니다. 또한 연결이 닫힌 후 논리를 처리하기 위해 handleCloseConnection이라는 코루틴 함수도 추가했습니다. IsUnexpectedCloseError函数来判断连接是否异常关闭。如果是异常关闭的情况，则记录相应的错误信息，并跳出循环，关闭连接。另外，我们还添加了一个名为handleCloseConnection的协程函数，用于处理连接关闭后的逻辑。

结论：
在开发Websocket应用时，处理异常关闭连接是非常重要的一环。通过使用IsUnexpectedCloseError

결론:

웹소켓 애플리케이션을 개발할 때 예외 처리 및 연결 종료는 매우 중요한 단계입니다. IsUnexpectedCloseError 함수와 코루틴 처리를 사용하면 비정상적인 연결 종료를 감지하고 처리하여 연결 예외로 인한 애플리케이션 충돌을 방지할 수 있습니다. 실제 애플리케이션에서는 로그 기록, 알림 전송 등과 같은 특정 요구에 따라 해당 확장을 수행하여 애플리케이션의 신뢰성과 유지 관리성을 향상시킬 수 있습니다.