Большие ли задержки в очередях сообщений?

Question

[smartbe]

Хочу чтобы один микросервис передал информацию другому. Я так понимаю, что для этого используется очередь сообщений (например rabbitMQ). Какая может быть задержка? Можно ли очередь сообщений держать где то в памяти?

Answer 1

[Василий Банников]

Какая может быть задержка?

Зависит от конфига и скорости диска. Обычно не критично. Может порядка нескольких-десятка миллисекунд (не измерял).

Можно ли очередь сообщений держать где то в памяти?

В смысле не сохранять на диск? Да, можно:
https://www.rabbitmq.com/persistence-conf.html

Ну и это речь конкретно про rabbitmq. В других брокерах может быть иначе.

Comments

[smartbe]

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

[Василий Банников]

smartbe, в этом случае стоит запилить на монолите, тк микросервисы могут спокойно на порядок увеличить задержки при передаче данных, по сравнению с передачей данных внутри одного процесса.

Answer 2

[Сергей]

Если говорить только о задержке внутри RabbitMQ при работе только в памяти, то не думаю, что она превысит пары миллисекунд на незагруженной системе. В RabbitMQ если очередь не-durable, сообщение не имеет флага persistent и нет memory pressure (хватает памяти), то обработка происходит чисто в памяти.
Но, если всё что нужно, это передать данные от одного сервиса к другому, то поднимать инстанс RabbitMQ может быть очень накладно. Попробуйте для начала вызывать второй сервис из первого с передачей данных напрямую. Другим вариантом может быть простой message bus (например, NATS), который не имеет очередей и не хранит данные, а отправляет сразу (или дропает сообщение, если нет подписчиков).

Comments

[smartbe]

Здравствуйте! А как можно вызвать второй сервис из первого с передачей данных напрямую?

[Сергей]

Всё зависит от среды, но банально - HTTP запросом :-)
По комментарию в другом ответе могу сказать, что стоит попробовать NATS, так как получателей будет много, а недоставленные сообщения вообще хранить не надо.

[smartbe]

Хорошо, спасибо!)