下载安装 ActiveMQ 网上有 N 多例子, 就不说什么了..
只有这点不同. 我在使用 5.9 版本时, 启动时需要 ./activemq start , 网上说 ./activemq 直接就可以.
JMS 确认机制
Session javax.jms.Connection.createSession(boolean transacted, int acknowledgeMode) throws JMSException
transacted 是决定是否启动事务,
true 启动事务
事务被提交的时候,确认自动发生.
false 非事务
非事务何时确认取决于: acknowledgeMode
这段摘自 ActiveMQ
引用
在非事务性会话中,消息何时被确认取决于创建会话时的应答模式(acknowledgement mode)。
该参数有以下三个可选值:
Session.AUTO_ACKNOWLEDGE。当客户成功的从receive 方法返回的时候,
或者从MessageListener.onMessage 方法成功返回的时候,会话自动确认
客户收到的消息。
Session.CLIENT_ACKNOWLEDGE。客户通过消息的acknowledge 方法确认消
息。需要注意的是,在这种模式中,确认是在会话层上进行:确认一个被
消费的消息将自动确认所有已被会话消费的消息。例如,如果一个消息消
费者消费了10 个消息,然后确认第5 个消息,那么所有10 个消息都被确
认。
Session.DUPS_ACKNOWLEDGE。该选择只是会话迟钝的确认消息的提交。如
果JMS provider 失败,那么可能会导致一些重复的消息。如果是重复的
消息,那么JMS provider 必须把消息头的JMSRedelivered 字段设置为
true。
发送和接收,以及 Persistence
JMS有两种模式
Queue
session.createQueue("Test")
当 1个发送者P, 2个消费者 C1, C2
需要注意的是, P发送了3条消息, 结果是 C1 接收2条, C2 接收1条.(大多数情况)
即每条消息,只会有一个消费者收到. Queue 模式特点.
当 producer.setDeliveryMode(DeliveryMode.PERSISTENT); 时, 如果没有消费者接收, 那么会将这条记录持久化, 等待消费者下次启动接收.
Topic
多称呼这种模式为 Pub-Sub. 发布-订阅
session.createTopic("Test")
当 1个发送者P, 2个消费者 C1, C2
P发送了3条消息, 结果是 C1 接收3条, C2 接收3条.
当 producer.setDeliveryMode(DeliveryMode.PERSISTENT); 时,
要看有没有持久订阅这个 Topic 的消费者. 如果有,会将这条消息持久化保存,供持久订阅者下次启动时接收.
持久订阅的方式是
...
connection.setClientID($ClientId);
...
Topic topic = new ActiveMQTopic("Test");
MessageConsumer consumer = session.createDurableSubscriber(topic, $Name);
...
持久订阅必须指定 $ClientId 和 $Name,由这两个属性联合成一个唯一订阅者标识.
ActiveMQ 会记录每个持久订阅者的 最后订阅的消息号(LAST_ACKED_ID).
下面是一些activeMQ 存储方式性能对比,
仅供参考
KahaDB 10W
PERSISTENT 26291 ms
NON_PERSISTENT 2095 ms
MySQLDB 10W
PERSISTENT 152362 ms
NON_PERSISTENT 2008 ms
LevelDB 10W
PERSISTENT 43593 ms
NON_PERSISTENT 1576 ms
ReplicationLevelDB 10W
PERSISTENT 48826 ms
NON_PERSISTENT 1576 ms
分享到:
相关推荐
1.6 Zabbix监控ActiveMQ1
0927分布式消息通信-ActiveMQ1
第十一章 企业项目开发--消息队列activemq注意:本章代码基于 第十章 企业项目开发--分布式缓存Redis(2)消息队列是分布式系统中实现RP C 的一
背景:你好,游客登录注册搜索首页Linux新闻Linux教程数据库技术Linux编程服务器应用Linux安全Linux下载Linux认证Linux主题Linux
消息的消费包含三个阶段: 客户端接收消息、客户端处理消息、消息被确认事务性会话 如上图,设置为true的时候,消息会在session.commit以后自动签收非
ACK_TYPE表示确认指令的类型,broker可以根据不同的ACK_TYPE去针对当前消息做不同的应对策略REDELIVERED_ACK_TYPE (brok
1、 ActiveMQ 安装1
Apache ActiveMQ 1天培训材料
activemq activeMq笔记.docx
spring.activemq.broker-url=failover:(tcp://10.0.1.227:61616,tcp://10.0.1.228:61616,tcp://10.0.1.229:61616,mqtt://10.0.1.227:1883,mqtt://10.0.1.228:1883,mqtt://10.0.1.229:1883) #spring.activemq.broker-...
1.什么是 ActiveMQ 2. ActiveMQ 服务器宕机怎么办 3. 丢消息怎么办 4. 持久化消息非常慢 5. 消息的不均匀消费 6. 死信队列 7.
activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-
activeMQ的测试工具,用于发送和接收activeMQ消息,jar包形式的,安装完jdk之后用java -jar xxx.jar命令运行
activemq5.15.0-1 jar
ActiveMQ高并发处理方案ActiveMQ高并发处理方案 超级字数补丁超级字数补丁
百度spring整合activemq 发现几乎都只是在xml文件配置固定的消息队列而且太麻烦。并没有根据需求进行动态生成主题和队列。本文档参考了纯粹的activemq java代码和百度上的demo,很简洁的实现了动态消息队列的生成和...
springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot...
1. ActiveMQ 启动 ActiveMQ 5.10 bin\activemq start ActiveMQ 5.9 or older bin\activemq 2. ActiveMQ 停止 bin/activemq stop 3. 访问 默认的用户名密码为:admin/admin 具体可在activemq-5.10.0\conf\jetty-realm...
apache-activemq Linux版本