Как избежать двойной тарификации при использовании RabbitMQ? (идемпотентность обработки сообщений)

Проблема:
Сообщение может быть доставлено повторно из-за:

• Повторной отправки от производителя.

• Ошибок сети или потребителя.

Решение:

1. Идемпотентный потребитель:

   • Сохраняйте message_id в таблицу processed_messages.

   • Перед обработкой проверяйте наличие ID:

     SELECT id FROM processed_messages WHERE message_id = ?;

2. Дедупликация на стороне RabbitMQ:

   • Включите deduplication в плагине rabbitmq_message_deduplication.

3. Паттерн "Транзакционный аутбокс":

   • Сохраняйте факт обработки в той же транзакции, что и бизнес-логика.

Пример кода:

@RabbitListener(queues = "billing")
public void handleMessage(Message message) {
    String messageId = message.getMessageProperties().getMessageId();
    if (isProcessed(messageId)) {
        return; // Пропускаем дубликат
    }
    processPayment(message);
    saveProcessedId(messageId); // Сохраняем ID в БД
}