[HTTP] SSE, HTTP 정리

// 클라이언트: GET 요청 1회로 연결 시작
const eventSource = new EventSource('/events');
// 서버가 계속 데이터 푸시
eventSource.onmessage = (event) => {
  console.log(event.data);
};

클라이언트: 192.168.1.100:54321
      ↕  (이 4개 값이 하나의 소켓 쌍)
서버: 93.184.216.34:443

같은 소켓 쌍 유지:
GET /events →
           ← data: message1
           ← data: message2
           ← data: message3
           ... (연결 계속 유지)

1. 클라이언트 → 서버: 연결 요청
2. 방화벽: "이 세션 추적 시작"
3. 서버 → 클라이언트: 응답 및 지속적 데이터 전송
4. 방화벽: "허용된 세션이니 통과!"

1. 서버 → 클라이언트: 연결 시도
2. 방화벽: "요청하지 않은 연결, 차단!"

클라이언트                           서버
    |                                 |
    |--- GET /events ---------------->|
    |    Connection: keep-alive       |
    |    Accept: text/event-stream    |
    |                                 |
    |<-- 200 OK ---------------------|
    |    Content-Type: text/event-stream
    |    Cache-Control: no-cache     |
    |    Connection: keep-alive       |
    |                                 |
    |<-- data: message1 -------------|
    |<-- data: message2 -------------|
    |<-- data: message3 -------------|
    |        ... (연결 유지)          |

# 클라이언트 요청
GET /events HTTP/1.1
Accept: text/event-stream
Connection: keep-alive

# 서버 응답
HTTP/1.1 200 OK
Content-Type: text/event-stream
Cache-Control: no-cache
Connection: keep-alive

클라이언트                           서버
    |                                 |
    |--- GET /data ------------------>|
    |<-- 200 OK + 데이터 ------------|
    |                                 |
   연결 종료 (또는 풀로 반환)

클라이언트                           서버
    |                                 |
    |--- GET /events ---------------->|
    |<-- 200 OK ---------------------|
    |<-- data: msg1 -----------------|
    |<-- data: msg2 -----------------|
    |<-- data: msg3 -----------------|
    |        ... (계속 유지)          |

# 서버 입장
# ❌ 불가능: 클라이언트 IP/포트를 모름
socket.connect(('어디?', '몇 번 포트?'))

# ✅ 가능: 특정 포트에서 대기
socket.bind(('0.0.0.0', 80))
socket.listen()

클라이언트가 사용하는 포트는 매번 다름:
- 첫 번째 연결: 192.168.1.100:54321
- 두 번째 연결: 192.168.1.100:54322
- 세 번째 연결: 192.168.1.100:54323

서버는 클라이언트가 다음에 어떤 포트를 쓸지 알 수 없음

가정/회사 네트워크:

[클라이언트] ---> [NAT/방화벽] ---> [인터넷] ---> [서버]
  사설 IP         공인 IP 변환

클라이언트 → 서버: 가능 (NAT가 매핑 생성)
서버 → 클라이언트: 불가능 (매핑 없음, 차단됨)

클라이언트 역할:
- 연결 시작
- 요청 전송
- 서비스 소비자

서버 역할:
- 연결 대기
- 응답 전송
- 서비스 제공자

from fastapi import FastAPI
from fastapi.responses import StreamingResponse
import asyncio

app = FastAPI()

async def event_generator():
    """SSE 이벤트 생성기"""
    count = 0
    while True:
        count += 1
        # SSE 형식: "data: 메시지\n\n"
        yield f"data: Message {count}\n\n"
        await asyncio.sleep(1)

@app.get("/events")
async def sse_endpoint():
    """SSE 엔드포인트"""
    return StreamingResponse(
        event_generator(),
        media_type="text/event-stream",
        headers={
            "Cache-Control": "no-cache",
            "Connection": "keep-alive",
        }
    )

// SSE 연결 생성
const eventSource = new EventSource('/events');

// 메시지 수신
eventSource.onmessage = (event) => {
    console.log('받은 데이터:', event.data);
};

// 연결 열림
eventSource.onopen = () => {
    console.log('SSE 연결 성공');
};

// 에러 처리
eventSource.onerror = (error) => {
    console.error('SSE 에러:', error);
    eventSource.close();
};

// 연결 종료
// eventSource.close();

import httpx
import asyncio

async def consume_sse():
    """SSE 스트림 소비"""
    async with httpx.AsyncClient() as client:
        async with client.stream('GET', 'http://localhost:8000/events') as response:
            async for line in response.aiter_lines():
                if line.startswith('data: '):
                    data = line[6:]  # "data: " 제거
                    print(f'받은 데이터: {data}')

# 실행
asyncio.run(consume_sse())

data: 메시지 내용\n\n

data: 첫 번째 줄
data: 두 번째 줄
data: 세 번째 줄

event: userConnected
data: {"userId": 123}

event: messageReceived
data: {"text": "안녕하세요"}

id: 1
data: 첫 번째 메시지

id: 2
data: 두 번째 메시지

retry: 3000
data: 3초 후 재연결

클라이언트 → 서버: ❌ (초기 연결만 가능)
서버 → 클라이언트: ✅ (계속 가능)

같은 도메인에 대한 SSE 연결 제한:
- 대부분 브라우저: 6개
- 초과 시 새 연결 대기

✅ 가능: JSON, XML, 일반 텍스트
❌ 불가능: 바이너리 데이터 직접 전송

# 실시간 알림 예시
async def notification_stream(user_id: int):
    while True:
        notification = await get_user_notification(user_id)
        if notification:
            yield f"data: {notification.json()}\n\n"
        await asyncio.sleep(5)

# 이런 경우는 WebSocket 사용
# - 채팅 애플리케이션
# - 멀티플레이어 게임
# - 협업 도구 (실시간 문서 편집)
# - 화상 통화