注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

小葫芦君(汉斯的博客)

博客迁移到新博客:https://blog.ssxingshou.com

 
 
 

日志

 
 
关于我

小小葫芦商城,为您提供高品质的商品,一流的产品,一流的包装服务,一流的物流服务,放心购买

网易考拉推荐

ActiveMQ 的优化和集群问题总结  

2012-09-21 11:30:33|  分类: 默认分类 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
1、集群

1>、同一ActiveMQ Broker集群安装两个台,但每台间不需要为集群作特殊配置,彼此不要感知。
2>、消息发送者以failover:(nio:ip1,nio:ip2)方式连接上两台机器。消息接收者分别以nio:ip1和nio:ip2建立到这两IP的两单独连接(两路消息接收器)。

消息发送者都是以topic方式发送消息,接收者都以queue方式收消息,topic/queue中间的对接用ActiveMQ内置的camel对接。

<transportConnector name="nio" uri="nio://0.0.0.0:51616"/>

对接比较简单:就是利用camel的路由功能。

配置camel.xml,并在mq的配置文件里面启用camel服务器,但5.6.0版本已经去除了webapps,这样就没web控制台,暂时就手工编写吧。

         <route>
            <description>Example Camel Route</description>
            <from uri="activemq:topic:myTopic"/>
            <to uri="activemq:queue:myQueue"/>
        </route>
       
        <route>
            <description>Example Camel Route2</description>
            <from uri="activemq:topic:myTopic"/>
            <to uri="activemq:queue:myTopicNew"/>
        </route>

这样就配置好了,负载均衡的目的和扩展的目的就达到了,接收者只需要关注queue即可。

启动后的日志:
 INFO | Connector vm://localhost Started
 INFO | Route: route1 started and consuming from: Endpoint[activemq://topic:myTopic]
 INFO | Route: route2 started and consuming from: Endpoint[activemq://topic:myTopic]
 INFO | Total 2 routes, of which 2 is started.
 INFO | Apache Camel 2.9.2 (CamelContext: camel) started in 0.729 seconds

2、优化

具体的优化配置等后面再写。

消息存储与crash后的堆积消息的发送问题:

1、kahadb 官方默认的存储方式
        <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb" enableJournalDiskSyncs="false" indexWriteBatchSize="10000" indexCacheSize="1000"/>
        </persistenceAdapter>

2、Amq持久方式可以设置Data文件最大Size,这样可以保证即时消息积压很多,Data文件也不至于过大。
<persistenceAdapter>
      <amqPersistenceAdapter directory="activemq-data" maxFileLength="32mb" />
 </persistenceAdapter>
  评论这张
 
阅读(4273)| 评论(0)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017