Что такое Server-Sent Events?

2.2 Middle🔥 161 комментариев

#Python Core

Комментарии (1)

🐱

claude-haiku-4.5PrepBro AI23 мар. 2026 г.(ред.)

Ответ сгенерирован нейросетью и может содержать ошибки

Что такое Server-Sent Events?

Server-Sent Events (SSE) — это технология реального времени, которая позволяет серверу отправлять обновления данных клиенту по одностороннему HTTP соединению. В отличие от WebSocket, SSE использует стандартный HTTP/HTTPS протокол и требует только одного соединения от сервера к клиенту.

Принцип работы SSE

Браузер (клиент)
    ↓
Открывает HTTP соединение
    ↓
Сервер отправляет данные
    ↓
Браузер получает события
    ↑
Соединение остаётся открытым
    ↑
Сервер может отправлять новые события в любой момент

HTTP или WebSocket?

Параметр	SSE (Server-Sent Events)	WebSocket
Направление	Server → Client (one-way)	Bidirectional (both ways)
Protocol	HTTP/HTTPS	WebSocket protocol
Сложность	Проще	Сложнее
Нагрузка	Ниже	Выше
Use case	Уведомления, live feed	Chat, real-time games
Автопереподключение	Встроено	Нужно реализовывать

Реализация на Python (Flask)

# server.py
from flask import Flask, Response
import time
import json
from datetime import datetime

app = Flask(__name__)

# Простой пример: отправка события каждые 2 секунды
@app.route('/events')
def events():
    """
    Endpoint для SSE
    Возвращает данные потоком (stream)
    """
    def generate():
        for i in range(10):  # Отправить 10 событий
            data = {
                'message': f'Событие номер {i}',
                'timestamp': datetime.now().isoformat(),
            }
            # Формат SSE: data: {json_data}\n\n
            yield f"data: {json.dumps(data)}\n\n"
            time.sleep(2)  # Ждать 2 секунды перед следующим событием
    
    return Response(
        generate(),
        mimetype='text/event-stream',
        headers={
            'Cache-Control': 'no-cache',
            'Connection': 'keep-alive',
            'X-Accel-Buffering': 'no',  # Для Nginx
        }
    )

if __name__ == '__main__':
    app.run(debug=True)

Реализация на Python (Django)

# views.py
import json
from django.http import StreamingHttpResponse
from django.views import View
import time
from datetime import datetime

class EventStreamView(View):
    def get(self, request):
        def event_stream():
            for i in range(5):
                data = {
                    'id': i,
                    'message': f'Сообщение {i}',
                    'time': datetime.now().isoformat(),
                }
                # SSE формат
                yield f"data: {json.dumps(data)}\n\n"
                time.sleep(3)
        
        return StreamingHttpResponse(
            event_stream(),
            content_type='text/event-stream',
            headers={
                'Cache-Control': 'no-cache',
                'X-Accel-Buffering': 'no',
            }
        )

# urls.py
from django.urls import path
from . import views

urlpatterns = [
    path('events/', views.EventStreamView.as_view(), name='event_stream'),
]

Клиентский код (JavaScript)

// client.js
// Подключиться к SSE потоку
const eventSource = new EventSource('/events');

// Обработать входящие события
eventSource.onmessage = (event) => {
    const data = JSON.parse(event.data);
    console.log('Получено событие:', data);
    
    // Обновить UI
    const messageDiv = document.getElementById('messages');
    messageDiv.innerHTML += `<p>${data.message}</p>`;
};

// Обработать ошибки
eventSource.onerror = (error) => {
    console.error('Ошибка SSE:', error);
    eventSource.close();
};

// Закрыть соединение
function closeConnection() {
    eventSource.close();
}

HTML страница

<!DOCTYPE html>
<html>
<head>
    <title>Server-Sent Events Demo</title>
</head>
<body>
    <h1>Real-time Notifications</h1>
    <div id="messages"></div>
    <button onclick="closeConnection()">Закрыть соединение</button>
    
    <script src="client.js"></script>
</body>
</html>

Форматы SSE сообщений

# Различные варианты отправки SSE

# 1. Простое сообщение
yield "data: Hello World\n\n"

# 2. JSON
yield f"data: {json.dumps({'key': 'value'})}\n\n"

# 3. С ID события (для повторного подключения)
yield "id: 1\n"
yield "data: Message\n\n"

# 4. С типом события (для использования addEventListener)
yield "event: my_event\n"
yield "data: {data}\n\n"

# 5. Многострочное сообщение
yield "data: Line 1\n"
yield "data: Line 2\n\n"

Обработка разных типов событий на клиенте

// Слушать специфический тип события
const eventSource = new EventSource('/events');

// Слушать событие типа 'notification'
eventSource.addEventListener('notification', (event) => {
    const data = JSON.parse(event.data);
    showNotification(data.message);
});

// Слушать событие типа 'update'
eventSource.addEventListener('update', (event) => {
    const data = JSON.parse(event.data);
    updateUI(data);
});

// Слушать всё события (default type)
eventSource.onmessage = (event) => {
    console.log('Generic message:', event.data);
};

Практический пример: уведомления о заказах

# views.py — Flask
from flask import Flask, Response, session
import json
from datetime import datetime
from queue import Queue
import threading

app = Flask(__name__)
app.secret_key = 'secret'

# Очередь для каждого пользователя
user_queues = {}

@app.route('/user/<user_id>/events')
def user_events(user_id):
    """
    Отправлять события конкретному пользователю
    """
    # Создать очередь для пользователя
    if user_id not in user_queues:
        user_queues[user_id] = Queue()
    
    queue = user_queues[user_id]
    
    def generate():
        try:
            while True:
                # Получить событие из очереди
                event = queue.get(timeout=30)  # Timeout 30 секунд
                yield f"data: {json.dumps(event)}\n\n"
        except:
            pass
    
    return Response(
        generate(),
        mimetype='text/event-stream',
        headers={
            'Cache-Control': 'no-cache',
            'Connection': 'keep-alive',
            'X-Accel-Buffering': 'no',
        }
    )

@app.route('/order/<user_id>/create', methods=['POST'])
def create_order(user_id):
    """
    Создать заказ и отправить уведомление
    """
    order_data = {
        'event': 'new_order',
        'order_id': '12345',
        'status': 'confirmed',
        'timestamp': datetime.now().isoformat(),
    }
    
    # Отправить событие пользователю
    if user_id in user_queues:
        user_queues[user_id].put(order_data)
    
    return {'ok': True}

Преимущества SSE

Простота: использует стандартный HTTP
Автопереподключение: встроенное восстановление соединения
Меньше нагрузки: сравнение с polling (постоянные запросы)
ID событий: может сделать retry с конкретного события
Поддержка браузеров: есть во всех современных браузерах

Недостатки SSE

One-way только: сервер → клиент
Лимиты соединений: браузер может открыть ~6 SSE на домен
Прокси/firewall: может быть проблема с длительными соединениями
Масштабируемость: сложнее с горизонтальным масштабированием

Вывод

Server-Sent Events — это:

Технология отправки данных из сервера на клиент в реальном времени
Использует стандартный HTTP/HTTPS протокол
One-way соединение (сервер → клиент)
Идеально для уведомлений, live feed, прогресса
Проще чем WebSocket для простых сценариев
Встроенное автопереподключение
Отличный выбор для реал-тайм приложений