Проблема с задержкой сообщений MQ (очереди сообщений) относится к явлению, когда в очереди сообщений накапливается большое количество необработанных сообщений, что приводит к серьезному отставанию сообщений в очереди сообщений, превышающему возможности обработки системы и влияющему на производительность и стабильность системы.

1. В какой ссылке возникает проблема с задержкой сообщений?

Выполнение MQ состоит из трех основных этапов:

1. Этап создания сообщения.
2. Этап хранения сообщений.
3. Этап потребления сообщения.

Очевидно, что накопление сообщений происходит на третьем этапе потребления сообщений.

2. Как это решить?

Обработка проблемы с задержкой сообщений зависит от типа очереди сообщений. Например, является ли очередь сообщений внезапной проблемой с задержкой сообщений? Или это медленно растущее количество сообщений? Решения разных задач немного отличаются, давайте рассмотрим их дальше.

2.1 Проблема с внезапным отставанием сообщений

Внезапная проблема с задержкой новостей Решение：Сначала быстро решите проблему с задержкой сообщений, а затем устраните проблему и сформулируйте соответствующие решения.,Таким образом, мы можем использовать следующие методы для обработки:

1. Расширьте потребителей по горизонтали (добавьте количество потребителей), чтобы решить проблему с задержкой сообщений.
2. Используйте текущие методы ограничения, чтобы ограничить скорость, с которой производители создают сообщения.
3. Проанализируйте проблему невыполненных сообщений с помощью журналов или мониторинга. Если проблема вызвана кодом потребления, оптимизируйте код, чтобы увеличить скорость обработки. 2.2 Проблема медленно и постоянно растущего количества невыполненных сообщений Проблема медленно и постоянно растущего количества невыполненных сообщений заключается в использовании механизма мониторинга для раннего обнаружения проблемы, а затем быстрого устранения неполадок и обнаружения проблемы с невыполненными сообщениями для ее решения. 3. Общее решение. В общем, решения проблемы невыполненных сообщений следующие:
4. Горизонтальное масштабирование потребителей：Увеличение количества потребителей,Это может увеличить скорость параллельного потребления сообщений.,Это позволяет избежать проблемы задержки сообщений.
5. Оптимизируйте скорость обработки данных потребителями：Повышение скорости потребления потребителями также может помочь избежать проблемы задержки сообщений.,Его решение：
   • Оптимизируйте логику обработки сообщений потребителя и сократите количество ненужных вычислений и операций ввода-вывода.
   • Для задач, которые можно обрабатывать параллельно, используйте многопоточность или асинхронную обработку для увеличения пропускной способности.
6. Ограничивайте производителей и используйте механизмы противодавления.：
   • Внедрите текущую стратегию ограничения на стороне производителя, чтобы гарантировать, что скорость генерации сообщений не превышает вычислительную мощность системы.
   • Используйте механизм противодавления, то есть, когда очередь сообщений достигает определенного порога, производитель уведомляется о необходимости снизить скорость отправки или приостановить отправку.
7. Используйте очередь недоставленных писем：В случае, если потребитель не смог обработать сообщение или истекло время ожидания,Добавьте механизм повтора сообщений или поместите сообщения об исключениях в очередь недоставленных писем.,Не допускайте, чтобы аномальные сообщения занимали ресурсы очереди.
8. Мониторинг и оповещение：Установите разумные пороги тревоги,Своевременно выдавайте сигналы тревоги, когда количество невыполненных сообщений достигает определенного уровня.,для быстрого ответа и обработки. Мысли после занятий по Кафке,Горизонтальное масштабирование потребители Должны ли мы решить проблему невыполненных сообщений? Почему?

Эта статья была включена на мой сайт интервью. www.javacn.site,Включенное содержимое: Redis, JVM, одновременно, одновременно, MySQL, Spring, Spring. MVC、Spring Boot、Spring Облако, MyBatis, шаблоны проектирования, очередь сообщений и другие модули.