Разработка аукциона в реальном времени: сервер, клиент, антиснайпинг

На прошлой неделе к нам пришёл клиент: его аукцион «зависал», когда два пользователя одновременно ставили на один лот — один бид пропадал, другой дублировался. Потери составляли до $5000 за лот. Такая ситуация знакома многим владельцам аукционов. Мы разрабатываем аукционные системы, которые исключают подобные ошибки «из коробки». За 7 лет мы реализовали более 30 проектов для e-commerce и торговых площадок.

Проблемы, которые решаем

Race condition при параллельных ставках — самая частая беда. Два запроса обрабатываются одновременно, каждый видит текущую цену $100, оба записывают $110 — побеждает первый, второй должен быть отклонён. Без блокировки клиент получает ложное подтверждение, а аукцион — спорную ситуацию. Мы устраняем это через пессимистичную блокировку Redis, исключая двойные записи.

Ложноопределение победителя — проблема из-за несинхронизированных таймеров. Сервер показывает 5 секунд до конца, но из-за задержки сети клиент считает, что осталось 10. Ставка уходит вовремя, но сервер уже закрыл лот. Потери для организатора — тысячи долларов. Наш подход — синхронизация времени через WebSocket с серверным таймером.

Антиснайпинг — когда участник ждёт последней секунды и «крадёт» лот. Без механизма продления аукцион теряет честность. Мы добавляем автоматическое продление на 2 минуты после каждой ставки в финальной фазе.

Как мы это делаем: стек и ключевые решения

Выбираем Node.js (NestJS для строгой архитектуры) и PostgreSQL — проверенная связка для транзакционных нагрузок. Пессимистичная блокировка через Redis SETNX — чтобы ни один запрос не проскочил без блокировки. WebSocket (Socket.IO) — для мгновенных update всех клиентов; fallback на long-polling, если сеть блокирует WebSocket. Фронтенд — React 18 с Next.js (SSR для SEO) и TypeScript, компоненты на Tailwind.

Сравним два подхода к блокировке:

Мы используем пессимистичную блокировку как более надёжную для аукционов с высокой конкуренцией.

Как предотвратить конфликт ставок?

Пессимистичная блокировка через Redis — надёжнее всего. Алгоритм:

class AuctionService { async placeBid(auctionId: string, userId: string, amount: number): Promise<BidResult> { const lockKey = `lock:auction:${auctionId}`; const lockAcquired = await redis.set(lockKey, userId, 'NX', 'PX', 5000); if (!lockAcquired) { throw new Error('Auction is processing another bid, try again'); } try { const auction = await auctionRepo.findById(auctionId); if (auction.status !== 'active') throw new BidError('Auction is not active'); if (new Date() > auction.endsAt) throw new BidError('Auction has ended'); if (amount <= auction.currentPrice) { throw new BidError(`Bid must be higher than ${auction.currentPrice}`); } if (amount < auction.currentPrice + auction.minIncrement) { throw new BidError(`Minimum increment is ${auction.minIncrement}`); } if (auction.currentLeaderId === userId) { throw new BidError('You are already the highest bidder'); } const bid = await bidRepo.create({ auctionId, userId, amount }); await auctionRepo.updateCurrentPrice(auctionId, amount, userId); // Anti-sniping const timeLeft = auction.endsAt.getTime() - Date.now(); if (timeLeft < 2 * 60 * 1000) { const newEndTime = new Date(Date.now() + 2 * 60 * 1000); await auctionRepo.extendTime(auctionId, newEndTime); } await this.broadcastBid(auctionId, bid, auction); return { success: true, bid }; } finally { await redis.del(lockKey); } } async broadcastBid(auctionId: string, bid: Bid, auction: Auction) { io.to(`auction:${auctionId}`).emit('bid:new', { bidId: bid.id, amount: bid.amount, bidderId: bid.userId, bidderName: anonymizeBidder(bid.userId), timestamp: bid.createdAt, totalBids: auction.bidCount + 1, newEndTime: auction.endsAt }); } } 

Почему антиснайпинг критичен для аукциона?

Без него любой участник может дождаться последних миллисекунд и выиграть без конкуренции. Наш таймер автоматически продлевается на 2 минуты, давая шанс ответить. Сервер транслирует обновлённое время всем клиентам через WebSocket.

class AuctionTimer { async startTimer(auctionId: string, endTime: Date): Promise<void> { const msUntilEnd = endTime.getTime() - Date.now(); setTimeout(async () => { await this.finalizeAuction(auctionId); }, msUntilEnd); const broadcastInterval = setInterval(async () => { const remaining = endTime.getTime() - Date.now(); if (remaining <= 0) { clearInterval(broadcastInterval); return; } if (remaining <= 60000) { io.to(`auction:${auctionId}`).emit('timer:tick', { remaining: Math.ceil(remaining / 1000) }); } }, 1000); } async finalizeAuction(auctionId: string): Promise<void> { const auction = await auctionRepo.findById(auctionId); if (auction.status !== 'active') return; await auctionRepo.finalize(auctionId); io.to(`auction:${auctionId}`).emit('auction:ended', { winnerId: auction.currentLeaderId, winnerName: await getUserName(auction.currentLeaderId), finalPrice: auction.currentPrice }); await this.notifyParticipants(auction); } } 

Клиентский компонент на React

Все данные приходят по WebSocket — компонент реагирует мгновенно. Никаких лишних re-render, только точечные обновления.

function AuctionRoom({ auctionId }) { const [auction, setAuction] = useState<AuctionState>(); const [bids, setBids] = useState<Bid[]>([]); const [timeLeft, setTimeLeft] = useState<number>(0); const socket = useSocket(); useEffect(() => { if (!socket) return; socket.emit('auction:join', { auctionId }); socket.on('auction:state', (state) => setAuction(state)); socket.on('bid:new', (bid) => { setBids(prev => [bid, ...prev].slice(0, 50)); setAuction(prev => prev ? { ...prev, currentPrice: bid.amount } : prev); }); socket.on('timer:tick', ({ remaining }) => setTimeLeft(remaining)); socket.on('auction:ended', ({ winnerId, finalPrice }) => { setAuction(prev => prev ? { ...prev, status: 'ended' } : prev); if (winnerId === currentUserId) { showCongratulations(finalPrice); } }); return () => socket.emit('auction:leave', { auctionId }); }, [socket, auctionId]); const placeBid = async (amount: number) => { try { await fetch(`/api/auctions/${auctionId}/bids`, { method: 'POST', body: JSON.stringify({ amount }) }); } catch (e) { showError(e.message); } }; return ( <div className="auction-room"> <CurrentPrice price={auction?.currentPrice} /> <AuctionTimer seconds={timeLeft} critical={timeLeft < 30} /> <BidForm minBid={(auction?.currentPrice ?? 0) + (auction?.minIncrement ?? 100)} onBid={placeBid} disabled={auction?.status !== 'active'} /> <BidHistory bids={bids} currentUserId={currentUserId} /> </div> ); } 

Процесс работы

1. Аналитика — смотрим на бизнес-логику, определяем типы аукционов (английский, голландский, закрытый), нагрузку, интеграции с платёжными системами.
2. Проектирование — рисуем архитектуру: схему БД, протокол WebSocket, стратегию блокировок, anti-sniping, таймеры.
3. Реализация — пишем сервер и клиент параллельно. На каждый спринт — демо.
4. Тестирование — unit-тесты, интеграционные тесты, нагрузочное тестирование (до 2000 RPS). Проверяем race condition и тайминги.
5. Деплой — настраиваем CI/CD, контейнеризацию, мониторинг (Grafana, Prometheus). Передаём документацию и доступы.

Что входит в работу

• Полная кодовая база сервера (Node.js + TypeScript) и клиента (React/Next.js).
• Документация API (Swagger) и архитектурная схема.
• Нагрузочное тестирование с отчётом.
• Инструкция по развёртыванию и настройке мониторинга.
• Один месяц поддержки после запуска (исправление багов, консультации).

Сроки ориентировочно

Точные сроки оцениваем после анализа вашего ТЗ. Свяжитесь с нами — пришлём оценку за 1 день.

Типичные ошибки при разработке аукционов

«После внедрения системы количество спорных ставок снизилось до нуля» — клиент из e-commerce.

Избежать этих граблей помогают наш опыт — 7 лет в разработке real-time систем, более 30 завершённых проектов для e-commerce и аукционов. Гарантируем стабильность и масштабируемость.

Если вы хотите такую же систему, закажите консультацию — обсудим детали и приступим. Получите консультацию — расскажите о вашем аукционе, и мы предложим оптимальное решение.