- 浏览: 82255 次
文章分类
- 全部博客 (32)
- java (32)
- java.lang.IncompatibleClassChangeError (1)
- mysql concat函数 字符串连接 (1)
- Java网络编程 (1)
- ActiveMQ中消息游标 (1)
- applicationContext-hibernate-transaction.xml (1)
- Google Chrome浏览器必备插件(附:Firefox火狐浏览器必备插件) (1)
- Oracle数据库文档构造器--Oraschemadoc (1)
- solaris essential (1)
- 使用Spring的test (1)
- org.springframework.dao.InvalidDataAccessApiUsageException: Write operations are (1)
- 《代码之道》 (1)
- 三亚之行 (1)
- StatCVS 对使用CVS的项目进行深入统计的开源工具 (1)
- 读写PDF TIFF JPEG文件的JAVA类库 (1)
- 应用MapXtreme2004开发GIS代码(C#) 搜索TAB表中的元素 (1)
- 购物车的实现及结算处理[转] (1)
- 微软发布搜索引擎 兼谈几个搜索引擎的比较 (1)
- 对于嵌入式系统的学习 应该可以告一段落了 (1)
- 移动审批工作流设计与实现 (1)
- SIFT算法概述 (1)
- 腾讯微博java(android) sdk 话题相关api详细介绍 (1)
- No configuration found. Configuring ehcache from ehcache-failsafe.xml (1)
- memcached client -- spymemcached使用 (1)
- Simple XML (1)
- 空指针错误 java.lang.NullPointerException (1)
- 服务器重起 (1)
- Spring中Quartz的Cron表达式详解 (1)
- swt 开发 (1)
- res.sendRedirect()和req.getRequestDispatcher().forward(req (1)
- res)的区别 (1)
- JAVA类设计技巧 (1)
- java之socket编程之谈 (1)
- 总结一下iteye上的足迹 (1)
最新评论
???????? 在 ActiveMQ 5.0的之前版本中,broker 会把正在传输的消息保存在内存中。使用这种内存模型,当一个消费者消费消息的速度跟不上生产者生产消息的速度的时候,会是 broker 内存中维护的正在传输的消息数量迅速增长,最终到达最大限额。当到达此最大限额后,broker 就不能接受来自客户端的消息,这样生产者就会被阻塞直到 broker 的内存中有保存消息的空间为止。
?????? 从 5.0 版本开始,ActiveMQ 实现了一种新的内存模型以防止慢速的消费者阻塞运行速度更快的生产者。这种内存模型使用了消息游标,详情请查看 http://activemq.apache.org/message-cursors.html 。 <br>??????? 当消息消费者在激活并且快速消息消息的情况下,紧跟消息的生产者。消息被消息存储并且被传递到消息者关联的broker对应的分发调度队列。
?<img src="http://dl.iteye.com/upload/picture/pic/93490/44ccef05-d76a-3530-a80a-f62c77770a27.png" alt="" width="479" height="360">
?
?
如果消息消费者处于激活状态,处于存储状态的消息处于等待状态或者消费者消费比生产者慢的时候,消息将通过等待指针把消息从消息存储中将消息放入分发队列中。
?
?<img src="http://dl.iteye.com/upload/picture/pic/93488/e47d858c-5326-3bce-9b18-1872ca08bf0a.png" alt="" width="484" height="366">
?
游标类型:
??? 在ActiveMQ5.0中默认消息指针类型是以存储为为基础。有两种类型的游标:vm Cursor和File Based Cursor。
?
Vm Cursor
????? 这种指针是从ActiveMQ4.x开始使用,当在需要的时候,消息将被存储到内存中同时把消息传递到分发队列中。这种基于内存指针速度很快,但是当消息者长时间处于非运行状态或者消息者消息很慢的时候,性能可能急速下降,内存占用比较高。
<img src="http://dl.iteye.com/upload/picture/pic/93494/108ba4ee-2a8f-38bc-88fd-e5dde8d5eb14.png" alt="" width="535" height="356">
?
File Based Cursor
? 这种指针在当Broker中内存达到最大的时候,指针将消息置入到磁盘上的临时文件中。这种消息的指针使用在消息者消费比较高。但是消息存储比较慢的情况。
发表评论
-
总结一下iteye上的足迹
2012-02-08 14:57 747<span style="bac ... -
java之socket编程之谈
2012-02-08 13:43 920<span style="col ... -
JAVA类设计技巧
2012-02-04 15:24 8001.一定要将数据设计为private 2.一定要 ... -
res.sendRedirect()和req.getRequestDispatcher().forward(req,res)的区别
2012-02-04 11:34 3233res.sendRedirect()=重定向 ... -
swt 开发
2012-02-03 17:14 8931. 下载 eclipse 3.7 2. 安装 goo ... -
Spring中Quartz的Cron表达式详解
2012-02-03 15:39 843<table style="& ... -
服务器重起
2012-02-03 14:54 603内报:141 外报:143,133 ? 外服:128 ... -
空指针错误 java.lang.NullPointerException
2012-02-02 14:44 874使用 ... -
Simple XML
2012-02-01 10:04 930<p style=""> ... -
memcached client -- spymemcached使用
2012-02-01 09:49 1277<a href="http://blo ... -
No configuration found. Configuring ehcache from ehcache-failsafe.xml
2011-12-28 13:23 1089<span style="font-f ... -
腾讯微博java(android) sdk 话题相关api详细介绍
2011-12-28 11:39 748<span style="font-f ... -
SIFT算法概述
2011-12-21 09:44 946<span></span> & ... -
移动审批工作流设计与实现
2011-12-20 10:59 1135<p style="text-ind ... -
对于嵌入式系统的学习 应该可以告一段落了
2011-12-19 10:19 667最近看了些关于嵌入式系统的资料,脑袋里对嵌入式开发的概 ... -
微软发布搜索引擎 兼谈几个搜索引擎的比较
2011-12-17 10:44 792微软于昨天(11月11日)正式发布其搜索引擎。这个是网 ... -
购物车的实现及结算处理[转]
2011-12-16 17:07 2659注:此文章来自CSDN。觉得代码挺清晰的,而且可能很多 ... -
应用MapXtreme2004开发GIS代码(C#) 搜索TAB表中的元素
2011-12-15 12:09 881</span></span>& ... -
读写PDF TIFF JPEG文件的JAVA类库
2011-12-14 09:49 3014这几种常见文件格式的读写类库,有人收集好了,详见下面网 ... -
StatCVS 对使用CVS的项目进行深入统计的开源工具
2011-12-14 09:19 696这个工具很好,主要是分析cvs的log得出统计结果,以 ...
相关推荐
ActiveMQ队列消息过期时间设置和自动清除解决方案.docx
springboot集成activemq实现消息接收demo
一个jms activemq Topic 消息实例 关于jms JMS 是接口,相当于jdbc ,要真正使用它需要某些厂商进行实现 ,即jms provider 常见的jms provider 有 ActiveMQ JBoss 社区所研发的 HornetQ (在jboss6 中默认即可以...
详细描述了ActiveMQ消息过期-时间设置和自动清除解决方案。
用C#实现的ActiveMQ发布/订阅消息传送源程序
activeMQ的发送消息后接收者返回信息
SpringBoot快速玩转ActiveMQ消息队列,jdk8下的简要版介绍。
SpringBoot整合ActiveMQ(消息中间件)实现邮件发送功能,里面含有详细业务逻辑代码,配置文件等
go语言实现的读取、发送消息到activemq,使用的stomp协议。
ActiveMQ(包括消息生成端和andorid消息接受端),实现了点对点的消息推送,和广播消息推送,当然离线推送也实现了。
activeMQ的测试工具,用于发送和接收activeMQ消息,jar包形式的,安装完jdk之后用java -jar xxx.jar命令运行
Android基于MQTT协议利用ActiveMQ发送消息给Android端接收,属于长连接那种,类似Socket通信
springboot整合ActiveMQ源码,适合范围消息队列入门小伙伴,对ActiveMQ消息队列不太了解,不知道如何发送消息,接收消息可以围观。
activemq消息中间件-视频教程activemq消息中间件-视频教程activemq消息中间件-视频教程activemq消息中间件-视频教程
百度spring整合activemq 发现几乎都只是在xml文件配置固定的消息队列而且太麻烦。并没有根据需求进行动态生成主题和队列。本文档参考了纯粹的... activemq下载文件中有一个demo 包含所有jar包。此处就不上传了。
NULL 博文链接:https://sswh.iteye.com/blog/1974169
简单的activemq点对点的同步消息模型
activemq消息持久化所需Jar包,详情请参见博文:http://blog.csdn.net/l1028386804/article/details/68997105
SpringBoot+ActiveMq+MQTT实现消息的发送和接收 后台消费者、生产者、消息发送接口、发送消息业务类等相关配置
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。 下载本压缩包后解压运行里面的activemq.bat即可。 http://192.168.0.61:8161/ 是管理ActiveMQ的后台管理系统入口, 如需在JAVA中使用,请下载本人的 ...