配置:
1. brokerURL
failover:(tcp://xxx.xxx.xxx.1:61616?tcpNoDelay=true,tcp://xxx.xxx.xxx.2:61616?tcpNoDelay=true,tcp://xxx.xxx.xxx.3:61616?tcpNoDelay=true)?timeout=10000&randomize=false
主从模式必须加上randomize=false。
发送:
1. 重要消息采用默认的同步发送useAsyncSend=true;
2. 加上线程池;
3. 批量发送加上事务。
同步发送采用线程池和事务批量发送的话,本机测试(levelDB持久化) 10W消息12秒发送完比,约8000/S。
接收:
1. 加上线程池;
2. 重要消息加上事务,保证一个consumer抛Exception后消息能转发到其它consumer;
3. 不能容忍重复的消息一定要加上去重处理,当consumer没有ACK之前停机一定会发生重复消息且redeliveryCounter=0(这里不知是否没配置对)。可运行activeMQ自己的测试类RedeliveryPolicyTest.java中的testRepeatedRedelivery*方法,在“connection.close()”之前停止运行。
消息确认:
1. optimizeAcknowledge:每批次消息消费65%后发送确认,假如某个queue的destination为"queue.test.msg?consumer.prefetchSize=10",客户端在处理完第7条消息时会发送第1~7条消息的ACK。也就是说某个consumer在处理完这10条后停机,后面的3条消息会得不到确认,再开启一个consumer会重新收到这3条且redeliveryCounter=0。
2. optimizeAcknowledgeTimeOut:系统时间 - 前条消息处理时间 > optimizeAcknowledgeTimeOut即发送ACK,如果条件不成立则按optimizeAcknowledge处理。
3. optimizedAckScheduledAckInterval:每隔optimizedAckScheduledAckInterval就发送ACK,如果条件不成立则按optimizeAcknowledge处理。
相关推荐
activemq activeMq笔记.docx
ActiveMq笔记
activeMQ学习笔记,JMS有两种传递消息的方式。标记为NON_PERSISTENT的消息最多投递一次,而标记为PERSISTENT的消息将使用暂存后再转送的机理投递。如果一个JMS服务离线,那么持久性消息不会丢失但是得等到这个服务...
ActiveMQ 教学视频/教程 /附带笔记等资源,jms 案例文档等...
这是我学习activeMQ时总结的文档,其中有实例,还有一些我遇到的问题。
将ActiveMQ放到Linux中,使用命令“tar -zxvf apache-activemq-5.15.9-bin.tar.gz”解压缩。 在bin目录下 使用命令“./activemq start”启动ActiveMQ 使用命令“./activemq stop”关闭ActiveMQ 使用命令“./activemq...
JAVA私塾全套笔记,这是全部的笔记,包括全部呢
整理最新的ActiveMQ笔记,消息中间件是解决的问题是能够解耦、能够削峰、能够异步处理,包含整合SpringBoot等、消息存储和持久化、多节点集群的使用、面试遇到和注意的问题等。
activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记
ActiveMQ In Action翻译笔记-更新版2011
Apache+ActiveMQ教程.pdf JMS规范教程.pdf JMS简明教程.pdf 三份教程
ActiveMQ消息中间键,包含源码分析,及各种功能使用的场景,原理,满满的干货。
activemq消息队列整合SpringBoot
NULL 博文链接:https://sswh.iteye.com/blog/1974169
消息中间件的学习笔记
ActiveMQ+In+Action翻译笔记-+更新版2011.pdf
NULL 博文链接:https://sswh.iteye.com/blog/1974131
脑图内容涵盖视频的99%的笔记,含有自己编写的代码文件,外加了自己对一些问题的测试与回答。 消息中间件之ActiveMQ 消息中间件已经成为互联网企业应用系统内部通信的核心手段,是目前企业内主流标配技术, 它...
NULL 博文链接:https://sswh.iteye.com/blog/1974156