Очередь сообщений

Очередь сообщений — это буфер, в который система-отправитель помещает сообщения, а система-получатель забирает их по мере готовности. Очередь гарантирует, что сообщение не будет потеряно, даже если получатель временно недоступен.

Принцип FIFO (First In, First Out): первое помещённое сообщение первым и обрабатывается. Отправитель пишет в очередь и сразу получает подтверждение — сообщение принято. Получатель читает из очереди с той скоростью, с которой способен обрабатывать. После успешной обработки сообщение удаляется из очереди. При сбое в процессе обработки сообщение возвращается в очередь для повторной попытки

Очередь решает проблему несоответствия скоростей между системами. Фронтенд интернет-магазина принимает 500 заказов в минуту, а ERP обрабатывает 50 — очередь сглаживает пик без потерь и без перегрузки ERP. В производственных системах очередь гарантирует, что производственные задания дойдут до MES даже при кратковременных сетевых сбоях.

В классической очереди каждое сообщение обрабатывается одним получателем и удаляется. В топике Kafka сообщения хранятся на протяжении настраиваемого периода и могут быть прочитаны несколькими независимыми группами потребителей. Очередь — для точечной доставки одному получателю. Топик — для широковещательной рассылки нескольким.

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