ActiveMQ消息特性：通知消息（Advisory Message）

电玩女神 2022-06-12 04:29 275阅读 0赞

### 通知消息（Advisory Message） ###

简单的说就是实现了ActiveMQ的broker上各种操作的记录跟踪和通知。

使用这个功能，你可以实时的知道broker上

1.  创建或销毁了连接，
2.  添加或删除了生存者或消费者，
3.  添加或删除了主题或队列，
4.  有消息发送和接收，
5.  什么时候有慢消费者，
6.  什么时候有快生产者
7.  什么时候什么消息被丢弃
8.  什么时候broker被添加到集群（主从或是网络连接）

这个机制是ActiveMQ对JMS协议的重要补充，也是基于JMS实现的ActiveMQ的可管理性的一部分。多个ActiveMQ的相互协调和互操作的基础设置。

### 使用示例与注意事项 ###

使用很简单，完全的jms方式，示例如下

...
    
        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);
            }
        }
    }

通过拿到的消息的数据结构，可以进一步的拿到相关操作信息。

而且Advisory消息都是先返回当前的所有存在数据，比如现在已经存在的所有连接或是队列信息，然后再实时通知你新创建和断开的连接，新添加或删除的队列等等。。。

ActiveMQ.Advisory.Queue [数据结构][Link 1]为DestinationInfo，先拿到broker上现有的所有队列列表  
如果再有add或remove队列的操作，拿到通知，operationType=0为add，为1则为remove  
为topic时，自动过滤掉Advisory的topic。  
  
ActiveMQ.Advisory.Producer.Queue 数据结构为ProducerInfo，其中包含Producer的参数信息  
ActiveMQ.Advisory.Consumer.Queue 数据结构为ConsumerInfo，其中包含Consumer的参数信息  
使用的时候，需要以此为前缀，监听需要的队列，比如kk.adt,则应该写  
Topic topic = new ActiveMQTopic("ActiveMQ.Advisory.Consumer.Queue.kk.adt");  
监听所有队列则  
Topic topic = new ActiveMQTopic("ActiveMQ.Advisory.Consumer.Queue..>");  
Producer或Consumer断开时，数据结构为RemoveInfo。  
主题的监听类似。

持久订阅者上线时是ConsumerInfo，里面有clientId和consumerId，下线时的RemoveInfo里有consumerId，跟上线时对应。  
  
ActiveMQ内置了一些工具类，根据你需要监听的队列名，自动拼Advisory的名称：  
例如 AdvisorySupport.getProducerAdvisoryTopic(new ActiveMQTopic("kk.adt"));  
  
broker接收到或是投递消息的通知默认是关闭的。  
需要在policy上设置相应的开关。 消息处理相关的Advisory的数据结构是消息本身。

### 客户端连接相关的通知消息 都是默认开启的 ###

### 队列和消息的通知消息  队列相关的是默认开启的，消息相关的都需要手工配置Pilocy选项开启 ###

### 从5.2版本新加的消息处理与性能相关的，都需要手工启动 ###

<table style="font-size:10px; color:rgb(0,0,0); margin:5px; border-collapse:collapse"> 
 <tbody> 
  <tr style="font-size:10px"> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> Advisory Topics</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> Description</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> properties</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> Data Structure</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> default</th> 
   <th style="border:1px solid rgb(204,204,204); padding:3px 4px; background-color:rgb(240,240,240); text-align:center"> PolicyEntry property</th> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.SlowConsumer.Queue</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Slow Queue Consumer</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='consumerId' - the consumer id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ConsumerInfo</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForSlowConsumers</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.SlowConsumer.Topic</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Slow Topic Consumer</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='consumerId' - the consumer id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ConsumerInfo</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForSlowConsumers</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.FastProducer.Queue</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Fast Queue producer</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='producerId' - the producer id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ProducerInfo</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisdoryForFastProducers</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory. FastProducer.Topic</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Fast Topic producer</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='consumerId' - the producer id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ProducerInfo</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisdoryForFastProducers</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageDiscarded.Queue</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message discarded</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the discarded id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForDiscardingMessages</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageDiscarded.Topic</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message discarded</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the discarded id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForDiscardingMessages</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageDelivered.Queue</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message delivered to the broker</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the delivered id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForDelivery</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageDelivered.Topic</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message delivered to the broker</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the delivered id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForDelivery</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageConsumed.Queue</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message consumed by a client</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the delivered id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForConsumed</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MessageConsumed.Topic</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message consumed by a client</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='orignalMessageId' - the delivered id</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> Message</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryForConsumed</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.FULL</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> A Usage resource is at its limit</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> String='usageName' - the name of Usage resource</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> null</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> false</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> advisoryWhenFull</td> 
  </tr> 
  <tr style="font-size:10px"> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> ActiveMQ.Advisory.MasterBroker</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> A broker is now the master in a master/slave configuration</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> null</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> null</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> true</td> 
   <td style="font-family:verdana,arial,helvetica,sans-serif; font-size:10px; border:1px solid rgb(204,204,204); padding:3px 4px"> none</td> 
  </tr> 
 </tbody> 
</table>

### 从5.4版本新加的DLQ的通知消息 ###

### 从5.5版本新加的网络连接集群的通知消息 ###

### 打开通知消息开关的示例 ###

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

此外，在broker上有个通知消息的总开关，设置false以后，所有的Advisory都不可用：

<broker advisorySupport="false">...

[Link 1]: http://lib.csdn.net/base/datastructure