ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动 netstat -an|find “61616”。ActiveMQ默认启动时，启动了内置的jetty服务器，提供一个用于监控ActiveMQ的

// 1)获取工厂 ConnectionFactory,使用摸摸人的用户名和密码admin/admin, 指定URL. // 4)创建Session ,参数transacted:事务，acknowledgeMode响应模式。// 6)创建消费者，

消息队列是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。注册时的短信、邮件通知，减少响应时间；信息发送者和消息接受者无需耦合，比如调用第三方；支持来自Java，C，C ++，C＃，Ruby，Perl，Pytho

ActiveMQ 支持同步、异步两种发送的模式将消息发送到 broker，模式的选择对发送延时有巨大的影响。ActiveMQ 默认使用异步发送的模式：除非明确指定使用同步发送的方式或者在未使用事务的前提下发送持久化的消息，这两种情况都是同步发送的。确认机制

前面2篇博客地址如下：《从入门到精通的ActiveMQ（一）》、《从入门到精通的ActiveMQ（二）》。注意到只有Master对外提供了服务，Slave是待机状态。当Master出现故障，ZK内部的选举机制，会让一个Slave升级成Master对外提供服

消息持久化是保证消息不丢失的重要方式。在data/kahadb这个目录下，会生成四个文件，来完成消息持久化。默认是32M，达到阀值会自动递增。

　　　　　　结论：当服务器宕机，重启服务器之后，没有被消费的消息依然在数据库中，这样就做到了持久化操作。　　　　　　结论：被消费的消息，将不会做持久化操作，就会从队列中清除。

# 注意检查5672和4240端口是否被占用,使用kill命令杀掉占用的进程。安装activemq需要java环境支持。# 启动失败查看错误使用。192.168.0.22 为 linux 的IP 地址， 使用 IP+端口 访问了ActiveMQ ， 登陆之

首先，说一下ActiveMQ在Linux的安装：。　　　　cd apache-activemq-5.14.0/bin --->到解压过后的activemq的bin目录下启动。加入内容并保存：-A RH-Firewall-1-INPUT -m stat

　　JMS是java消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。客戶端成功接收一条消息的标志是一条消息被签收，成功应答。

直到消息被复制到从节点,并且从节点完成对消息的处理,主节点才会处理这条消息.接着就会发送一个响应告诉生产者消息已经被成功处理了.这种模式会比不共享模式总体来说要慢,但是它不需要额外的配置,对从节点的数量也没有限制.如果你对性能有很高的要求,可以用文件共享系

协调端的重发送，根据ack类型自动不断重发---消费端选择手动ack的时候就需要接到消息，硬编码ack. 2，消费端没有正常接受， 消费端 不同的 ack broker会有不同的反应---例如：broker重发，broker取消删除队列消息，只有消费端才有

最近项目里面要求实时的分析数据，唉，storm学习成本太高，所以就想到了activeMQ.Apache ActiveMQ是最流行的功能强大的开源即时通讯和集成模式的服务器。Apache ActiveMQ的速度快，支持多语言和跨客户协议，带有易于在充分支持J

当消息从代理中分发时,遵循着先进先出原则.但是如果在一个队列中有超过一个消费者,你就不能保证这个原则了.这是因为你没有用了控制发送消息线程的调度--即使所有消费者使用同一个连接.理想情况下,只有一个消息消费者,为了支持容错机制,你需要其他的消费者在主消费者

直到消息被复制到从节点,并且从节点完成对消息的处理,主节点才会处理这条消息.接着就会发送一个响应告诉生产者消息已经被成功处理了.这种模式会比不共享模式总体来说要慢,但是它不需要额外的配置,对从节点的数量也没有限制.如果你对性能有很高的要求,可以用文件共享系

这时生产者就被阻塞了，直到broker将内存中的消息被消费后才能继续发送。通常消息在未消费或者发送后未收到消费者的确认信息时都会持久保存消息到存储中。当有消费者来消费消息时，broker会分页一批一批的从存储中取出消息，放入消息处理队列。

ActiveMQ 是Apache出品，最流行的、功能强大的即时通讯和集成模式的开源服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。提供客户端支持跨语言和协议，带有易于在充分支持JMS 1.1和1.

下面通过学习与配置，实现消息服务的基本功能：发送与接收。Spring对JMS提供了很好的支持，可以通过JmsTemplate来方便地实现消息服务。这里，我们的消息服务不涉及事务管理。下面简单说明实现过程：

花了三天终于在Websphere commerce 7，实现了和activeMQ的JMS异步通行。这里JMS Provider采用的是activeMQ买不起啊。其实和Websphere MQ的集成方式类似。选择“JMS提供程序”，选择作用域,点击“新建”。

队列即一个消息只能被一个消费者消费。