Розробка аукціонної площадки: ставки, realtime, escrow

Розробка аукціонної площадки

Під час запуску аукціону з реальними грошима критична кожна мілісекунда. Уявіть: два учасники одночасно натискають «Ставка». Без коректної синхронізації може бути втрачена ставка або зарахована неправильна. Саме такі баги призводять до судових позовів і втрати довіри. Ми будуємо аукціонні платформи, де такі ситуації виключені на рівні архітектури.

Типи аукціонів

Як вирішується проблема race conditions?

Головна технічна складність — одночасні ставки двох учасників. Без коректного блокування можна втратити дані або допустити перебивку. Використовуємо оптимістичне блокування в PostgreSQL: атомарний UPDATE перевіряє версію запису та поточну ставку. Якщо зачеплено 0 рядків — ставка відхиляється.

UPDATE auctions
SET current_bid = $new_bid,
    current_bidder_id = $user_id,
    version = version + 1
WHERE id = $auction_id
  AND version = $expected_version
  AND current_bid < $new_bid;

При високих навантаженнях (тисячі ставок в секунду) PostgreSQL може стати вузьким місцем. Тоді застосовуємо Redis і Lua-скрипти — вони виконуються атомарно і швидше: Redis SETNX + Lua працює до 10 разів швидше на типових навантаженнях. В одному з проектів з 5000 одночасних учасників ми досягли 10 000 ставок в секунду з затримкою менше 10 мс.

Порівняння методів захисту

Як працюють realtime-оновлення?

Кожен учасник бачить нові ставки та час, що залишився, в реальному часі через WebSocket. При підключенні до аукціону відкривається сокет-з'єднання. При новій ставці сервер відправляє broadcast в кімнату аукціону: {auctionId, bidAmount, bidderAlias, remainingSeconds}. Таймер синхронізується з сервером кожні 10 секунд, щоб уникнути розсинхрону з клієнтом.

// Socket.io на сервері
io.to(`auction:${auctionId}`).emit('bid_placed', {
  bidAmount: bid.amount,
  bidderAlias: `Учасник ${bid.alias}`,
  remainingSeconds: auction.endsAt - Date.now()
});

Чому escrow критичний для аукціонів?

Після перемоги класична схема escrow: покупець платить на ескроу-рахунок → продавець відправляє товар → покупець підтверджує отримання → гроші перераховуються продавцю. Це знижує ризик шахрайства для обох сторін. У нашій практиці ця схема запобігла 95% спірних ситуацій. Ми реалізуємо escrow як окремий мікросервіс, інтегрований з платіжним шлюзом.

Депозити та блокування коштів

Для участі в торгах користувач вносить депозит. Реалізація через Stripe PaymentIntent з manual capture: гроші авторизовані, але не списані. Після перемоги — capture, після програшу — скасування авторизації. Такий підхід гарантує наміри учасника та безпеку коштів.

Система сповіщень

• Вас перебили → push / email негайно
• 1 година до закінчення → нагадування
• Перемога → привітання + інструкція по оплаті
• Аукціон завершено без перемоги → результати

Модерація лотів

Перед стартом лот проходить перевірку: відповідність правилам, документи на право власності (для дорогих товарів), підтвердження наявності. Це підвищує довіру користувачів до платформи.

Що входить в роботу

• Документація: архітектурний опис, API-специфікація, інструкція для адміністратора
• Доступи до репозиторію та dev-стенду
• Навчання команди замовника роботі з платформою
• Технічна підтримка на 3 місяці після запуску

Процес роботи

1. Аналітика: збираємо вимоги, визначаємо типи аукціонів, навантаження, інтеграції
2. Проектування: архітектура БД (PostgreSQL + Redis), схема WebSocket-каналів, API (REST/GraphQL), security (JWT, rate limiting)
3. Реалізація: ітеративна розробка з демо кожні 2 тижні
4. Тестування: навантажувальне тестування (до 10 000 одночасних ставок), юніт-тести, E2E
5. Деплой: на ваш сервер або хмару (AWS/Selectel/Beget), налаштування CI/CD (GitLab CI / GitHub Actions)
6. Запуск і підтримка: моніторинг (Prometheus + Grafana), баг-фіксинг, оптимізація

Які гарантії ми даємо?

Ми надаємо гарантію коректної роботи механізму ставок, таймерів та платежів. У разі багів — виправляємо безкоштовно протягом терміну підтримки. Наш досвід — понад 50 проектів у сфері торгових платформ за 10 років. Замовте консультацію прямо зараз, щоб обговорити ваш проект.

Строки та вартість

MVP (англійський аукціон, захист race conditions, WebSocket, базові сповіщення) — 3–4 місяці. Повноцінна платформа з proxy bidding, кількома типами аукціонів, депозитами, escrow — 5–8 місяців. Точна вартість розраховується індивідуально після аналізу вимог. Зв'яжіться з нами для консультації та оцінки вашого проекту.

Оцінка продуктивності: Redis atomic operations vs PostgreSQL row locking

Розробка систем реального часу: WebRTC, SSE, WebSocket

Ми знаємо, як боляче, коли полінг вбиває сервер. Один наш проєкт — платформа для онлайн-аукціонів — використовував полінг кожні 2 секунди. Під навантаженням у 400 учасників сервер отримував 12 000 HTTP-запитів на хвилину заради однієї ставки. 90% відповідей — пусті. Після переходу на WebSocket навантаження впало в 15 разів, економія серверних ресурсів — значна сума. Замовте розробку real-time функцій під ключ — отримайте готове рішення з гарантією стабільності.

Реалізація real-time на продакшні — не просто бібліотека. Ми проектуємо архітектуру під навантаження, сценарії та бюджет. Нижче — розбір ключових рішень з прикладами.

Три транспорти реального часу: коли що вибирати

Server-Sent Events працюють поверх звичайного HTTP/1.1 або HTTP/2. Браузер відкриває з'єднання, сервер тримає його відкритим і пушить події у форматі text/event-stream. Автоматичне перепідключення вбудоване — reconnect-логіка не потрібна. Обмеження: тільки сервер → клієнт. Ідеально для нотифікацій, прогресу довгих завдань, live-фідів.

WebSocket — повнодуплексний канал після HTTP Upgrade-рукопотискання. Браузер і сервер обмінюються фреймами в обидві сторони. Підходить для чатів, спільного редагування, ігор, торгових терміналів. Вимагає окремої обробки reconnect-логіки та heartbeat (ping/pong кожні 30 секунд, інакше NAT-таблиці закривають з'єднання).

WebRTC — peer-to-peer аудіо/відео та дані між браузерами напряму, минаючи сервер. Сервер потрібен лише для сигналізації (STUN/TURN для обходу NAT). TURN-сервер потрібен у 20–30% випадків (корпоративні мережі, симетричний NAT). Для сервісу телемедицини ми впровадили WebRTC: затримка звуку впала з 800 мс (через релей) до 50 мс (P2P). TURN-сервер знадобився лише 15% сесій, що зекономило значні кошти на трафіку.

WebSocket (Wikipedia) WebRTC (Wikipedia)

Як правильно вибрати транспорт: покрокова інструкція

1. Визначте сценарій обміну даними: однонаправлений (сервер → клієнт) — SSE; двонаправлений з низькою затримкою — WebSocket; аудіо/відео — WebRTC.
2. Оцініть вимоги до затримки. Якщо прийнятно <500 мс — підійде SSE; для <100 мс і двонаправленості — WebSocket; для <50 мс і P2P — WebRTC.
3. Перевірте бюджет на інфраструктуру. SSE використовує звичайні HTTP-сервери, WebSocket вимагає тримати з'єднання в пам'яті, WebRTC може потребувати TURN-сервер (додаткові витрати).
4. Врахуйте масштабування: для 100k+ з'єднань розгляньте WebSocket-gateway (Centrifugo, Pushpin).

Що таке CRDT і чим він кращий за Operational Transformation?

Спільне редагування — не просто «хто останній записав, той і правий». Без алгоритму злиття колізій два користувачі вставляють текст у позицію 45, перший зберігає — позиція зсувається, другий зберігає поверх — операція застосовується до застарілого стану. Текст дублюється або втрачається.

OT (Operational Transformation) потребує сервера для вирішення конфліктів, CRDT (Conflict-free Replicated Data Types) працює без централізованого координатора. Yjs — найбільш зріла CRDT-бібліотека для браузера. Інтегрується з ProseMirror, TipTap, CodeMirror, Monaco Editor.

Порівняння бібліотек для спільного редагування

Проблема: розмір Yjs-документа зростає через історію операцій. Потрібне періодичне збирання сміття — snapshot документа + очищення старих операцій. Без цього документ, над яким працювали рік, може важити 50 МБ.

const ws = new WebSocket('wss://example.com');
let pingInterval;

ws.on('open', () => {
  pingInterval = setInterval(() => {
    ws.ping();
    setTimeout(() => {
      if (ws.readyState === WebSocket.OPEN) ws.terminate();
    }, 5000);
  }, 25000);
});

ws.on('close', () => clearInterval(pingInterval));

Типові помилки при впровадженні real-time

Memory leak на сервері — забули видалити обробник події при закритті з'єднання. На Node.js heap зростає ~1 МБ/год. EventEmitter попереджає про 10+ слухачів, але не завжди це помічають.

Thundering herd при реконнекті. Сервер упав на 30 секунд, піднявся — 10 000 клієнтів намагаються перепідключитися одночасно. Exponential backoff з jitter обов'язковий: delay = Math.min(baseDelay * 2^attempt + random(0, 1000), maxDelay).

Відсутність індикації втрати з'єднання. WebSocket не завжди сповіщає про розрив (наприклад, телефон пішов у тунель). Heartbeat вирішує проблему.

Процес роботи

Починаємо з вибору транспорту під сценарії — іноді в одному проєкті потрібні всі три: SSE для системних нотифікацій, WebSocket для чату, WebRTC для відеодзвінків. Проектуємо протокол повідомлень (JSON з type і payload, рідше бінарний через MessagePack). Розробляємо з тестуванням race conditions — це не покривається юніт-тестами.

Навантажувальне тестування з k6 + k6/experimental/websockets: моделюємо 5 000 одночасних з'єднань з реальним патерном. Інженери мають сертифікати з WebSocket і WebRTC, гарантуємо стабільність 99.9%.

Що входить

• Архітектура real-time шару (вибір транспорту, протокол повідомлень)
• Реалізація з навантажувальним тестуванням (k6, сценарії race conditions)
• Інтеграція з бекендом через Redis Pub/Sub або аналогічну шину
• Документація з протоколу та схем даних
• Навчання вашої команди
• Технічна підтримка 2 тижні після запуску

Чому Centrifugo може бути вигіднішим за Socket.io?

Socket.io простіше в налаштуванні (1–2 дні), але центрифуга на Go тримає 1M+ з'єднань на одній ноді. Для 100k+ одночасних клієнтів Centrifugo економить до 40% витрат на інфраструктуру. Отримайте консультацію — ми допоможемо вибрати стек під ваше навантаження.

Строки

• Базовий WebSocket-чат або нотифікації поверх існуючого API: 1–3 тижні.
• Коллаборативний редактор з Yjs і persistence: 4–8 тижнів.
• WebRTC відеодзвінки з записом: 6–12 тижнів (значна частина — інтеграція з медіасервером mediasoup або Janus).

Зв'яжіться з нами для оцінки вашого проєкту. Обговоріть завдання з інженером — оцінимо складність і строки індивідуально.