11、ActiveMQ 实战 - ActiveMQ的NIO协议使用

NIO协议配置

由ActiveMQ安装目录所在的/conf/activemq.xml的配置文件可知，ActiveMQ默认出厂配置并不是NIO网络模型，而是BIO网络模型，若想使用NIO网络模型，需要transportConnectors标签加入以下配置，端口可以自定义（如果不指定端口，默认使用BIO网络IO模型端口，比如OpenWire、STOMP、AMQP等）：

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

配置完后，使用命令./activemq restart重启ActiveMQ，打开控制台的Connections看到Connector NIO一栏则表示配置成功。

更多协议介绍参考：10.ActiveMQ的传输协议

NIO配置文件修改后，连接ActiveMQ的url由原来的tcp://your ip:61616改成nio://your ip:61618即可。

连接ActiveMQ的java代码参考：Java编码实现ActiveMQ通讯

NIO使用增强

在我们没有配置NIO时，端口使用的是以TCP为协议基础的BIO + TCP模式，当配置了NIO并且URI格式以“nio”开头后，此时端口使用的是以TCP协议为基础的NIO网络模型，即NIO + TCP。

怎么能做到让这个端口既支持NIO网络模型，又让他支持多个协议呢（即不仅仅是TCP协议）？

1、 配置auto；
auto关键字：在NIO上启用自动检测功能（来自官方翻译）

在ActiveMQ安装目录所在的/conf/activemq.xml的配置文件的transportConnectors中加入以下一行配置（端口可自行指定）。

<transportConnector name="auto+nio" uri="auto+nio://0.0.0.0:5678" />

配置完后，启动ActiveMQ，并在控制台访问，在Connections菜单出现Connector auto+nio一栏则表示配置成功。

2、 修改连接服务的URI；
连接ActiveMQ服务的URI格式：[协议名称]://[your ip]:5678

由上一步可知，使用auto关键字配置了5678端口，当我们在5678端口使用指定的协议名称时，ActiveMQ会自动使用该协议的NIO网络不行，不再是原来的BIO网络模型，由此达到NIO网络模型支持多协议的作用。

比如当我们在5678使用TCP协议时，则URI应该配置为：tcp://your ip://5678，则此时5678使用的是以TCP协议为基础的NIO网络模型。

注：不同的网络协议使用不同的客户端代码，即jar不同，api也不同。