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

На минулому тижні до нас прийшов клієнт: його аукціон «зависав», коли два користувачі одночасно ставили на один лот — одна ставка зникала, інша дублювалася. Втрати становили до $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 та аукціонів. Гарантуємо стабільність та масштабованість.

Якщо ви хочете таку саму систему, замовте консультацію — обговоримо деталі та приступимо. Отримайте консультацію — розкажіть про ваш аукціон, і ми запропонуємо оптимальне рішення.