Python 및 Go를 사용하여 서버 전송 이벤트(SSE) 구현

오늘날의 대화형 웹 애플리케이션에서 실시간 데이터 업데이트는 사용자 경험을 향상시키는 데 매우 중요합니다. 다양한 실시간 통신 기술 중에서 SSE(Server-Sent Events)는 간단하면서도 효과적인 솔루션으로 돋보입니다. SSE를 사용하면 서버가 HTTP를 통해 클라이언트에 실시간 업데이트를 푸시할 수 있습니다.

SSE란 무엇인가요?

서버 전송 이벤트(SSE)는 서버가 클라이언트에 데이터를 사전에 푸시할 수 있도록 하는 데 사용되는 기술로, "이벤트 스트림"이라고도 합니다. 이는 HTTP 프로토콜을 기반으로 하며 수명이 긴 연결 특성을 활용합니다. SSE는 클라이언트와 서버 사이에 지속적인 연결을 설정하여 서버가 클라이언트에 실시간 데이터 업데이트를 보낼 수 있도록 합니다. 그러나 클라이언트는 SSE를 통해 서버로 데이터를 다시 보낼 수 없습니다.

SSE를 선택하는 이유는 무엇입니까?

서버 전송 이벤트는 HTML5 사양의 일부로, 서버에서 클라이언트로 이벤트를 푸시하도록 특별히 설계되었습니다. 단순성, 자동 재연결 및 이벤트 추적 기능은 단방향 데이터 흐름이 필요한 시나리오에 이상적입니다. SSE는 데이터가 한 방향으로 스트리밍될 때 탁월한 성능을 발휘합니다.

개요

SSE를 사용하면 서버가 메시지를 브라우저에 실시간으로 푸시할 수 있습니다. HTML5 사양의 일부로 다음이 포함됩니다.

• 통신 프로토콜: HTTP를 활용합니다.
• 이벤트 개체: 브라우저 측에서 사용할 수 있습니다.

WebSocket은 실시간 통신도 제공하지만 크게 다릅니다.

Feature	SSE	WebSockets
Protocol Basis	HTTP	TCP
Data Flow	Unidirectional (server to client)	Full-duplex (bidirectional)
Complexity	Lightweight and simple	More complex
Reconnection	Built-in	Manual implementation needed
Message Tracking	Automatic	Manual implementation needed
Data Types	Text or Base64-encoded binary	Various data types supported
Event Types Support	Custom events supported	Custom events not supported
Limitations	HTTP/1.1 or HTTP/2	Unlimited connections

서버 구현

프로토콜 구현

기본적으로 브라우저는 HTTP 요청을 시작하고 서버는 다음 헤더와 함께 HTTP 상태로 응답합니다.

Content-Type: text/event-stream
Cache-Control: no-cache
Connection: keep-alive

SSE는 이벤트 스트림의 MIME 유형이 text/event-stream이어야 함을 지정합니다. 브라우저는 데이터를 캐시해서는 안 되며 연결은 지속적으로 유지되어야 합니다(연결 유지).

메시지 형식

이벤트 스트림은 UTF-8로 인코딩된 텍스트 또는 gzip으로 압축된 Base64로 인코딩된 바이너리 메시지를 사용합니다. 각 메시지는 field-name : field-value 형식의 하나 이상의 필드로 구성됩니다. 각 필드는 n으로 끝납니다. 콜론으로 시작하는 줄은 주석이며 브라우저에서는 무시됩니다. 푸시의 여러 메시지는 빈 줄(nn)로 구분됩니다.

주요 필드는 다음과 같습니다.

• 이벤트: 이벤트 유형
• id: 재연결을 위해 마지막으로 수신된 이벤트를 추적하기 위해 브라우저에서 사용하는 이벤트 ID입니다.
• 재시도: 브라우저가 연결 실패 후 연결을 다시 시도할 때까지의 대기 시간(ms)입니다.
• 데이터: 메시지 데이터

예: Python을 사용한 SSE

다음은 Python을 사용한 구현입니다.

from flask import Flask, Response

app = Flask(__name__)

@app.route('/events')
def sse_handler():
    def generate():
        paragraph = [
            "Hello, this is an example of a continuous text output.",
            "It contains multiple sentences, each of which will be sent to the client as an event.",
            "This is to simulate the functionality of Server-Sent Events (SSE).",
            "We can use this method to push real-time updates.",
            "End of sample text, thank you!",
        ]

        for sentence in paragraph:
            yield f"data: {sentence}\n\n"

            import time
            time.sleep(1)

    return Response(generate(), mimetype='text/event-stream')

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8081, debug=True)

예: Go를 사용한 SSE

Go를 사용한 구현은 다음과 같습니다.

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"
)

func main() {
    http.HandleFunc("/events", sseHandler)

    fmt.Println("Starting server on :8080")
    if err := http.ListenAndServe(":8080", nil); err != nil {
        log.Fatalf("Server error: %v", err)
    }
}

func sseHandler(w http.ResponseWriter, r *http.Request) {
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "Streaming unsupported!", http.StatusInternalServerError)
        return
    }

    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    paragraph := []string{
        "Hello, this is an example of a continuous text output.",
        "It contains multiple sentences, each of which will be sent to the client as an event.",
        "This is to simulate the functionality of Server-Sent Events (SSE).",
        "We can use this method to push real-time updates.",
        "End of sample text, thank you!",
    }

    for _, sentence := range paragraph {
        _, err := fmt.Fprintf(w, "data: %s\n\n", sentence)
        if err != nil {
            return
        }
        flusher.Flush()
        time.Sleep(1 * time.Second)
    }
}

브라우저 API

클라이언트 측에서 JavaScript의 EventSource API를 사용하면 서버에서 보낸 이벤트를 수신하는 EventSource 개체를 생성할 수 있습니다. 연결되면 서버는 이벤트 메시지를 브라우저에 보낼 수 있습니다. 브라우저는 onmessage, onopen 및 onerror 이벤트를 수신하여 이러한 메시지를 처리합니다.

    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width,initial-scale=1.0">
    <title>SSE 예 ?</title>
머리>

    <h1 id="서버에서-보낸-이벤트-예">서버에서 보낸 이벤트 예 ?</h1>
    <div>



<h2>
  
  
  SSE 디버깅 도구
</h2>

<p>현재 Postman, Insomnia, Bruno, ThunderClient 등 널리 사용되는 많은 도구에는 SSE(서버 전송 이벤트) 디버깅에 대한 적절한 지원이 부족합니다. 이러한 제한은 개발 중에 상당히 실망스러울 수 있습니다. 다행스럽게도 EchoAPI는 탁월한 SSE 디버깅 기능을 제공하여 워크플로 효율성과 생산성을 크게 향상시킵니다.</p>

<p><img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/000/000/173482771419125.jpg?x-oss-process=image/resize,p_40" class="lazy" alt="Implementing Server-Sent Events (SSE) with Python and Go"></p>

<p>SSE 또는 API 디버깅 작업을 하고 있다면 EchoAPI를 사용해 보시기를 적극 권장합니다. 이는 디버깅 경험을 혁신하고 개발 프로세스를 간소화할 수 있습니다. 자세한 내용은 echoapi.com을 방문하세요. </p>
<h3>
  
  
  예: SSE용 EchoAPI 클라이언트
</h3>

<p>EchoAPI에서는 SSE 인터페이스를 사용하는 것이 간단합니다. URL을 입력하고 관련 매개변수를 입력한 후 "<strong>보내기</strong>"를 클릭하면 요청 결과를 볼 수 있습니다.</p>

<p><img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/000/000/173482771591634.jpg?x-oss-process=image/resize,p_40" class="lazy" alt="Implementing Server-Sent Events (SSE) with Python and Go"></p>


          </div>

            
        

위 내용은 Python 및 Go를 사용하여 서버 전송 이벤트(SSE) 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!