Потеря сообщений в процессорах при перезапуске брокера

Question

В моем previous message Я искал решение для обработки входящих сообщений параллельно. После многих проб и ошибок, я думаю, у меня может быть рабочее решение.

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

Во время тестирования я успешно начал несколько процессоров сразу, чтобы выполнить единицу работы на сообщение. То, что я обнаружил при внезапном перезапуске брокера, заключается в том, что любое сообщение, «обработанное» внутри процессора, фактически потеряно. Однако, когда процессор выбрасывает преднамеренное исключение, сообщение пересылается в очередь.

Как я могу защитить свое сообщение во время его обработки (а часть работы еще не закончена)? Любые рекомендации очень ценятся.

Примечание: окончательная реализация будет использовать мастер-мастер-установку двух одинаковых брокеров за балансировщиком tcp.

Answer 1

Чтобы сохранить ваше сообщение, вы должны использовать транзакции с постоянными сообщениями. Без транзакций не учитываются все сценарии исключений, особенно если вы используете AUTO_ACKNOWLEDGE по умолчанию, который сообщает брокеру, что вы использовали это сообщение, поэтому зайдите в голову и удалите его, как только сообщение будет доставлено. Вот почему при перезапуске брокера вы теряете свое сообщение. Другого пути нет.

Предполагая, что у вас установлены правильные транзакции, нет причин, по которым вы не сможете обрабатывать параллельно. This blog is a bit older now, но по-прежнему заполнен хорошей информацией, чтобы убедиться, что вы правильно настраиваете свои транзакции.