Я новичок в Spring-Integration и слежу за решением следующей задачи.
Мы пытаемся создать MQTT-Consumer (на основе адаптера входящего канала mqtt ), который получает сообщения по 7 темам от 50 издателей.
Поскольку адаптер обрабатывает сообщения последовательно, необходимо масштабировать распараллеливание обработки или получать оставшиеся сообщения, отброшенные посредником.
Первой идеей для масштабирования был отдельный адаптер на тему с соответствующими конвертерами.Он хорошо принимает сообщения от одного издателя, но не может противостоять такому количеству издателей с помощью очереди или прямого исходящего канала.
В настоящее время рассматривается вопрос об использовании канала исполнителя с количеством обработчиков сообщений.(собственные конвертеры) для каждой темы.Затем они передадут свои результаты в соответствующие очереди, что позволит обрабатывать и распространять сообщения в пакетном режиме.
Однако я не уверен, является ли создание одного отдельного адаптера для каждой темы хорошей идеей, и я ищу любые предложения по улучшению архитектуры.Заранее спасибо!