Мобильная система донатов и подарков для стримов

Разработка системы донатов и подарков для прямых трансляций

Представьте: стример запускает прямой эфир, зрители хотят поддержать его донатами. На мобильных устройствах критична скорость — анимация подарка должна появиться менее чем за секунду. Мы построили систему, где от нажатия кнопки до Lottie-анимации у всех зрителей проходит не более 500 мс. Используем Kafka для очередей событий, Swift Concurrency на iOS и Kotlin Coroutines на Android. За 5 лет реализовали более 30 проектов с донатами для стриминговых платформ, и каждая система проходила нагрузочное тестирование с гарантией uptime 99.9%.

На одном из проектов с пиковой аудиторией 50 000 зрителей мы достигали задержки менее 100 мс. Критически важно, чтобы анимация подарка воспроизводилась одновременно на всех устройствах без разрывов. Для этого мы используем Kafka и распределённые очереди. За 5 лет обработано более 50 миллионов донатов без единого сбоя. Убедитесь сами: свяжитесь с нами для оценки вашего проекта.

Архитектура: три параллельных потока

Донат проходит через три независимых слоя одновременно:

1. Платёжный поток — списание через Stripe/IAP/Google Play Billing с подтверждением.
2. Real-time поток — WebSocket-событие всем зрителям трансляции.
3. Лента донатов — обновление 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 предпочтительнее: в 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.

Шаги обработки доната

1. Пользователь выбирает подарок, клиент отправляет запрос на сервер.
2. Сервер проверяет баланс монет в атомарной транзакции и списывает стоимость.
3. После успешного списания сервер публикует событие в WebSocket-канал трансляции.
4. Клиент получает событие и добавляет анимацию в очередь.
5. Очередь воспроизводит анимации последовательно с задержкой 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-канал.

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

• Серверная логика списания монет (атомарная транзакция)
• WebSocket-рассылка событий всем зрителям
• Очередь анимаций подарков на клиенте (Lottie)
• Лента донатов с prepend-логикой
• Топ донатеров в реальном времени
• Обработка reconnect и восстановления состояния
• Интеграция с App Store и Google Play Billing

Сроки

5 дней под нагрузкой до 10 000 зрителей. Серверная часть с WebSocket и биллингом монет — 2 дня. Клиентская часть с анимациями и лентой — 2 дня. Интеграция, тестирование, edge cases — 1 день. Стоимость рассчитывается индивидуально. Получите консультацию — мы подберём оптимальное решение для вашего проекта.