开发者社区> 行者武松> 正文

【转】ActiveMQ与虚拟通道

简介:
+关注继续查看

ActiveMQ提供了虚拟通道的特性(Virtual Destination),它允许一个逻辑通道(logical destination)映射成一个或者多个物理通道(physical destination);它可以非常灵活的解决"消息整合"方面的问题,它可以实现:

    1) 提供了VirtualTopic特性,可以让一个订阅者的消息列表,作为Queue来消费。

    2) 提供了Composite特性,可以把一个逻辑通道中的消息,转发到任意多的物理通道中。

 

一. VirtualTopic

   Topic最大的限制就是同一个ClientId的订阅者,任何时刻只能有一个活跃。所以我们在分布式部署时,就会很麻烦,比如一个应用部署成多个实例,且它们都有相同的Topic Consumer配置,那么意味着

一个实例部署成功后,其它的实例都会因为无法订阅Topic而导致故障;同时也意味着,如果这个Topic Consumer失效后,我们不能自动让其他Consumer的接管它。但是Queue却没有这些限制,因为Queue可以同时有任意多个消费者,它们可以并发的消费消息,从而实现“负载均衡”。如果我们期望Topic也能如此,那么可以用VirtualTopic。

Java代码  收藏代码
  1. <broker xmlns="http://activemq.apache.org/schema/core">  
  2.   <destinationInterceptors>  
  3.     <virtualDestinationInterceptor>  
  4.       <virtualDestinations>  
  5.         <virtualTopic name=">" prefix="VConsumers.*." selectorAware="false"/>  
  6.       </virtualDestinations>  
  7.     </virtualDestinationInterceptor>  
  8.   </destinationInterceptors>  
  9. </broker>  

 

    对于所有的VirtualTopic,它们的namespace一定是"VirtualTopic.",Broker将会根据此namespace来判定逻辑通道是否为VirtualTopic,反过来说,如果你希望一个逻辑通道是一个VirtualTopic,那么它必须以“VirtualTopic.”作为前缀。比如“VirtualTopic.order”,那么它就是一个VirtualTopic,它的物理通道名称为"order"。

 

    对于Producer端,需要按照正常的Topic发送消息,通道名称为逻辑通道全名:

Java代码  收藏代码
  1. Topic topic = session.createTopic("VirtualTopic.order");  
  2. MessageProducer producer = session.createProducer(topic);  
  3. //producer.send(message);  

 

     VirtualTopic对Consumer而言,是一个逻辑的Queue,Queue的全名有上述配置文件中的“prefix” + Client标识 + 逻辑虚拟通道;假如“Client标识”为"dbcenter"【相当于ClientId】,用来订阅Order消息,那么最终逻辑Queue的全名为:"VConsumers.dbcenter.VirtualTopic.order",其中需要注意prefix中的"*"占位符就是用来替换“Client标识”的;Broker端默认的prefix为"Consumer.*."。当然我们还可以postfix【后缀】,不过通常没有必要。

Java代码  收藏代码
  1. Queue queue = session.createQueue("VConsumers.dbcenter.VirtualTopic.order");  
  2. MessageConsumer consumer = session.createConsumer(queue);  

 

    对于Order通道而言,“dbcenter”相当于是一个订阅者;Broker将dbcenter订阅的消息转发到了“VConsumers.dbcenter.VirtualTopic.order”队列中;最重要的一点,这个虚拟Queue完全具有队列的所有特性,它的Consumer可以并行消费。

 

    其中还有一个重要的参数"selectorAware",它表示从Topic中将消息转发给Queue时,是否关注Consumer的selector情况。如果为false,那么Topic中的消息全部转发给Queue,否则只会转发匹配Queue Consumer的selector的消息。需要非常注意,当selectorAware为true时,如果消息不匹配任何selector或者Queue中没有任何Consumer活跃,那么消息将不会转发给Queue。

 

     VirtualTopic仍然可以被正常的订阅者消费,即:

Java代码  收藏代码
  1. Topic topic = session.createTopic("VirtualTopic.order");  
  2. TopicSubscriber subscriber = session.createDurableSubscriber(topic,"dbcenter");  

 

     同时需要注意,VirtualTopic只会转发“Client标识”注册之后的消息,且即使Queue消费了消息,VirtualTopic中的消息仍然不会被删除(看起来仍然是Dequeued=0),对于Broker而言,逻辑Queue不被认为是一个“Durable Subscriber”,只有真正的Subscriber消费消息后,Topic中的消息才会Dequeue。不过消息Dequeue后,不会影响Queue中的消息,因为这是基于Copy的。

 

    到目前为止,我尚不清楚,如果VirtualTopic中没有真正的Subscriber,这些消息该如何Dequeue。

 

    当真正的subscriber和Queue都同时存在VirtualTopic中的时候,而且你的broker架构采用了“forward-brige”结构,那么你需要增加如下配置来避免消息的重复转发问题。在forward-brige架构中,任何通道中的消息都会forward到其他network node中(其他broker上),当然这个虚拟的Queue的消息也不例外。

Java代码  收藏代码
  1. <networkConnectors>  
  2.   <networkConnector uri="static://(tcp://localhost:61617)">  
  3.     <excludedDestinations>  
  4.         <!-- prefix和VirtualTopic保持一致  
  5.         <queue physicalName="VConsumer.*.VirtualTopic.>"/>  
  6.     </excludedDestinations>  
  7.   </networkConnector>  
  8. </networkConnectors>  

 

 二. Composite Destinations

    复合通道,它允许一条消息在多个物理通道间转发,就像一个通道映射成多个一样(one-many);比如复合通道A,映射成B和C,那么发往A的消息会同时转发给B和C,那么消费者可以直接通过B或者C获取消息;

这是一种实现消息复制转发、通道映射的便捷办法。复合通道包括CompositeQueue和CompositeTopic两种。

Java代码  收藏代码
  1. <broker persistent="false" useJmx="false" xmlns="http://activemq.apache.org/schema/core">  
  2.     <destinationInterceptors>  
  3.       <virtualDestinationInterceptor>  
  4.         <virtualDestinations>  
  5.           <compositeQueue name="order">  
  6.             <forwardTo>  
  7.               <queue physicalName="order.dbcenter" />  
  8.               <topic physicalName="order.statistic" />  
  9.             </forwardTo>  
  10.           </compositeQueue>  
  11.  <!--   
  12.  <compositeTopic name="order" forwardOnly="false">  
  13.             <forwardTo>  
  14.               <queue physicalName="order.dbcenter" />  
  15.               <topic physicalName="order.statistic" />  
  16.             </forwardTo>  
  17.           </compositeTopic>  
  18.  -->  
  19.         </virtualDestinations>  
  20.       </virtualDestinationInterceptor>  
  21.     </destinationInterceptors>  
  22.    
  23.   </broker>  

 

    上述配置forwardOnly属性表示发往CompositeQueue中的消息是否“仅仅转发,而不本地保留”,如果forwardOnly为true,那么消息将不会在order队列中保留,即order队列中不会有任何消息。如果为false,那么消息将会转发完成后,添加到order中,消费者仍然可以消费order队列中的消息。无论是Compsite通道还是转发的通道,它们和普通的通道没有任何区别,开发者仍然可以像使用普通的通道一样使用它们(消费消息和发送消息)。

  

    很多时候,我们希望在转发消息时,能够使用selector,此时我们可以使用filteredDestination,这样我们可以消息转发时控制消息。

Java代码  收藏代码
  1. <compositeQueue name="MY.QUEUE">  
  2.     <forwardTo>  
  3.          <filteredDestination selector="orderType = 1" queue="food.order"/>  
  4.         <filteredDestination selector="status = 1" topic="order.statistic"/>  
  5.     </forwardTo>  
  6. </compositeQueue>  

原文链接:[http://wely.iteye.com/blog/2328781]

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
18705 0
阿里云服务器ECS登录用户名是什么?系统不同默认账号也不同
阿里云服务器Windows系统默认用户名administrator,Linux镜像服务器用户名root
13894 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
25091 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
20424 0
使用SSH远程登录阿里云ECS服务器
远程连接服务器以及配置环境
13537 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,大概有三种登录方式:
9725 0
腾讯云服务器 设置ngxin + fastdfs +tomcat 开机自启动
在tomcat中新建一个可以启动的 .sh 脚本文件 /usr/local/tomcat7/bin/ export JAVA_HOME=/usr/local/java/jdk7 export PATH=$JAVA_HOME/bin/:$PATH export CLASSPATH=.
13948 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
18705 0
+关注
行者武松
杀人者,打虎武松也。
17142
文章
2569
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载