Для чего нужен SignalR?

SignalR и его применение

SignalR — это библиотека от Microsoft для добавления real-time двусторонней коммуникации между сервером и клиентом в .NET приложениях. Хотя это не Python технология, я знаю её назначение и могу объяснить аналогичные решения в Python экосистеме.

Что такое SignalR:

SignalR автоматически выбирает лучший транспорт для real-time коммуникации:

1. WebSocket — предпочтительный протокол
2. Server-Sent Events (SSE) — однонаправленный канал от сервера к клиенту
3. Long Polling — клиент периодически спрашивает сервер (fallback)

Основные назначения SignalR:

1. Real-time уведомления Отправка событий сразу после их возникновения:

Сервер: Пользователь создал новый пост
↓
Все подписанные клиенты → Получают уведомление
↓
UI обновляется автоматически (без перезагрузки)

2. Live чат и мессенджеры Мгновенная доставка сообщений между пользователями.

3. Collaborative editing Редактирование документа несколькими пользователями одновременно (как Google Docs).

4. Live dashboards и мониторинг Обновление метрик и графиков в реальном времени.

5. Игры с multiplayer Синхронизация состояния игры между игроками.

Архитектура SignalR:

Клиент (JavaScript)       Сервер (.NET)
     ↓                         ↑
  WebSocket ←─────────────→ Hub
     ↑                         ↓
  Автоматически выбирает    Управляет
  лучший транспорт         подключениями

Пример использования SignalR на C#:

// Hub на сервере
public class ChatHub : Hub
{
    public async Task SendMessage(string message)
    {
        // Отправить всем подключённым клиентам
        await Clients.All.SendAsync("ReceiveMessage", message);
    }
    
    public async Task SendToUser(string userId, string message)
    {
        // Отправить конкретному пользователю
        await Clients.User(userId).SendAsync("ReceiveMessage", message);
    }
}

// На клиенте (JavaScript)
const connection = new signalR.HubConnectionBuilder()
    .withUrl("/chathub")
    .build();

connection.on("ReceiveMessage", (message) => {
    console.log("Получено:", message);
});

await connection.start();
await connection.invoke("SendMessage", "Hello!");

Аналоги в Python экосистеме:

1. WebSockets с FastAPI

from fastapi import WebSocket
from fastapi.applications import FastAPI

app = FastAPI()

class ConnectionManager:
    def __init__(self):
        self.active_connections = []
    
    async def connect(self, websocket: WebSocket):
        await websocket.accept()
        self.active_connections.append(websocket)
    
    async def disconnect(self, websocket: WebSocket):
        self.active_connections.remove(websocket)
    
    async def broadcast(self, message: str):
        for connection in self.active_connections:
            await connection.send_text(message)

manager = ConnectionManager()

@app.websocket("/ws/chat")
async def websocket_endpoint(websocket: WebSocket):
    await manager.connect(websocket)
    try:
        while True:
            data = await websocket.receive_text()
            await manager.broadcast(f"Message: {data}")
    except:
        manager.disconnect(websocket)

2. Socket.IO (самый популярный аналог)

from flask import Flask
from flask_socketio import SocketIO, emit, join_room

app = Flask(__name__)
socketio = SocketIO(app)

@socketio.on('connect')
def handle_connect():
    print('Client connected')
    emit('response', {'data': 'Connected to server'})

@socketio.on('message')
def handle_message(msg):
    print(f'Received message: {msg}')
    emit('message', msg, broadcast=True)

@socketio.on('join')
def on_join(data):
    username = data['username']
    room = data['room']
    join_room(room)
    emit('message', 
         f'{username} joined the room',
         to=room)

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

3. Django Channels (для Django)

from channels.generic.websocket import AsyncWebsocketConsumer
import json

class ChatConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.room_name = self.scope['url_route']['kwargs']['room_name']
        self.room_group_name = f'chat_{self.room_name}'
        
        # Присоединиться к группе
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )
        await self.accept()
    
    async def receive(self, text_data):
        data = json.loads(text_data)
        message = data['message']
        
        # Отправить всем в группе
        await self.channel_layer.group_send(
            self.room_group_name,
            {
                'type': 'chat_message',
                'message': message
            }
        )
    
    async def chat_message(self, event):
        message = event['message']
        await self.send(text_data=json.dumps({
            'message': message
        }))

Различия WebSocket vs SignalR:

Когда использовать real-time коммуникацию:

Нужна WebSocket/SignalR:

• Чат и мессенджеры
• Live уведомления
• Совместное редактирование
• Live трансляция данных
• Игры
• Live аналитика и мониторинг

Хватит REST API:

• Простые CRUD операции
• Один запрос — один ответ
• Нет критичности в скорости доставки
• Предсказуемые интервалы обновления

Оптимизация real-time приложений:

# Используй сжатие
from compress import compress

compressed = compress(json.dumps(data))
await websocket.send_bytes(compressed)

# Батчинг сообщений
queue = []
async def add_message(msg):
    queue.append(msg)
    if len(queue) >= 10:
        await broadcast(queue)
        queue.clear()

# Фильтрация подписчиков
for connection in active_connections:
    if connection.user_id in relevant_users:
        await connection.send_text(message)

SignalR в .NET и WebSocket/Socket.IO в Python — мощные инструменты для real-time приложений. Выбор зависит от платформы и требований проекта.