单机ActiveMQ的优化

• 协议端口优化
• NIO模式
• Prefetch机制

协议端口优化

在5.13+之前的版本activemq.xml配置文件中可以配置协议的端口等属性。

<transportConnectors>
<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>

1） 可以使用不同协议不同窗口。
2） 可以设置一些优化属性：maximumConnections”属性，代表这个端口支持的最大连接数量；”wireFormat.maxFrameSize”属相代表支持协议的“一个完整消息”的最大数据量（单位为byte）；
在版本5.13+之后，统一一个配置。

<transportConnectors>
<transportConnector name="auto" uri="auto://0.0.0.0:61617?maximumConnections=1000" />
</transportConnectors>

NIO模式

NIO是同步非阻塞模式，采用这种模式可以增加性能。

<transportConnector name="auto+nio" uri="auto+nio://0.0.0.0:61608?maximumConnections=1000" />

这里使用“+”号，可以合并使用协议和模式。

Prefetch机制

ActiveMQ有一个prefetch机制，用于提高发送效率，即服务器发送给客户端，可能一次性批量发送，减少客户端的请求次数。但是这个可能造成一个问题是很可能一直发送给同一台客户端，导致没有负责均衡。
可以通过配置queue或发布/订阅模式下面的prefetch数量。属性是：jms.prefetchPolicy.all=50