使用保价信函在JBoss ESB中发布订阅者设计

Question

我在设计将在JBoss ESB上运行的发布/订阅服务时遇到了问题。我需要能够发布一个主题的消息，可能会有200个订阅者在听，他们一旦收到消息就会做一些事情。我正在编写一个发布服务和一个示例订阅服务来展示它是如何实现的。

我需要保证向这些订阅者交付。如果它们在一段时间内脱机，并且消息在该时间内发布，则当它们重新联机时，需要传递这些消息。所以我认为这意味着他们需要是持久的订阅者（我的理解是主题不是持久的，但订阅者被定义为持久的）。

我现在有一个发布服务，它将ESB消息粘贴到ESB感知队列上，调用NotifyTopic，将消息粘贴到不感知ESB的主题上。我有一个订阅者，它有一个ESB未知主题的侦听器，它使用httprouter调用Web服务，httprouter将消息发送给我的Web服务处理。这一切都正常-除了当我的Web服务离线时（我必须弄清楚如何处理这种情况，但我还没有做到），或者如果我的ESB订户服务离线（我通过卸载它，发送一些发布消息，然后重新安装它来进行测试-没有积压的消息发送到我的webservice）。

我很确定我没有正确构建订阅者。我认为我需要将订阅者部署在ESB上。我不知道它将如何工作，否则它将如何部署在不同的服务器上，然后仍然连接到ESB（试图避免与相互ssl、防火墙、端口等混淆）。我认为将订阅者安装在ESB上是最好的选择。但是我不知道如何让它持久/保价信函。

Answer 1

摘自创建健壮的 JMS 应用程序

创建长期订阅

要确保pub/sub应用程序接收到所有已发布的消息，请为发布者使用PERSISTENT交付模式。此外，为订阅者使用持久订阅。

TopicSession.createSubscriber方法创建非持久订户。非持久订户只能接收在其活动期间发布的消息。

以较高的开销为代价，您可以使用主题会话.create持久订阅者方法来创建持久订阅者。持久订阅一次只能有一个活动订阅者。

[...]

通过设置以下内容来建立持久订户的唯一标识：

• 连接的客户端 ID
• 订阅者的主题和订阅名称

我已经使用JBoss 7运行了一些测试

• 我已在连接工厂级别设置了客户端 ID
• 对三个订阅服务器中的每一个使用不同的订阅名称：

java prettyprint-override">topicSession.createDurableSubscriber(topic, subscriptionName);

JMS服务器为每个断开连接的订阅者正确缓冲消息。