在前两篇文章中说了入门和与spring以及springboot框架的整合，本文来聊聊activemq更深层次的东西，包括传输协议、消息存储、持久化、集群、异步投递、延迟投递、定时投递、重试机制、死信队列和防止重复消费问题等。

---

欢迎大家关注我的公众号 javawebkf ，目前正在慢慢地将简书文章搬到公众号，以后简书和公众号文章将同步更新，且简书上的付费文章在公众号上将免费。

---

一、传输协议

默认使用tcp协议，那么可以改吗？如果可以，怎么改？
1、能否改？
可以改，activemq支持很多协议，除了默认的TCP，还有SSL、UDP、NIO、Http(s)、VM等。在项目中，一般使用NIO，性能更好。使用tcp协议时的端口是61616，url后面还有可选参数，可以参考官网的说明。TCP协议的优点是可靠性高，稳定性强，字节流方式传递，效率高，应用广泛，支持任何平台。NIO适合有大量的client去连接broker的情况，提供更好的性能，连接的url形式：nio://hostname:port?key=value
2、如何改？
在activemq的安装目录的conf目录下，有个activemq.xml配置文件，在transportConnectors标签内就可以配置协议。

image.png
在这里加上nio的配置：

<transportConnector name="nio" uri="nio://0.0.0.0:61618?trace=true"/>

这样就配置好了，然后将生产者和消费者中连接的url都改成

nio://192.168.X.XX:61618

这样就可以成功使用nio协议了。
3、nio适配多协议：
其实说nio协议不太准确，应该是说使用以tcp协议为基础的nio网络模型。也就是说，activemq默认的那些协议，底层用的都是BIO，经过上面这样配置，就让tcp协议底层使用nio了。那么怎么让其他协议底层也用nio呢？配置文件中默认的其他四种协议，如amqp、stomp、mqtt和ws协议。只需要把之前配置的nio删掉，然后在配置文件中做如下配置：

<transportConnector name="auto+nio" uri="auto+nio://0.0.0.0:61608?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;org.apache.activemq.transport.nio.SelectManager.corePoolSize=20&amp;org.apache.activemq.transport.nio.SelectorManager.maximumPoolSize=50"/>

最后将代码中的端口改成61608即可。这时即使将连接url开头的nio换成tcp，也可以在61608端口正确运行。

二、保证消息可靠性 --- 持久化

在MQ的入门篇中讲到过保证MQ的可靠性就要从持久、事务和签收三方面去考虑，这三个都是MQ自带的可配的参数。这里要说的持久化，和redis中持久化概念差不多，持久化到硬盘或者数据库，即使MQ挂了消息也不会丢失。

1、activemq的持久化机制有哪些？
有JDBC(工作中常用的机制)、AMQ(版本5.3之前的存储机制，现在不用了)、KahaDB(版本5.4开始的默认机制)和Level DB。不论用哪种，存储消息的逻辑都是一致的。

2、存储消息的逻辑是怎样的？
生产者发送消息后，消息中心首先将消息进行持久化，然后再发送给接收者，发送成功则删除持久化的消息，失败就继续发送。

3、KahaDB机制介绍(4+1结构，4个文件一把锁)：
类似于redis的aof方式，基于日志文件，记录消息。5.4开始的版本默认持久化机制就是这个，在activemq的配置文件activemq.xml中有如下配置：

kahaDB
通过这段配置可以知道，在activemq的安装目录下有个data/kahadb目录，打开目录，有如下文件：
kahadb目录
它们的作用分别是：

• db-1.log：这是存储消息数据的日志文件，大小固定，如果存储满了，数字就会递增，比如db-1.log存储满了，就会生成一个db-2.log来存储消息数据。
• db-data：这个文件保存了BTree索引，就是保存了db-1.log文件的索引。
• db-free：其实还有个上图没显示的文件，就是db-free，这个是记录db-data哪里是空闲的，是没有索引的，以便要建新索引时就建在那里，可以充分利用db-data文件。
• db-redo：这又是对上面三个文件的备份，如果上面三个文件出现意外数据丢失了，可以通过db-redo恢复。
• lock：对记录日志和索引的时候加锁用的。

4、levelDB机制介绍：
它是activemq5.8开始引入的持久化机制，将来要替代kahadb的东西。和kahadb也挺相似，也是基于日志文件进行存储。要使用的话只需要将activemq.xml配置文件中的持久化配置改成这样即可：

<persistenceAdapter>
     <levelDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>

没错，就是将配置节点中的kahaDB换成levelDB即可。

5、JDBC持久化介绍：
有了kahadb和leveldb，为什么还要有jdbc持久化机制呢？因为kahadb和leveldb还是基于activemq的，还是依赖于activemq自身。而jdbc持久化，就是将消息存储到数据库中。使用jdbc持久化步骤如下：