Отправка сообщений на основе очереди сообщений Redis
Базовые знания
Мы используем следующие команды для отправки наших сообщений
- br режим блокировки всплывающих окон удаляется после получения значения из правой части очереди
- brpoplpush удаляется из правой части очереди A и помещается в очередь B с левой стороны
логический анализ
- Запишите цель сообщения, которое будет отправлено, в очередь очереди отправки в обычном сценарии задачи и задайте содержимое, которое будет отправлено для цели, срок действия которого никогда не истечет
- В очереди отправки Redis обрабатывается brpoplpush, и обработанное значение помещается во временную очередь, чтобы предотвратить сбой отправки, вызванный сбоем программы
- RedisAutoDeleteTempqueueItems обрабатывает временную очередь. здесь используется brpop
реализация кода
Сценарий общей задачи
Красный – это очередь толчка
RedisAutoDeleteTempqueueItems
Оригинал: “https://programmer.help/blogs/message-push-based-on-redis-message-queue.html”