8.4. 配置接受器和连接器
连接器和接收器有许多配置选项。它们在配置中显示为子 <param> 元素。每个 <param> 元素包含一个 名称和 值 属性对,由默认的基于 Netty 的工厂类理解和使用,该类负责实例化连接器或接收器。
在管理 CLI 中,每个远程连接器或接收器元素都包含参数名称和值对的内部映射。例如,要将新的 param 添加到 名为 连接器中,请使用以下命令:
myRemote 的远程
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:map-put(name=params,key=foo,value=bar)
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:map-put(name=params,key=foo,value=bar)
使用类似语法检索参数值。
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:map-get(name=params,key=foo)
{
"outcome" => "success",
"result" => "bar"
}
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:map-get(name=params,key=foo)
{
"outcome" => "success",
"result" => "bar"
}
您还可以在创建接收器或连接器时包含参数,如下例所示。
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:add(socket-binding=mysocket,params={foo=bar,foo2=bar2})
/subsystem=messaging-activemq/server=default/remote-connector=myRemote:add(socket-binding=mysocket,params={foo=bar,foo2=bar2})
| 属性 | 描述 |
|---|---|
| batch-delay |
在将数据包写入传输之前,可以将消息传递服务器配置为批处理写入,最多以毫秒为 |
| direct-deliver |
当消息到达服务器并传送到等待的消费者时,默认情况下会在邮件到达的同一线程上执行传输。这为具有相对较小的消息和少量消费者的环境提供了良好的延迟,但降低了吞吐量和延迟。对于最高吞吐量,您可以将此属性设为 |
| http-upgrade-enabled |
http-connector 使用 |
| http-upgrade-endpoint |
指定 |
| local-address | 对于 http 或远程连接器,这用于指定在连接到远程地址时客户端将使用的本地地址。如果未指定本地地址,则连接器将使用任何可用的本地地址。 |
| local-port |
对于 http 或远程连接器,这用于指定客户端在连接到远程地址时使用的本地端口。如果使用 local-port 默认值(0),则连接器将允许系统采用临时端口。有效端口值为 |
| nio-remoting-threads |
如果配置为使用 NIO,则消息将默认使用等于 |
| tcp-no-delay |
如果 |
| tcp-send-buffer-size |
此参数以字节为单位确定 TCP 发送缓冲区的大小。默认值为 |
| tcp-receive-buffer-size |
此参数以字节为单位确定 TCP 接收缓冲区的大小。默认值为 |
| use-nio-global-worker-pool |
此参数将确保所有 JMS 连接共享一个 Java 线程池,而不是每个连接具有自己的池。这有助于避免耗尽操作系统中进程的最大数量。默认值为 |