Please enable JavaScript.

Coggle requires JavaScript to display documents.

users bathing - Coggle Diagram

- - - - Этап 1: Отслеживание изменений в друзьях
        
        Событие: добавление/удаление друга
        
        При добавлении/удалении друга у пользователя в базе данных создаётся событие.
        
        2 more items...
        
        Событие: изменение даты рождения друга
        
        Если дата рождения друга изменяется, создаётся аналогичное событие, но с типом update.
      - Этап 2: Чтение изменений из Redis Streams
      - Этап 3: Обновление Redis
  - - - Описание: Redis используется с горизонтальным шардированием по ID пользователей.
      - Преимущества: Масштабируемость и равномерное распределение данных.
      - Технологии:
        
        Redis Cluster для распределённого хранения.
        
        Go для параллельного обновления шардов.
  - - - Redis Pub/Sub.
      - Go для реализации подписчика.
  - - - Описание: Для каждого дня создаётся отдельный ключ в Redis (birthdays:YYYY-MM-DD), где хранятся ID друзей.
        
        Преимущества: Простота реализации, удобство очистки устаревших данных.
        
        Технологии:
        
        Redis с TTL для автоматического удаления старых ключей.
    - - Описание: У каждого пользователя есть ключ (user:<id>:birthdays), в котором хранятся ID друзей с датами.
        
        Преимущества: Лёгкий доступ к данным по каждому пользователю.
        
        Технологии:
        
        Redis Hashes для хранения множества пар ключ-значение.
    - - Описание: Go Worker подписывается на определённые каналы Redis и обновляет данные по триггерам.
        
        Преимущества: Мгновенное обновление данных.
        
        Технологии:
        
        Redis Pub/Sub.
        
        Go для реализации подписчика.
- - - - Преимущества
        
        Снижение нагрузки на RabbitMQ
      - Технологии
        
        PHP с php-amqplib для отправки больших сообщений
      - Описание
        
        Несколько батчей объединяются в одно сообщение для уменьшения количества запросов к RabbitMQ
    - - Преимущества
        
        Балансировка нагрузки на обработчики
      - Технологии
        
        RabbitMQ с поддержкой DLX.
      - Описание
        
        Использование отложенных сообщений с помощью Dead Letter Exchange (DLX) в RabbitMQ, чтобы равномерно распределить нагрузку.
    - - Преимущества
        
        Простота реализации, прозрачность логики обработки
      - Технологии
        
        PHP с библиотекой php-amqplib для работы с RabbitMQ
      - Описание
        
        Каждый батч отправляется отдельным сообщением в RabbitMQ