Уявіть: конференція на 10 000 учасників, організатори запускають голосування, а результати оновлюються раз на 30 секунд через звичайний AJAX-polling. Користувачі скаржаться на затримки, сервер падає від 10 000 запитів на секунду. Знайома ситуація? Обираючи real-time голосування, ви вирішуєте два завдання: миттєва доставка результатів та зниження навантаження на сервер. Наша команда має понад 5 років досвіду у розробці високонавантажених веб-систем і реалізувала такі рішення для 30+ проєктів — від корпоративних опитувань до масштабних прямих ефірів. Ми пропонуємо розробку систем голосування під ключ: від проектування до розгортання.
Чому SSE, а не polling?
Polling — це N запитів на секунду, де N — кількість користувачів. При 500 користувачах — 500 req/s даремно. SSE або WebSocket дають одне з'єднання на користувача, через яке сервер надсилає дані лише при зміні. Для голосувань підходять два механізми: SSE (Server-Sent Events) та WebSocket. Третій варіант — polling — не розглядаємо: 1 запит на секунду на 500 одночасних користувачів — це 500 req/s навантаження лише заради перевірки «нічого не змінилося». SSE — однонаправлений потік від сервера до клієнта, описаний у специфікації EventSource. Для опитувань в реальному часі цього достатньо: голос надсилається звичайним POST, результат приходить через SSE. WebSocket виправданий, якщо потрібен негайний зворотний зв'язок (анімація «ваш голос прийнято») або додаткові інтерактивні елементи. Зазначимо, що SSE у 3 рази простіший у реалізації, ніж WebSocket, при цьому покриває той самий базовий функціонал.
| Параметр | SSE | WebSocket |
|---|---|---|
| Напрямок | Однонаправлений (сервер → клієнт) | Двонаправлений |
| Складність реалізації | Низька (нативний EventSource) | Середня (потрібен WebSocket-сервер) |
| Інфраструктура | Не потребує sticky sessions | Потребує sticky session або окремий сервер |
| Продуктивність | До 10 000 з'єднань на один PHP-воркер | До 100 000 з'єднань на Node.js |
| Підтримка браузерів | Всі сучасні, крім IE | Всі сучасні |
Як запобігти дублюванню голосів?
Для авторизованих користувачів — unique constraint (option_id, user_id) та перевірка в контролері. Для анонімних голосувань — захист через IP + fingerprint. Fingerprint генерується на фронті (бібліотека fingerprintjs) і передається в заголовку. Це не абсолютний захист, але достатній для більшості випадків.
$fingerprint = $request->header('X-Client-Fingerprint'); $alreadyVoted = PollVote::where('poll_id', $poll->id) ->where(function ($q) use ($request, $fingerprint) { $q->where('ip', $request->ip()) ->orWhere('fingerprint', $fingerprint); })->exists(); Додатково можна використовувати Redis-блокування: Cache::lock('vote:'.$poll->id.':'.$userId, 10)->get() — це запобіжить одночасному надсиланню з одного акаунту.
Як масштабувати голосування на тисячі учасників?
PHP-застосунок з SSE тримає з'єднання відкритим. 1 000 одночасних користувачів = 1 000 PHP-воркерів. Це дорого. Рішення: винести broadcast через Pusher або Laravel Echo Server (socket.io). Тоді SSE-контролер більше не потрібен — клієнт підписується на канал, сервер публікує подію poll.updated в Redis, Laravel Echo транслює всім підписникам. Наприклад, для проєкту з 1000 учасників використання Pusher замість прямих SSE-воркерів може зменшити витрати на сервери з $500 до $150 на місяць — економія понад 70%.
// Після запису голосу broadcast(new PollUpdated($poll->id, $counts))->toOthers(); Echo.channel(`poll.${pollId}`) .listen('PollUpdated', ({ counts }) => updateBars(counts)); Така архітектура тримає сотні тисяч підключень на одному процесі Node.js. Для моніторингу використовуйте Laravel Horizon: він показує кількість активних SSE-воркерів та час відгуку. Pusher для голосування витримує навантаження у 2-3 рази більше, ніж власний SSE-воркер, при тих же витратах.
Схема даних та оптимізація
Схема бази даних
CREATE TABLE polls ( id BIGSERIAL PRIMARY KEY, title VARCHAR(500) NOT NULL, is_multiple BOOLEAN NOT NULL DEFAULT false, is_active BOOLEAN NOT NULL DEFAULT true, ends_at TIMESTAMP, created_at TIMESTAMP NOT NULL DEFAULT NOW() ); CREATE TABLE poll_options ( id BIGSERIAL PRIMARY KEY, poll_id BIGINT NOT NULL REFERENCES polls(id) ON DELETE CASCADE, label VARCHAR(255) NOT NULL, position SMALLINT NOT NULL DEFAULT 0 ); CREATE TABLE poll_votes ( id BIGSERIAL PRIMARY KEY, option_id BIGINT NOT NULL REFERENCES poll_options(id), user_id BIGINT REFERENCES users(id), ip INET, voted_at TIMESTAMP NOT NULL DEFAULT NOW(), UNIQUE(option_id, user_id) ); Агрегація рахується через materialized view або прямим COUNT. При піковому навантаженні (прямий ефір, 5 000+ учасників) краще зберігати лічильники окремо та інкрементувати через Redis: HINCRBY poll:42:counts 1 1.
Клієнтська частина та надсилання голосу
const pollId = 42; const source = new EventSource(`/api/polls/${pollId}/stream`); source.onmessage = (event) => { const { counts } = JSON.parse(event.data); updateBars(counts); }; source.onerror = () => { console.warn('SSE reconnecting...'); }; function updateBars(counts) { const total = Object.values(counts).reduce((a, b) => a + Number(b), 0); document.querySelectorAll('[data-option-id]').forEach(el => { const id = el.dataset.optionId; const pct = total > 0 ? Math.round((counts[id] || 0) / total * 100) : 0; el.querySelector('.bar').style.width = pct + '%'; el.querySelector('.label').textContent = pct + '%'; }); } async function vote(optionId) { const resp = await fetch(`/api/polls/${pollId}/vote`, { method: 'POST', headers: { 'Content-Type': 'application/json', 'X-CSRF-Token': csrfToken }, body: JSON.stringify({ option_id: optionId }), }); if (resp.status === 409) { showMessage('Ви вже голосували'); } } Як реалізувати SSE-ендпоінт на Laravel
Кроки реалізації:
- Створіть маршрут, що повертає streaming response.
- У контролері в циклі отримуйте поточну статистику через Redis або COUNT.
- Відправляйте дані у форматі SSE:
echo "data: {$data}\n\n";. - Додайте обов'язковий заголовок
X-Accel-Buffering: noдля Nginx. - Перевіряйте
connection_aborted()для коректного завершення.
Route::get('/api/polls/{poll}/stream', function (Poll $poll) { return response()->stream(function () use ($poll) { while (true) { if (connection_aborted()) break; $counts = PollVote::selectRaw('option_id, COUNT(*) as votes') ->whereIn('option_id', $poll->options->pluck('id')) ->groupBy('option_id') ->pluck('votes', 'option_id'); $data = json_encode(['counts' => $counts, 'ts' => now()->timestamp]); echo "data: {$data}\n\n"; ob_flush(); flush(); sleep(2); } }, 200, [ 'Content-Type' => 'text/event-stream', 'Cache-Control' => 'no-cache', 'X-Accel-Buffering' => 'no', ]); }); Як тестувати real-time голосування?
Використовуйте інструменти: Postman для надсилання голосів, k6 для навантажувального тестування, вбудовану консоль браузера для перевірки SSE-з'єднань. Основні сценарії: 1) перевірка отримання оновлень після голосування; 2) симуляція одночасних голосів від тисячі користувачів; 3) перевірка стійкості при обриві з'єднання (SSE автоматично перепідключається).
Типові помилки та їх вирішення
- N+1 запити: при отриманні списку голосів з підвантаженням опцій через lazy loading. Використовуйте
with('options')в Eloquent. - Відсутність
X-Accel-Buffering: без цього заголовка Nginx буферизує SSE-потік, і користувачі бачать дані пачками. - Ігнорування
connection_aborted(): без цього PHP-воркери продовжують висіти, споживаючи пам'ять. - Невживання Redis для лічильників: прямий COUNT з БД при кожному оновленні створює навантаження. Redis інкременти в рази швидші.
Що входить у роботу
- Технічне завдання та узгодження архітектури
- Розробка системи голосування під ключ
- Документація з інтеграції для вашої команди
- Навчання адміністраторів та розробників
- Налаштування моніторингу (Laravel Horizon або аналог)
- 30-денна гарантія на відсутність багів та підтримка після запуску
Строки розробки
| Етап | Час |
|---|---|
| Базове голосування (SSE, авторизовані) | 2–3 дні |
| Анонімне голосування + anti-duplicate | +1 день |
| Багатоваріантні опитування + історія | +1 день |
| Масштабування через Pusher/Echo | +2 дні |
| Адміністративний інтерфейс | 2–3 дні |
Ми пропонуємо реалізацію голосування на сайті з урахуванням усіх сучасних вимог. Наша команда має 5+ років досвіду та 30+ успішних проєктів. Пишіть нам, і ми оцінимо ваш проект за 1 день — отримайте детальний план і точні строки. Замовте консультацію, щоб переконатися, що ваше голосування працюватиме без збоїв при будь-якому навантаженні.