java - Artemis 使用 JMS 持久订阅多播地址

Question

使用 JMS，我想为某个主题(多播地址)创建一些持久订阅。如果有一个双重订阅，它可以工作，但如果有更多订阅，它就不能工作，并且会发生错误。

这些是我的听众:也许属性没有正确填写？

 @JmsListener(destination = "VirtualTopic.test", id = "c1", subscription = "Consumer.A.VirtualTopic.test", containerFactory = "queueConnectionFactory")
public void receive1(String m) {

}


@JmsListener(destination = "VirtualTopic.test", id = "c2", subscription = "Consumer.B.VirtualTopic.test", containerFactory = "queueConnectionFactory")    
public void receive2(String m) {

}

这是listenerFactory:我不确定最后一个属性。

    @Bean
    public DefaultJmsListenerContainerFactory queueConnectionFactory() {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory());
        factory.setClientId("brokerClientId");
        factory.setSubscriptionDurable(true);
        factory.setSubscriptionShared(true);       **<-- needed for my case?**
        return factory;
    }

    @Bean
    public ActiveMQConnectionFactory connectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
        return connectionFactory;
    }

这些是当我设置“factory.setSubscriptionShared(true);”时的错误日志:

2020-04-17 11:23:44.485  WARN 7900 --- [enerContainer-3] o.s.j.l.DefaultMessageListenerContainer  : Setup of JMS message listener invoker failed for destination 'VirtualTopic.test' - trying to recover. Cause: org.apache.activemq.ActiveMQSession.createSharedDurableConsumer(Ljavax/jms/Topic;Ljava/lang/String;Ljava/lang/String;)Ljavax/jms/MessageConsumer; 
2020-04-17 11:23:44.514 ERROR 7900 --- [enerContainer-3] o.s.j.l.DefaultMessageListenerContainer  : Could not refresh JMS Connection for destination 'VirtualTopic.test' - retrying using FixedBackOff{interval=5000, currentAttempts=0, maxAttempts=unlimited}. Cause: Broker: d1 - Client: brokerClientId already connected from /127.0.0.1:59979

Answer 1

正如 JMS 规范所指出的，只有一个具有相同 ID 的客户端可以连接。您显然对所有连接使用相同的客户端 ID，即:

factory.setClientId("brokerClientId");

尝试不设置客户端 ID，看看效果如何。

此外，请确保您使用的 JMS 客户端实现实际上支持 JMS 2.0(例如 ActiveMQ Artemis 核心 JMS 客户端)。