JMS持久异步事件通知

Question

我希望有人为我指出一些要求的正确方向：我们需要在我们的服务器上发送异步可靠的通知 消息的消费者将随意订阅/取消订阅 消费者的数量将很大 生产者将是一个通知，即使服务器关闭，也不会丢失，如果服务器再次上升将被发送。通知数预计为高 使用的线程数应尽可能少。

鉴于上述（疯狂的）要求，我试图使用activemq / jms来解决这个问题。这似乎是正确的方向吗？

考虑到以上：1.我使用了持久订阅者、jms消息和kahadb。2对于jms生产者，解决方案似乎是直截了当的。3.在消费者方面，我遇到了麻烦。

一个。虽然我有Spring，但我不能使用jms：listener-container，因为我需要有消费者的动态订阅和取消订阅，这似乎是不可能的，所以我为我拥有的每个听众创建一个简单的听众容器。这听起来还行吗？b.在简单列表容器中，i设置客户端Id（因为这是持久化所需的）

    super.setSubscriptionDurable(durable);
    if (durable ) super.setClientId(clientId);

在这里，我有以下。给定以下配置:

    <bean id="messageBusReceiverConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
        <property name="maxConnections" value="10"/>
        <property name="maximumActive" value="500"/>
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
        <property name="idleTimeout" value="0"/>
    </bean>

我预计可能有10*500=5000个并行消费者。如果消费者不耐用，这是真的。但是，对于耐用消费者，在使用super.setClientId（clientId）（超级是SimpleMessageListenerContainer）的情况下，在第10个连接后，我得到：org.springframework.jms.IllegalStateException：不允许在已使用的连接上设置clientID；嵌套异常是javax.jms.IllegalStateException：不允许在已使用的连接上设置clientID

因此，我似乎无法使用使用SimpleMessageListenerContainer的持久订户进行会话，而只能用于连接。这是真的吗？maxConnections=500和maximumActive=1听起来合理吗？这解决了我的问题，但是……虽然JMS是新的，但对于代理来说，这似乎是过火了。

好吧，考虑到我仍然在正确的轨道上，我需要动态取消订阅我的消费者/listenr，所以我这样做了

container.stop();
container.destroy();

其中容器是SimpleMessageListenerContainer.container.destroy（）；调用时抛出一些异常。是需要调用它还是停止方法就足够了？

好吧，我知道这些问题是任意的，甚至对于了解jms(如果jms是正确的解决方案)并且几乎没有从我的代码中得到任何东西的人来说，也可能很难回答。我希望有人能就我是否在正确的轨道上给我一些指导，尽可能多地就所提出的问题给我输入，然后我可以在需要的地方给出代码，以解决我剩下的问题。

Answer 1

我缺乏关于spring的知识来回答您关于IllegalStateException的问题，尽管我猜这与maxConnections设置为10有关。

你需要Spring吗？在任何情况下，请确保在 JMS 代理的配置中启用了持久性，确保使用持久队列/主题，并确保对消息使用 setDurable（true）。

我认为，如果您想要可靠的消息传递，那么使用功能强大的JMS提供程序通常是正确的。您可以使用SPECjms2007基准测试各种产品，这取决于性能对您的重要性，也有一些可用的结果。