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 2.0 的 JMS 客户端实现（例如 ActiveMQ Artemis 核心 JMS 客户端）。