RU
EN
ES
ZH
FR
DE
PT
AR
HI
js_student88
·
Что такое Long-Polling, WebSockets, SSE и Comet? Как реализовать их в PHP?
Разбираемся с технологиями реального времени в PHP
Ваш вопрос очень актуален. Давайте разложим все по полочкам. Вы уже правильно поняли суть, но давайте углубимся и посмотрим, как это работает на PHP.
1. Long-Polling (Длинный опрос)
Это эволюция обычного AJAX-опроса. Клиент отправляет запрос, но сервер не отвечает сразу, если данных нет. Он держит соединение открытым до появления новых данных или до таймаута (обычно 30-60 секунд). Как только данные появляются, сервер отправляет ответ, клиент его обрабатывает и сразу же открывает новое соединение.
Реализация на PHP (упрощенно):
```php // long_poll.php header('Content-Type: application/json'); header('Cache-Control: no-cache'); set_time_limit(60); // Максимальное время выполнения скрипта $lastId = $_GET['last_id'] ?? 0; $maxWait = 30; // Максимальное время ожидания в секундах $start = time(); while (true) { $messages = getNewMessages($lastId); if (!empty($messages)) { echo json_encode(['messages' => $messages, 'status' => 'new_data']); flush(); break; } // Если прошло больше maxWait секунд - отдаем пустой ответ if ((time() - $start) >= $maxWait) { echo json_encode(['messages' => [], 'status' => 'timeout']); flush(); break; } // Спим 0.5 секунды перед следующей проверкой usleep(500000); } ```Проблемы: Каждый запрос держит процесс PHP-FPM. При 1000 пользователей нужно 1000 процессов. Это убивает сервер.
2. Server-Sent Events (SSE) — События от сервера
Это односторонний канал: сервер может отправлять данные клиенту, но не наоборот (для отправки на сервер используем обычный AJAX). SSE использует HTTP-протокол, работает через EventSource на клиенте. Отлично подходит для уведомлений, ленты новостей, курсов валют.
Реализация на PHP:
```php // sse.php header('Content-Type: text/event-stream'); header('Cache-Control: no-cache'); header('Connection: keep-alive'); set_time_limit(0); $lastId = 0; while (true) { $messages = getNewMessages($lastId); if (!empty($messages)) { foreach ($messages as $msg) { echo "id: {$msg['id']}\n"; echo "event: message\n"; echo "data: " . json_encode($msg) . "\n\n"; $lastId = $msg['id']; } ob_flush(); flush(); } // Проверяем, не закрыл ли клиент соединение if (connection_aborted()) break; sleep(2); } ```На клиенте (JavaScript):
```javascript const eventSource = new EventSource('sse.php'); eventSource.addEventListener('message', function(e) { const data = JSON.parse(e.data); console.log('Новое сообщение:', data); }); ```Проблемы: Те же, что и у Long-Polling — держит процесс PHP. Поддерживается не всеми браузерами (IE не поддерживает).
3. WebSockets — Полный дуплекс
Это полноценный двусторонний канал поверх TCP. После установки соединения (через HTTP-рукопожатие) данные передаются в реальном времени в обе стороны. Для PHP существуют специальные библиотеки:
- Ratchet — самая популярная библиотека WebSocket для PHP
- ReactPHP — асинхронный PHP, на котором можно строить WebSocket серверы
- Swoole — расширение для PHP, которое добавляет асинхронность
Пример с Ratchet:
```php use Ratchet\MessageComponentInterface; use Ratchet\ConnectionInterface; class Chat implements MessageComponentInterface { protected $clients; public function __construct() { $this->clients = new \SplObjectStorage; } public function onOpen(ConnectionInterface $conn) { $this->clients->attach($conn); echo "Новое подключение: {$conn->resourceId}\n"; } public function onMessage(ConnectionInterface $from, $msg) { foreach ($this->clients as $client) { if ($from !== $client) { $client->send($msg); } } } public function onClose(ConnectionInterface $conn) { $this->clients->detach($conn); } public function onError(ConnectionInterface $conn, \Exception $e) { $conn->close(); } } ```4. Comet — Устаревшая концепция
Comet — это общее название для техник "push-уведомлений" через HTTP (Long-Polling, Forever Frame, XHR Streaming). Сейчас этот термин практически не используется, так как его вытеснили WebSockets и SSE.
Что выбрать для чата?
Для чата однозначно WebSockets — это единственное решение, которое обеспечит реальную двустороннюю связь без нагрузки на сервер. Если PHP — ваш основной язык, используйте Ratchet или Swoole. Если хотите что-то попроще — посмотрите на Pusher или Socket.io (но это уже не чистый PHP).
Для простых уведомлений (например, "у вас новое сообщение") подойдет SSE. Для всего остального — WebSockets.
<<Альтернативный подход: гибридное решение с Redis и SSE
Если вы не хотите полностью переходить на WebSockets, но обычный polling вас не устраивает, можно использовать гибридный подход: SSE для отправки данных клиенту + AJAX для отправки данных на сервер + Redis Pub/Sub для обмена сообщениями между процессами PHP.
Схема работы:
- Клиент подключается через SSE к PHP-скрипту
- PHP-скрипт подписывается на канал Redis (SUBSCRIBE)
- Когда другой пользователь отправляет сообщение (через AJAX), PHP публикует его в Redis (PUBLISH)
- Все подписанные SSE-скрипты получают сообщение и отправляют его клиенту
Код для отправки через AJAX:
```php // send_message.php $message = $_POST['message'] ?? ''; if ($message) { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->publish('chat_channel', json_encode([ 'user' => $_SESSION['user_id'], 'message' => $message, 'time' => time() ])); } ```SSE-скрипт с Redis:
```php // sse_redis.php header('Content-Type: text/event-stream'); set_time_limit(0); $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->setOption(Redis::OPT_READ_TIMEOUT, -1); $redis->subscribe(['chat_channel'], function($redis, $channel, $message) { echo "data: $message\n\n"; ob_flush(); flush(); }); ```Плюсы: Не нужно держать отдельный WebSocket-сервер, легко масштабируется (можно добавить несколько PHP-воркеров).
Минусы: Все еще держит процессы PHP (но с Redis они легче), требуется установка Redis.
Этот подход — хороший компромисс
