Go에서 WebSocket 연결을 어떻게 유지하나요?

Go에서 WebSocket 연결 유지

실시간 통신이 필수적인 웹 애플리케이션에서는 서로 간의 연결을 보장하는 것이 중요합니다. 클라이언트와 서버는 비활성 기간에도 활성 상태를 유지합니다. Go의 websocket 패키지(code.google.com/p/go.net/websocket)의 맥락에서 이러한 활동 부족으로 인해 서버가 EOF 오류를 반환하고 연결이 중단될 수 있습니다.

WebSocket Heartbeat(Ping-Pong)

WebSocket 프로토콜에는 Ping-Pong이라는 하트비트 메커니즘이 포함되어 있습니다. 여기에는 클라이언트에서 서버로 핑 메시지를 보내고 그 대가로 서버로부터 퐁 응답을 받는 작업이 포함됩니다. 이러한 메시지를 정기적으로 교환하면 다른 데이터가 전송되지 않는 경우에도 연결을 유지하는 데 도움이 됩니다.

Go의 Websocket 패키지 지원

안타깝게도 code.google.com /p/go.net/websocket 패키지는 기본적으로 핑퐁 하트비트 메커니즘을 지원하지 않습니다. 따라서 연결을 유지하려면 대체 솔루션이 필요합니다.

맞춤 구현

한 가지 접근 방식은 Go의 채널과 타이머를 사용하여 맞춤 하트비트를 구현하는 것입니다. 이 솔루션에서 클라이언트는 일정한 간격(예: 5초마다)으로 서버에 하트비트 메시지를 보냅니다. 서버는 이러한 하트비트 메시지를 수신하고 승인으로 응답합니다. 서버가 지정된 제한 시간(예: 10초) 내에 하트비트를 수신하지 않으면 연결을 닫습니다.

다음은 고루틴을 사용하여 이러한 사용자 정의 하트비트 구현을 달성할 수 있는 방법의 예입니다.

<code class="go">func startHeartbeat(ws *websocket.Conn, timeout time.Duration) {
    heartbeatTicker := time.NewTicker(timeout)
    defer heartbeatTicker.Stop()

    go func() {
        for {
            select {
            case <-heartbeatTicker.C:
                ws.WriteMessage(websocket.PingMessage, []byte("heartbeat"))
            }
        }
    }()
}

// Server-side:
func handleConnection(ws *websocket.Conn) {
    startHeartbeat(ws, time.Second*10)
    for {
        _, _, err := ws.ReadMessage()
        if err != nil {
            ws.Close()
            break
        }
        // Handle incoming data ...
    }
}</code>

이 사용자 정의 구현은 클라이언트와 서버 간에 정기적인 하트비트가 유지되도록 보장하여 연결 시간 초과를 방지합니다. 또는 자동 재연결 및 정상적인 종료 처리 기능을 포함하여 웹소켓 하트비트에 대한 고급 지원을 제공하는 Go용 타사 라이브러리가 있습니다.

위 내용은 Go에서 WebSocket 연결을 어떻게 유지하나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!