ActiveMQ CMS：在创建消费者和设置监听器之间会丢失消息吗？

Question

使用侦听器设置 CMS 消费者涉及两个单独的调用：首先，获取消费者：

 cms::MessageConsumer* cms::Session::createConsumer( const cms::Destination* );

然后，在消费者上设置一个监听器：

void cms::MessageConsumer::setMessageListener( cms::MessageListener* );

如果实现在侦听器激活之前订阅目的地（并从代理/路由器接收消息），消息会丢失吗？还是这些消息在内部排队并在激活时传递给侦听器？

为什么没有 API 调用来创建使用侦听器作为构造参数的消费者？ （是因为 JMS 规范没有吗？）

（附录：这可能是 API 本身的一个缺陷。更合乎逻辑的顺序是从会话中实例化消费者，并在 API 中有一个cms::Consumer::subscribe( cms::Destination*, cms::MessageListener* ) 方法。）

Answer 1

我认为 API 不一定有缺陷。显然它可以设计成不同的方式，但我相信您所谓的问题的解决方案来自Connection 对象上的start 方法（通过Startable 继承）。 Connection 的文档指出：

CMS 客户端通常会创建一个连接、一个或多个会话以及许多消息生产者和消费者。创建连接时，它处于停止模式。这意味着没有消息被传递。

在设置完成之前（即，直到所有消息使用者都创建完毕），通常会保持连接处于停止模式。此时，客户端调用连接的 start 方法，消息开始到达连接的消费者。此设置约定可最大限度地减少客户端仍在自行设置过程中异步消息传递可能导致的任何客户端混淆。

可以立即开始连接，之后可以进行设置。执行此操作的客户端必须准备好在它们仍在设置过程中时处理异步消息传递。

这与 JMS 遵循的模式相同。

在任何情况下，无论您何时调用start()，我都不认为有任何消息丢失的风险。如果消费者使用自动确认模式，则只有在通过其中一种接收方法同步传递或通过侦听器的onMessage 异步传递消息后，才应自动确认消息。否则将是我估计的错误。在过去的 10 年里，我一直在使用 JMS 进行各种实现，我从未见过任何与此相关的消息丢失的情况。

如果您想在调用 start() 之后添加消费者，您当然可以先调用 stop()，但我认为简单地即时添加它们没有任何问题。