У меня есть класс Java Processor
, который слушает тему jms, и он изо всех сил старается не отставать от скорости, с которой приходят сообщения, поэтому мы решили пойти параллельно:
ОдинКласс, слушающий тему, задача которой состоит в том, чтобы передавать сообщения в пул рабочих потоков, фактически являясь балансировщиком нагрузки.Это также должно помешать двум работникам обрабатывать сообщения для одного и того же клиента.
Я ожидал, что в Интернете будет достаточно информации об этом, но все, похоже, предполагает использование EJB, где сервер приложений управляет сервером.пул и делает балансировку.Я уверен, что это должно быть действительно распространенной проблемой, но не могу найти какие-либо библиотеки или шаблоны проектирования, чтобы помочь.Я делаю из этого больше, чем есть, и должен просто углубиться и написать свой собственный код?