首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 其他教程 > 开源软件 >

ActiveMq 施用经历

2013-07-20 
ActiveMq 使用经历一. 需求一处产生消息,两处消费,故采取Topic模式的activemq.二.下载及安装http://active

ActiveMq 使用经历
一. 需求
     一处产生消息,两处消费,故采取Topic模式的activemq.

二.  下载及安装
http://activemq.apache.org/下载最新版本。
解压, 进入安装目录 bin/activemq start xbean:conf/activemq.xml
http://localhost:8161/admin查看mq状态,用户名和密码在conf/jetty-realm.properties,默认是admin, admin
至此server已启动。
三. server配置
conf/activemq.xml
    1. message cursors, 引用http://www.chinacreator.com/technique/rjhxjs/content_468.html介绍的比较详细,大部分情况下用默认的Store-based cursor就能满足需求
    2. producer-flow-control
         http://activemq.apache.org/producer-flow-control.html
     生产者流量控制,当内存和硬盘空间到达的时候控制流量,抛出异常或挂起等待,个人觉得在有message cursors的时候可以禁用
    3. slow consumer handling
      对于nondurable 的consumer,要求broker未其保存未消费的message在内存中,会导致生产者阻塞,其他的快速消费者变慢,所以可以设置一个限制大小的消息队列。
constantPendingMessageLimitStrategy
     4. jmx enable
      未研究todo


四. ps
about durable topics, non-durable模式下,如果订阅者不在线,那么其不在线期间topic上收到的消息将不会被该订阅者收到,如果想要一个订阅者收到topic上的所有消息,请使用durable模式, 推荐使用durable模式,可以免去生产者流量控制和慢消费者处理的麻烦

about transaction mode,  server 有transactionstore, 缓存所有的message和acks不执行,直到commit 和 rollback到达,另外也不把commit 和 rollback之前的message和acks放到分发的队列上去

热点排行