[FastAPI] SSE (Server-Sent Events)

1. Server-Sent Events

SSE(Server-Sent Events) 클라이언트가 서버에 연결을 유지한 채, 서버에서 발생하는 실시간 이벤트를 지속적으로 전달받는 방식

📌 “서버가 클라이언트에게 한 번 연결로 여러 번 응답을 보낼 수 있는 HTTP 기반 기술”

 

2. SSE 구조

• 클라이언트는 EventSource 객체를 통해 서버에 요청을 보냅니다.
• 서버는 text/event-stream 타입으로 응답을 보내고 연결을 유지한 채 여러 메시지를 전송합니다.
• 클라이언트는 서버로부터 받은 각 메시지를 실시간으로 처리합니다.

# Client
GET /stream HTTP/1.1
Accept: text/event-stream

 

# Response
event: data
data: Hello, world!

event: final
data: Done!

 

 

3. SSE와 WebSocket

방식	연결 방향	양방향	특징
SSE	서버 → 클라이언트	❌	구현이 간단하고 안정적, 브라우저 지원 좋음
WebSocket	양방향	✅	실시간 채팅, 게임 등 완전한 실시간 통신

 

 

4. SSE의 장점

1. HTTP 기반이라 설정이 쉬움

• SSE는 기존에 쓰던 HTTP 요청/응답 방식 그대로 사용 가능
• WebSocket처럼 별도로 복잡한 연결 설정 없이, GET 요청 보내고 서버가 text/event-stream 타입으로 데이터를 계속 보냄

2.자동 재연결 기능

• 브라우저에서 SSE를 사용할 땐, 서버와의 연결이 끊기면 자동으로 다시 연결
• 개발자가 특별히 신경 안 써도 되니까 편함.

3. HTTP/2도 지원

• HTTP/2는 최신 브라우저와 서버에서 사용하는 더 빠른 HTTP 프로토콜인데,
• SSE는 이 환경에서도 문제 없이 동작함.

4. 프록시/NAT 환경에서도 잘 동작함

• WebSocket은 프록시나 방화벽, 회사 내부망에서 막히는 경우가 많음.
• 반면 SSE는 일반 HTTP 트래픽이랑 똑같이 생겼기 때문에, 포트 80(HTTP)이나 443(HTTPS)으로 무리 없이 전달 가능.
• 방화벽이나 회사 네트워크 안에서도 잘 작동

 

5. SSE의 한계

1. 서버 → 클라이언트 단방향만 가능

• SSE는 서버가 클라이언트한테 일방적으로 데이터만 보낼 수 있음.
• 클라이언트가 서버에 무언가 전송하고 싶으면 별도의 POST나 WebSocket 등의 방식이 필요
• 양방향 대화(채팅, 게임 등)를 원한다면 WebSocket이 더 적합.

2. 오래된 브라우저에서는 동작하지 않을 수도 있음

• 현대 브라우저(Chrome, Edge, Safari 등)는 SSE를 잘 지원하지만, 아주 오래된 버전이나 Internet Explorer에선 동작하지 않을 수 있음

3. 브라우저 탭이 많으면 연결 수 초과 가능

• 브라우저는 한 도메인 당 유지 가능한 연결 수에 제한 있음
• 예를 들어, 탭 10개에서 모두 SSE 연결을 유지하면 브라우저가 더 이상 새 연결을 못 만들 수 있음.
• 그래서 탭마다 SSE를 쓰는 건 성능이나 자원 관리 측면에서 유의

 

 

6.  FastAPI 예시

from fastapi import FastAPI
from sse_starlette.sse import EventSourceResponse, ServerSentEvent
import asyncio

app = FastAPI()

@app.get("/sse")
async def stream():
    async def event_generator():
        for i in range(5):
            yield ServerSentEvent(
                event="progress",
                data=f"현재 단계: {i}",
            )
            await asyncio.sleep(1)

        yield ServerSentEvent(
            event="complete",
            data="✅ 작업이 완료되었습니다!"
        )

    return EventSourceResponse(event_generator())