ActiveMQ（十二）——Consumer高级特性-创新互联

一、独有消费者
    Queue中的消息是按照顺序被分发到consumers的，然而，当有多个consumers同时从相同的queue中提取消息时，你将失去这个保证。因为这些消息是被多个多线程并发的处理。有的时候，保证消息按照顺序处理是很重要的，但是你可能不希望在插入订单操作结束之前执行更新这个订单的操作。
    ActiveMQ从4.x版本起开始支持Exclusive Consumer。Broker会从多
个consumers中挑选一个consumer来处理queue中所有的消息，从而保证消息的有序处理。如果这个consumer失效，那么broker会自动切换到其他的consumer。可以通过Destination Options来创建一个Exclusive Consumer，如下：
    queue = new ActiveMQ(“TEST.QUEUE?Consumer.exclusive=true”);
    Consumer = session.createConsumer(queue);
    还可以给consumer设置优先级，以便针对网络情况进行优化，如下：

成都创新互联网站建设提供从项目策划、软件开发，软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务，主营业务为做网站、成都网站建设，app软件开发以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。成都创新互联深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

queue = new ActiveMQQueue(“TEST.QUEUE?Consumer.exclusive=true
&consumer.priority=10”);

二、消息异步分发

三、消息优先级

三、管理持久化消息

四、消息分组
    消息分组可以看成是一种并发的Exclusive Consumer。跟所有的消息都由唯一的consumer处理不同，JMS消息属性JMSXGroupID被用来区分message group。
Message Groups特性保证所有具有相同JMSXGroupID的消息会被分发到相同的consumer（只要这个consumer保持active）
    另一方面，消息分组特性也是一种负载均衡的机制。在一个消息被分发到consumer之前，broker首先检查消息JMSXGroupID属性。如果存在，那么broker会检查是否有某个consumer拥有这个message group。
    如果没有，那么broker会选择一个consumer，并将它关联到这个message group。此后，这个consumer会接收这个message group的所有消息，直到：

• 创建一个Message Groups，只需要在message对象上设置属性即可，如下：
  message.setStringProperty("JMSXGroupID","GroupA");

• 关闭一个Message Groups，只需要在message对象上设置属性即可，如下：
  message.setStringProperty("JMSXGroupID","GroupA");
  Message.setIntProperty("JMSXGroupSeq",-1);
  六、消息选择器
  
  七、消息重递策略
  
  
  
  八、消费者追溯消息
  
  九、慢消费者处理
  
  
  
  

创新互联www.cdcxhl.cn，专业提供香港、美国云服务器，动态BGP最优骨干路由自动选择，持续稳定高效的网络助力业务部署。公司持有工信部办法的idc、isp许可证， 机房独有T级流量清洗系统配攻击溯源，准确进行流量调度，确保服务器高可用性。佳节活动现已开启，新人活动云服务器买多久送多久。

本文名称：ActiveMQ（十二）——Consumer高级特性-创新互联
文章起源：http://dzwzjz.com/article/dpsijh.html