未确认消息的 HornetQ 行为

Question

我有一个基于 HornetQ 的 JMS 提供者，消费者在 CLIENT_ACKNOWLEDGE_MODE 中附加到提供者。 message.acknowledge () sn-p 虽然在 if else 之下。因此，如果应用层在处理消息时出现故障，消费者有时不会向服务器发送确认。所以这里有两个问题 -

1) 更多在服务器中排队的消息会继续发送吗 流向消费者，即使消费者不承认 如前所述的消息中的一个

2) 未确认的消息是否会在重新启动时再次向下流动 消费者。

这些是我对我提出的问题的一些观察

1) 消息按照 消费者日志，即使它没有确认其中一条消息 由于应用层故障而发送到服务器（注意，有 没有未捕获的异常，只是消费者没有 承认） 。

2)其次，在重新启动消费者时，消息也没有 令人惊讶的是再次从服务器流下来。

有人可以澄清这种行为吗？

Answer 1

很难完全确定您的应用程序在消息确认方面正在做什么，但我的猜测是您在尝试确认相关消息失败后继续确认消息。在这种情况下，因为您使用的是客户端确认模式，所以下一个确认也将应用于上一条消息，因为这就是客户端模式的工作方式。

Session.CLIENT_ACKNOWLEDGE：客户端通过调用消息的确认方法来确认消息。在这种模式下，确认发生在会话级别：确认已消费的消息会自动确认已收到其会话已消费的所有消息。例如，如果消息消费者消费了 10 条消息，然后确认发送的第 5 条消息，则所有 10 条消息都被确认。

因此，如果您仔细阅读，您会发现会话中的消费者在客户端确认模式下确认消息是如何相互影响的。

要获得更好的答案，您需要进一步分解事件链，以便更清楚发生了什么。