一. 面试题

默认的61616端口如何修改?
你生产上的链接协议如何配置的? 使用TCP吗?

二. 官网

官方描述各种主要协议

1. 是什么

ActiveMQ支持的client-broker通讯协议有: TCP 、 NIO、UDP、SSL、Http（s）、VM。其中配置Transport Connector的文件在activeMQ安装目录的conf、activemq.xml中的< transportConnectors> 标签之内

<transportConnectors>
            <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
</transportConnectors>

在上文给出的配置信息中,
URI描述信息的头部都是采用协议名称:例如

描述amqp协议的监听端口时, 采用的URI描述格式为"amqp://…"
描述Stomp协议的监听端口时, 采用的URI描述格式为"stomp://…"

唯独在进行openwire协议描述时,URI头却采用的"tcp://..."

这是因为ActiveMQ中默认消息协议就是openwire

2. 有哪些协议?

2.1 Transmission Control Protocol(TCP)我是默认

1. 这是默认的Broker配置, TCP的Client监听端口61616
2. 在网络传输数据前,必须要序列化数据,消息是通过一个叫wire protocol的来序列化成字节流.
3. TCP连接的URI形式如: tcp://hostname:port?key=value&key=value,后面的参数是可选
4. TCP传输的优点:
   4.1 TCP协议传输可靠性高,稳定性强
   4.2 高效性: 字节流方式传递,效率很高
   4.3 有效性,可用性: 应用广泛,支持任何平台
5. 关于Transport协议的可配置参数可以参考官网

2.2 New I/O API Protocol(NIO)

New I/O API Protocol(NIO)

1. NIO协议和TCP协议类似但NIO更侧重于底层的访问操作,它允许开发 人员对同一资源可有更过的client调用和服务端有更多的负载.
2. 适合使用NIOO协议的场景:
   2.1 可能有大量的Client去连接到Broker上,一般情况下,大量的Client去连接Broker是被操作系统的线程所限制的,因此NIO的实现比TCP需要更少的线程去运行, 所以建议使用NIO协议
   2.2 可能对于Broker有一个很迟钝的网络传输, NIO比TCP提供更好的性能

2.3 NIO连接的URI形式: nio//hostname:port?key=value

2.4 Transport Connector 配置示例,参考官网

2.3 AMQP协议

2.4 stomp协议

2.5 Secure Sockets Layer Protocol(SSL)

2.6 mqtt

2.7 ws协议

3. NIO案例演示

3.1 修改配置文件activemq.xml

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

如果不特别指定ActiveMQ的网络监听端口,那么这些端口都将使用BIO网络IO模型.(OpenWire, STOMP, AMQP…)
所以为了首先提高单节点的网络吞吐性能,我们需要明确指定Active的网络IO模型.
如下所示:URI格式头以"nio"开头,表示这个端口使用以TCP协议为基础的NIO网络IO模型

3.2 生产和消费两端协议代码修改

public static final String ACTIVEMQ_URL = "nio://192.168.249.88:61618";

查看网络协议

3. NIO案例演示增强

使用auto关键字,使用"+"符号来为端口设置多种特性

<transportConnector name="auto+nio" uri="auto+nio://localhost:5671"/>

如果我们既需要某一个端口支持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.SelectorManager.corePoolSize=20&amp;
	org.apache.activemq.transport.nio.SelectorManager.maximumPoolSize=50"/>