随笔分类 - activeMQ摘要: http://www.cnblogs.com/CopyPaster/archive/2012/04/27/2473179.html阅读全文 posted @ 2013-08-20 11:35 悟寰轩-叶秋| 编辑
摘要: http://www.cnblogs.com/baibaluo/archive/2012/12/24/2748468.html#2590289公司有一个应用，多个线程从activeMQ中取消息，随着业务的扩大，该机器占用的网络带宽越来越高。仔细分析发现，mq入队时并没有异常高的网络流量，仅仅在出队时会产生很高的网络流量。最终发现是spring的jmsTemplate与activemq的prefetch机制配合导致的问题。研究源码发现jmsTemplate实现机制是：每次调用receive()时都会创建一个新的consumer对象，用完即销毁。正常情况下仅仅会浪费重复创建consumer的资源代阅读全文 posted @ 2013-08-06 17:12 悟寰轩-叶秋| 编辑
摘要: 转自：http://www.cnblogs.com/CopyPaster/archive/2012/04/27/2473179.html目前常用的消息队列组建无非就是MSMQ和ActiveMQ，至于他们的异同，这里不想做过多的比较。简单来说，MSMQ内置于微软操作系统之中，在部署上包含一个隐性条件：Server需要是微软操作系统。（对于这点我并去调研过MSMQ是否可以部署在非微软系统，比如:Linux，只是拍脑袋想了想，感觉上是不可以）。对于ActiveMQ，微软系统和Linux都是可以部署的。从功能方面来说，一般最常用的就是：消息的收/发，感觉差异不大。从性能上来说，一般的说法是Active阅读全文 摘要: 接收的时候指定MessageIDActiveMQConnection connection = (ActiveMQConnection) new ActiveMQConnectionFactory().createConnection();Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//P_1为消息IDMessageConsumer myConsumer = session.createConsumer(session.createTopic("TestMessage"阅读全文 posted @ 2013-01-25 10:09 悟寰轩-叶秋| 编辑
摘要: 1 <broker xmlns="http://activemq./schema/core" schedulePeriodForDestinationPurge="10000">2 <destinationPolicy>3 <policyMap>4 <policyEntries>5 <policyEntry queue=">" gcInactiveDestinations="true" inactiveTimoutBeforeGC=&q阅读全文 posted @ 2013-01-25 10:08 悟寰轩-叶秋| 编辑
摘要: JMS，Java Message Service，是JavaEE平台最重要的规范之一， 也是企业开发中经常使用到的异步技术。JMS规范目前支持两种消息模型：点对点（point to point， queue）和发布/订阅（publish/subscribe，topic）。点对点：消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。这里要注意：消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费。发布/订阅消息生产者（发布）将消息发布到topic中，同时有多个阅读全文 摘要: 转自：http://marshal./archives/1414activemq可以单独部署和执行，比如类似ActiveMQ的最简单应用中提到的安装和执行方式。但是有时候需要作为一个web应用部署在servlet容器中，这样利于和其他web应用的配合。官方文档上有一个针对这种需求的文档：http://activemq./web-console.html根据文档，使用tomcat 6.0.20，activemq 5.2.0。实现了上述需求。首先需要下载：activemq-web-consoleactivemq-all前者直接复制到tomcat的web阅读全文
|
|
|
来自： WindySky > 《ActiveMQ》
