是否可以使用 spring jms 停止和重新启动持久订阅？

Question

我正在使用以下 DefaultMessageListenerContainer 创建一个持久订阅，即使在停机时间也能获取消息，这确实很有效。

@Bean
ConnectionFactory connectionFactory() {
    SingleConnectionFactory connectionFactory = new SingleConnectionFactory(new ActiveMQConnectionFactory(
            AMQ_BROKER_URL));
    connectionFactory.setClientId(CLIENT_ID);
    return connectionFactory;
}

@Bean
DefaultMessageListenerContainer container(final MessageListener messageListener,
        final ConnectionFactory connectionFactory) {
    return new DefaultMessageListenerContainer() {
        {
            setMessageListener(messageListener);
            setConnectionFactory(connectionFactory);
            setDestinationName(JMS_TARGET);
            setPubSubDomain(true);
            setSessionTransacted(true);
            setSubscriptionDurable(true);
            setDurableSubscriptionName(SUBSCRIPTION_ID);                        
            setConcurrentConsumers(1);
        }
    };
}

问题是：当我不再需要订阅时，删除订阅的最佳方法是什么？是否可以暂时删除订阅（并错过一些消息），但稍后再启用它？

到目前为止，唯一可行的方法是关闭 DMLC，然后调用取消订阅。

dmlc.shutdown();
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
session.unsubscribe(SUBSCRIPTION_ID);

这是一个明智的解决方案吗？如何重新开始订阅？

我已经看过this answer，但我真的不知道该怎么做？或者以完全不同的方式订阅和取消订阅会更好吗？

Answer 1

在我提出我的答案之前，请允许我提一句：暂时删除持久订阅听起来有点像您真的不需要持久订阅。持久订阅适用于需要接收离线时发送的消息的Consumers。如果您仅在某些时候需要消息（例如，当您的消费者连接时），则可以选择非持久主题。

请注意，这只对Topics 有意义（1:n 通信，发布/订阅）。 Queues 的工作方式略有不同，因为它们用于 1:1 通信（暂时搁置负载平衡等先进技术）。

持久主题会在消息代理上产生显着的资源开销，并且删除和重新创建订阅可能会导致一遍又一遍地进行昂贵的初始化。

现在，如果您真的想（暂时）取消订阅持久主题（也适用于“正常”主题），则必须扩展 DefaultMessageListenerContainer：

public class MyContainer extends DefaultMessageListenerContainer {
    public Session retrieveSession() {
        return getSession(); // this is protected, so we wrap it (could also make getSession public)
    }
}

当您在container 方法中实例化MyContainer（而不是DefaultMessageListenerContainer）时，请确保存储引用：

protected MyContainer listenerContainer;
...
listenerContainer = new MyContainer(...);
return listenerContainer;

然后您可以拨打listenerContainer.retrieveSession().unsubscribe(...) 取消订阅。

还请注意，您只能在该主题的所有会话消费者都关闭并且没有传输中的消息后调用此函数（直接引用documentation：“客户端删除持久订阅是错误的当订阅有一个活动的（未关闭的）消费者时，或者当消费的消息是待处理事务的一部分或尚未在会话中得到确认时。”