具有并发消费者的 Jms 消息驱动通道适配器避免在崩溃期间丢失消息

Question

我正在尝试弄清楚如何将消息驱动通道适配器与并发消费者一起使用并成为 能够承受系统故障而不会丢失任何消息。 在我当前的实现中，我使用 Spring Integration 并从 ArtemisMQ 服务器读取数据，并且我需要能够回滚任何未能到达流程末尾的消息。

我确实使用以下实现来接收消息

  <int-jms:message-driven-channel-adapter
            connection-factory="connectionFactory"
            destination="myQueue"
            message-converter="messageConverter"
            channel="inputChannel"
            concurrent-consumers="5"
            error-channel="errorChannel"
            acknowledge="transacted"
    />

但由于现在涉及多个并发消费者，因此现在重新定义了事务边界，如果发生故障，则消息将丢失。

我的主要问题是我需要多个消费者提供消息，同时我不想在崩溃事件期间丢失消息。有没有办法扩展/传播事务边界或至少手动确认每条消息 在我的流程结束时？

Answer 1

我认为你误解了一些东西，只是感到困惑。并发不会中断事务：每个并发消费者都有自己的事务，如果消息处理在同一个线程中完成，则不会丢失任何内容。

我认为您将消息发送到下游某处的不同线程。这就是你的 tx 被提交的地方，如果出现错误，消息可能会丢失。

您需要修改处理消息的方式以将它们保持在 tx 边界内，或者真正考虑使用client ack 模式在下游手动执行此操作。