连接到ActiveMQ时向使用者发送消息

Question

我有多个连接到队列的工作人员实例，所有请求都将以负载平衡的方式分发给员工实例。当一个新的工作者实例连接到队列时，我应该将一个小数据从主流应用程序转储到这个新的工作者实例(一次作业)。

目前，我正在使用主流应用程序的REST端点在应用程序启动时执行此操作，但我们能利用消息队列进行此操作吗？一旦一个新的工作者实例连接到队列，它将要求初始数据转储通过队列将应用程序主流化，然后应用程序将使用初始数据进行回复。

是否可以使用消息队列/主题？请分享您的观点/建议，以实现这一点使用activemq。

Answer 1

如果您使用的是ActiveMQ Artemis，则这种需求通常通过一个同时支持非破坏性和最后值语义的队列来满足。最后一个值语义允许队列保持最新的消息，而非破坏性语义意味着即使消费者确认了消息，他们仍将留在队列中等待下一个连接的客户端。当使用这种组合时，客户端可以首先使用这个特殊的“初始化”队列中的所有消息，然后继续进行他们需要做的任何其他消息传递工作。

不幸的是，ActiveMQ“经典”并不支持这两种语义，也没有一种直接的方法来获得等价的行为。