咨询消息

功能 > 消息功能 > 咨询消息

ActiveMQ Classic 支持咨询消息，允许您使用常规 JMS 消息监视系统。目前，我们有支持以下内容的咨询消息：

• 消费者、生产者和连接启动和停止
• 创建和销毁临时目标
• 主题和队列上的消息过期
• 代理向没有消费者的目标发送消息。
• 连接启动和停止

咨询消息可以被认为是一种管理通道，您可以在其中接收有关 JMS 提供程序上发生的事情以及生产者、消费者和目标上发生的事情的信息。 当您通过 JMX 查看代理时，您将看到以 ActiveMQ.Advisory. 为前缀的咨询主题。

每个咨询都具有消息 类型 Advisory 和一些预定义的消息属性

此外，一些消息会携带一个 Command 对象，该对象包含有关咨询性质的额外信息，例如，对每个目标的订阅会返回一个 ActiveMQMessage。 可以使用 ActiveMQMessage.getDataStructure() 检索特定 DataStructure 对象，例如 ConsumerInfo、ProducerInfo、ConnectionInfo。

例如

Destination advisoryDestination = AdvisorySupport.getProducerAdvisoryTopic(destination)
MessageConsumer consumer = session.createConsumer(advisoryDestination);
consumer.setMessageListener(this);

public void onMessage(Message msg){
    if(msg instanceof ActiveMQMessage) {
        try {
             ActiveMQMessage aMsg = (ActiveMQMessage)msg;
             ProducerInfo prod = (ProducerInfo) aMsg.getDataStructure();
        } 
        catch(JMSException e) {
            log.error("Failed to process message: " + msg);
        }
    }
}

支持以下咨询主题

基于客户端的咨询

提示

这些总是生成的。

请注意，消费者启动/停止咨询消息还具有一个 consumerCount 标头，以指示发送咨询消息时目标上活动消费者的数量。 这意味着您可以使用以下选择器在给定目标上没有活动消费者时收到通知

consumerCount = 0

基于目标和消息的咨询

提示

NoConsumer 主题咨询仅针对非持久性消息发送。

5.2 版本中的新咨询

5.4 版本中的新咨询

网络桥接咨询

从 ActiveMQ Classic 5.5 版本开始，您可以监视与网络桥接状态相关的事件的咨询主题。 网络桥接启动或停止时，您可以获得咨询消息。

启用默认情况下禁用的咨询

默认情况下未打开的咨询（请参阅最后一列）可以在 ActiveMQ Classic 代理配置中的 PolicyEntry 上启用，例如，要启用消息消费咨询，您可以配置以下内容

<destinationPolicy>
    <policyMap>
       <policyEntries> 
           <policyEntry topic=">" advisoryForConsumed="true"/>
       </policyEntries>
    </policyMap>
</destinationPolicy>

提示

> 字符匹配所有主题 - 您可以使用通配符匹配来设置目标策略 - 请参阅 通配符

禁用咨询消息

咨询消息的使用会导致内存和连接资源方面的一点开销，这与系统中的目标数量有关。 在某些情况下，禁用所有咨询可能很有意义。

咨询需要在代理上禁用，通过 XML 配置

<broker advisorySupport="false">

或从 Java 代码

BrokerService broker = new BrokerService();
broker.setAdvisorySupport(false);
// ...
broker.start();

以及在您的 ActiveMQConnectionFactory 上（因为对咨询主题的订阅会自动创建它）通过 brokerUrl

tcp://127.0.0.1:61616?jms.watchTopicAdvisories=false

或通过使用 ActiveMQConnectionFactory 上的 watchTopicAdvisories 属性的 Java 代码。

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
factory.setWatchTopicAdvisories(false);

警告

咨询消息是 动态网络代理拓扑 所必需的，因为 NetworkConnectors 会订阅咨询消息。 如果没有咨询消息，则网络必须进行静态配置。

使用目标

以上所有目标实际上都是前缀，这些前缀会附加重要的信息（如实际的主题或队列、客户端 ID、生产者 ID、消费者 ID 等）。 这使您可以重复使用发布/订阅、通配符 和 选择器 的功能来按需筛选咨询消息。

例如，如果您想订阅主题 FOO.BAR 上的过期消息，您可以订阅 ActiveMQ.Advisory.Expired.Topic.FOO.BAR。 要订阅特定类型咨询的所有消息，只需在主题后附加 .>，例如，要订阅所有对主题和队列启动和停止的消费者，请订阅 ActiveMQ.Advisory.Consumer..>。

帮助方法

用于获取咨询目标对象的方法在 AdvisorySupport 中通过以下方法提供。

• AdvisorySupport.getConsumerAdvisoryTopic()
• AdvisorySupport.getProducerAdvisoryTopic()
• AdvisorySupport.getExpiredTopicMessageAdvisoryTopic()
• AdvisorySupport.getExpiredQueueMessageAdvisoryTopic()
• AdvisorySupport.getNoTopicConsumersAdvisoryTopic()
• AdvisorySupport.getNoQueueConsumersAdvisoryTopic()
• AdvisorySupport.getDestinationAdvisoryTopic()
• AdvisorySupport.getExpiredQueueMessageAdvisoryTopic()
• AdvisorySupport.getExpiredTopicMessageAdvisoryTopic()
• AdvisorySupport.getNoQueueConsumersAdvisoryTopic()
• AdvisorySupport.getNoTopicConsumersAdvisoryTopic()

// 5.2 版本及以上

• AdvisorySupport.getSlowConsumerAdvisoryTopic()
• AdvisorySupport.getFastProducerAdvisoryTopic()
• AdvisorySupport.getMessageDiscardedAdvisoryTopic()
• AdvisorySupport.getMessageDeliveredAdvisoryTopic()
• AdvisorySupport.getMessageConsumedAdvisoryTopic()
• AdvisorySupport.getMasterBrokerAdvisoryTopic()
• AdvisorySupport.getFullAdvisoryTopic()

一些用于处理咨询消息的帮助类在 advisories 包中提供。