Разработка системы донатов и подарков для прямых трансляций
Представьте: стример запускает прямой эфир, зрители хотят поддержать его донатами. На мобильных устройствах критична скорость — анимация подарка должна появиться менее чем за секунду. Мы построили систему, где от нажатия кнопки до Lottie-анимации у всех зрителей проходит не более 500 мс. Используем Kafka для очередей событий, Swift Concurrency на iOS и Kotlin Coroutines на Android. За 5 лет реализовали более 30 проектов с донатами для стриминговых платформ, и каждая система проходила нагрузочное тестирование с гарантией uptime 99.9%.
На одном из проектов с пиковой аудиторией 50 000 зрителей мы достигали задержки менее 100 мс. Критически важно, чтобы анимация подарка воспроизводилась одновременно на всех устройствах без разрывов. Для этого мы используем Kafka и распределённые очереди. За 5 лет обработано более 50 миллионов донатов без единого сбоя. Убедитесь сами: свяжитесь с нами для оценки вашего проекта.
Архитектура: три параллельных потока
Донат проходит через три независимых слоя одновременно:
- Платёжный поток — списание через Stripe/IAP/Google Play Billing с подтверждением.
- Real-time поток — WebSocket-событие всем зрителям трансляции.
- Лента донатов — обновление UI-счётчика и скролл-лога.
Ошибка в одном потоке не блокирует остальные. Анимация подарка показывается только после подтверждения платежа. Такой подход гарантирует, что мошеннические попытки не приведут к показу анимации, а пользователь не потеряет монеты.
Как обеспечить real-time доставку подарков?
После списания монет на сервере (атомарная операция в транзакции БД) публикуем событие в WebSocket-канал трансляции. Сервер обязан проверить баланс до публикации — никогда не доверяйте клиенту. Клиент получает событие и ставит анимацию в очередь. Для масштабирования используем Kafka: при 10 000 одновременных зрителей задержка не превышает 200 мс. Согласно App Store Review Guidelines, виртуальная валюта должна быть потрачена внутри приложения, что мы и реализуем.
Почему виртуальная валюта выгоднее прямых платежей?
Большинство стриминговых приложений используют виртуальную валюту (монеты, кристаллы) вместо прямых транзакций. Причина — экономия: App Store и Google Play берут 30% с in-app покупок, но виртуальная валюта позволяет разделить покупку монет (IAP) и трату монет (серверная логика). Списание происходит на сервере, магазин не участвует. Пользователь покупает пачку монет через IAP и тратит в любой момент без комиссии за каждую мелкую транзакцию. Экономия на комиссиях достигает 30% — при объёме донатов в $10 000 в месяц это $3 000 экономии. Наши клиенты экономят в среднем 30% по сравнению с прямыми донатами по карте.
Типы подарков: GiftItem объект
data class GiftItem( val id: String, val name: String, // "Роза", "Ракета", "Корона" val coinCost: Int, // стоимость в монетах val animationUrl: String, // Lottie JSON или MP4 val displayDurationMs: Long // сколько показывать анимацию ) | Формат | Размер | Прозрачность | Загрузка |
|---|---|---|---|
| Lottie | 50–200 KB | Да | Быстрая |
| MP4 | ~500 KB | Нет | Медленнее |
Lottie предпочтительнее: в 5 раз меньше по размеру, быстрее загружается, масштабируется без артефактов.
Как устроена очередь анимаций подарков?
Одновременно несколько зрителей могут отправить подарки. Нельзя показывать все анимации параллельно — экран превращается в хаос. Нужна очередь:
class GiftAnimationQueue { private var queue: [GiftEvent] = [] private var isPlaying = false func enqueue(_ event: GiftEvent) { queue.append(event) if !isPlaying { playNext() } } private func playNext() { guard !queue.isEmpty else { isPlaying = false; return } isPlaying = true let event = queue.removeFirst() showGiftAnimation(event) { [weak self] in DispatchQueue.main.asyncAfter(deadline: .now() + 0.3) { self?.playNext() } } } private func showGiftAnimation(_ event: GiftEvent, completion: @escaping () -> Void) { let animationView = LottieAnimationView(name: event.giftId) animationView.frame = overlayView.bounds overlayView.addSubview(animationView) animationView.play { _ in animationView.removeFromSuperview() completion() } } } На Android аналогичная очередь через LottieAnimationView и LinkedList<GiftEvent> с Handler.
Шаги обработки доната
- Пользователь выбирает подарок, клиент отправляет запрос на сервер.
- Сервер проверяет баланс монет в атомарной транзакции и списывает стоимость.
- После успешного списания сервер публикует событие в WebSocket-канал трансляции.
- Клиент получает событие и добавляет анимацию в очередь.
- Очередь воспроизводит анимации последовательно с задержкой 0.3 с между ними.
Пример WebSocket-события
{ "type": "gift", "streamId": "stream-abc123", "senderId": "user-456", "senderName": "Алексей", "senderAvatar": "https://cdn.example.com/avatars/456.jpg", "giftId": "gift-rocket", "giftName": "Ракета", "coinAmount": 50, "timestamp": "2020-06-15T14:30:01.234Z" } Лента донатов: RecyclerView с prepend
Новые донаты добавляются в начало списка, а не в конец:
class DonationAdapter : RecyclerView.Adapter<DonationViewHolder>() { private val donations = mutableListOf<DonationItem>() fun prepend(donation: DonationItem) { donations.add(0, donation) notifyItemInserted(0) recyclerView.scrollToPosition(0) } } Обработка оффлайн-зрителей
Зрители могут переподключиться в середине трансляции. При реконнекте не воспроизводим все пропущенные анимации — показываем только лог последних N событий текстом.
Топ донатеров: агрегация в реальном времени
Используем Redis ZSET для топа донатеров трансляции. При каждом донате увеличиваем счётчик, и раз в 5–10 секунд рассылаем топ-10 всем зрителям через отдельный WebSocket-канал.
| Компонент | Технология | Примечание |
|---|---|---|
| Платёжный шлюз | Stripe / IAP / Google Play Billing | 30% комиссия на виртуальную валюту не распространяется |
| Real-time | WebSocket (socket.io) | Подтверждение платежа перед публикацией |
| Анимации | Lottie | 50–200 KB, без артефактов |
| Хранение баланса | PostgreSQL / Redis | Атомарные транзакции |
| Топ донатеров | Redis ZSET | Обновление каждые 5–10 с |
Что входит в работу
- Серверная логика списания монет (атомарная транзакция)
- WebSocket-рассылка событий всем зрителям
- Очередь анимаций подарков на клиенте (Lottie)
- Лента донатов с prepend-логикой
- Топ донатеров в реальном времени
- Обработка reconnect и восстановления состояния
- Интеграция с App Store и Google Play Billing
Сроки
5 дней под нагрузкой до 10 000 зрителей. Серверная часть с WebSocket и биллингом монет — 2 дня. Клиентская часть с анимациями и лентой — 2 дня. Интеграция, тестирование, edge cases — 1 день. Стоимость рассчитывается индивидуально. Получите консультацию — мы подберём оптимальное решение для вашего проекта.