第 3 章 在网络连接中配置消息协议
AMQ Broker 具有可插拔协议架构,以便您可以轻松为网络连接启用一个或多个协议。
代理支持以下协议:
除了上面的协议,代理还支持自己的原生协议,称为"Core"。此协议的过去版本被称为"HornetQ",并由红帽 JBoss 企业应用平台使用。
3.1. 配置网络连接以使用消息传递协议
您必须将协议与网络连接关联,然后才能使用它。(请参阅 第 2 章 在网络连接中配置接收器和连接器 以了解有关如何创建和配置网络连接的更多信息。)位于 < broker_instance_dir> /etc/broker.xml
文件中的默认配置,包括已经定义了多个连接。为方便起见,AMQ Broker 包括对每个支持的协议的接受器,以及一个支持所有协议的默认接受器。
默认接收器概述
下面是在 broker.xml
配置文件中默认包括的接收器。
<configuration> <core> ... <acceptors> <!-- All-protocols acceptor --> <acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor> <!-- AMQP Acceptor. Listens on default AMQP port for AMQP traffic --> <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor> <!-- STOMP Acceptor --> <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor> <!-- HornetQ Compatibility Acceptor. Enables HornetQ Core and STOMP for legacy HornetQ clients. --> <acceptor name="hornetq">tcp://0.0.0.0:5445?anycastPrefix=jms.queue.;multicastPrefix=jms.topic.;protocols=HORNETQ,STOMP;useEpoll=true</acceptor> <!-- MQTT Acceptor --> <acceptor name="mqtt">tcp://0.0.0.0:1883?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=MQTT;useEpoll=true</acceptor> </acceptors> ... </core> </configuration>
在给定网络连接器中启用协议的唯一要求是,将 protocol
参数添加到接受者的 URI 中。参数的值必须是用逗号分开的协议名称列表。如果在 URI 中省略了 protocol 参数,则启用所有协议。
例如,要创建使用 AMQP 协议在端口 3232 上接收消息的接受者,请按照以下步骤操作:
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 -
在 <
acceptors&
gt; 小节中添加以下行:
<acceptor name="ampq">tcp://0.0.0.0:3232?protocols=AMQP</acceptor>
默认接受者中的其他参数
在最小接受器配置中,您将指定协议作为连接 URI 的一部分。但是,broker.xml
配置文件中的 default acceptors 已配置了一些附加参数。下表详细介绍了为默认接收器配置的其他参数。
接受者 | 参数 | 描述 |
---|---|---|
all-protocols acceptor AMQP STOMP | tcpSendBufferSize |
TCP 发送缓冲区的大小(以字节为单位)。默认值为 |
tcpReceiveBufferSize |
TCP 接收缓冲区的大小(以字节为单位)。默认值为 TCP 缓冲区大小应该根据网络的带宽和延迟调整。 在概述 TCP 发送/接收方缓冲区大小中,应计算如下: buffer_size = bandwidth * RTT.
其中带宽为每秒字节数,网络往返时间(RTT)以秒为单位。RTT 可以使用 对于快速网络,您可能想要从默认设置中增加缓冲区大小。 | |
all-protocols acceptor AMQP STOMP HornetQ MQTT | useEpoll |
如果使用支持它的系统(Linux),请使用 Netty epoll。Netty 原生传输提供了优于 NIO 传输的性能。这个选项的默认值是 |
all-protocols acceptor AMQP | amqpCredits |
AMQP 生产者可以发送的最大消息数量,而不考虑消息总数。默认值为 要了解有关如何使用贡献范围来阻止 AMQP 信息的更多信息,请参阅 第 7.3.2 节 “阻塞 AMQP 生产者”。 |
all-protocols acceptor AMQP | amqpLowCredits |
降低代理重新制作者学分的阈值。默认值为 要了解有关如何使用贡献范围来阻止 AMQP 信息的更多信息,请参阅 第 7.3.2 节 “阻塞 AMQP 生产者”。 |
HornetQ 兼容性接受者 | anycastPrefix |
当连接到一个使用 有关配置前缀以启用客户端在连接到地址时指定路由类型的更多信息,请参阅 第 4.6 节 “在接受器配置中添加路由类型”。 |
multicastPrefix |
当连接到一个使用 有关配置前缀以启用客户端在连接到地址时指定路由类型的更多信息,请参阅 第 4.6 节 “在接受器配置中添加路由类型”。 |
其他资源
- 有关您可以为 Netty 网络连接配置的其他参数的详情,请参考 附录 A, acceptor 和 Connector 配置参数。