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

一时失言乱红尘 2022-06-13 03:10 208阅读 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 数据结构为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。   
主题的监听类似。   
  
ActiveMQ内置了一些工具类，根据你需要监听的队列名，自动拼Advisory的名称：   
例如 AdvisorySupport.getProducerAdvisoryTopic(new ActiveMQTopic("kk.adt"));   
  
broker接收到或是投递消息的通知默认是关闭的。   
需要在policy上设置相应的开关。 消息处理相关的Advisory的数据结构是消息本身。

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

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

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

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