Сообщение процесса Секвенциален с конкурирующими потребителями

Question

Проблема:

• Получает сообщения (говорят заказы) на очереди в определенной последовательности (FIFO)
• Я конкурирующие потребитель на очереди
• Для дальнейшего добавления к сложности, потребитель может интересоваться только конкретными версиями заказа в зависимости от его состояния. (Скажем, версия1, версия 2 и версия5)
• Номер версии заказа доступен в заказе, но не может использоваться для последовательности, поскольку мой слушатель может не интересоваться все версии (потребитель может быть заинтересован только в версиях Say version1, version 2 и version5)

Как обеспечить, чтобы я обрабатывал сообщения через потребителей в том порядке, в котором я их получил?

Answer 1

Вы не можете использовать несколько потребителей, по крайней мере, не базовые JMS. Вам нужно будет предоставить логику.

Решения, о которых я думаю, все сосать, потому что он принимает красоту асинхронной интеграции и пытается сделать его синхронным. Для каждого «объекта» или «сообщения» или «типа», имеющего прикрепленную к нему версию, вы можете отслеживать, какие версии вы получили, и попытаться гарантировать их обработку в порядке. Если потребитель получает их не по порядку, потребитель может просто остановиться на своем пути или может переупорядочить сообщение, но у любого решения есть какая-то гадость.

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

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

Снова я задам вопрос: используете ли вы правильную технологию?