242.2. 选项
Netty4 组件支持 6 个选项,如下所列。
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
maximumPoolSize (advanced) | 如果正在使用 EventExecutorGroup 的线程池大小。默认值为 16。 | 16 | int |
配置 (高级) | 在创建端点时,使用 NettyConfiguration 作为配置。 | NettyConfiguration | |
executorService (advanced) | 使用给定的 EventExecutorGroup。 | EventExecutorGroup | |
useGlobalSslContext 参数 (security) | 启用使用全局 SSL 上下文参数。 | false | 布尔值 |
sslContextParameters (security) | 使用 SSLContextParameters 配置安全性 | SSLContextParameters | |
resolveProperty Placeholders (advanced) | 组件是否应在启动时解析属性占位符。只有 String 类型的属性可以使用属性占位符。 | true | 布尔值 |
Netty4 端点使用 URI 语法进行配置:
netty4:protocol:host:port
使用以下路径和查询参数:
242.2.1. 路径参数(3 参数):
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
protocol | 必需 使用的协议,可以是 tcp 或 udp。 | 字符串 | |
主机 | 必需 的主机名。对于消费者,主机名是 localhost 或 0.0.0.0。对于生成者,主机名是要连接的远程主机 | 字符串 | |
port | 需要 主机端口号 | int |
242.2.2. 查询参数(72 参数):
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
disconnect (common) | 使用后是否从 Netty Channel 断开连接(关闭)。可用于使用者和制作者。 | false | 布尔值 |
keepalive ( common) | 设置以确保因为不活跃而不会关闭套接字 | true | 布尔值 |
reuseAddress (common) | 设置以方便套接字多路 | true | 布尔值 |
reuseChannel (common) | 此选项允许生成者和消费者(在客户端模式中)在处理交换生命周期中重复使用相同的 Netty Channel。如果您需要在 Camel 路由中多次调用服务器并希望使用相同的网络连接,这非常有用。使用此选项时,频道不会返回到连接池,直到 Exchange 完成后;如果 disconnect 选项设为 true,则断开连接。重复使用的频道以一个交换属性的形式存储在 Exchange 中,它带有一个键 NettyConstants SerialNETTY_CHANNEL,它允许您在路由过程中获取频道并使用它。 | false | 布尔值 |
sync (common) | 将端点设置为单向或请求响应 | true | 布尔值 |
tcpNoDelay (common) | 设置以提高 TCP 协议性能 | true | 布尔值 |
bridgeErrorHandler (consumer) | 允许将消费者桥接到 Camel 路由错误处理程序,这意味着当消费者试图选择传入消息或类似信息时发生异常,现在将作为消息处理并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况,该处理程序将被记录在 WARN 或 ERROR 级别,并忽略。 | false | 布尔值 |
broadcast (consumer) | 将 设置为选择通过 UDP 的多播 | false | 布尔值 |
clientMode (consumer) | 如果 clientMode 为 true,netty 使用者会将地址连接到 TCP 客户端。 | false | 布尔值 |
reconnect (consumer) | 仅在消费者中的 clientMode 中使用,如果用户启用,消费者将尝试在断开连接时重新连接 | true | 布尔值 |
reconnectInterval (consumer) | 如果启用了 reconnect 和 clientMode,则使用。尝试重新连接的时间间隔(以 milli 秒为单位) | 10000 | int |
backlog (consumer) | 允许为 netty consumer (server)配置积压。请注意,积压只是取决于操作系统的最佳努力。将此选项设置为值(如 200、500 或 1000)告知 TCP 堆栈如果未配置此选项,则接受队列的时长,则积压取决于操作系统设置。 | int | |
bossCount (consumer) | 当 netty 适用于 nio 模式时,它使用 Netty 中的默认 bossCount 参数,即 1。用户可以使用此操作从 Netty 覆盖默认的 bossCount | 1 | int |
bossGroup (consumer) | 设置 BossGroup,可用于处理 NettyEndpoint 中服务器端的新连接 | EventLoopGroup | |
disconnectOnNoReply (consumer) | 如果启用了同步,则此选项将指定 NettyConsumer (如果它应该断开连接),没有回复回来。 | true | 布尔值 |
ExceptionHandler ( consumer) | 要让使用者使用自定义例外处理程序:请注意,如果启用了 bridgeErrorHandler 选项,则此选项不使用。默认情况下,消费者将处理异常,其记录在 WARN 或 ERROR 级别中,并忽略。 | ExceptionHandler | |
exchangePattern (consumer) | 在消费者创建交换时设置交换模式。 | ExchangePattern | |
nettyServerBootstrapFactory (consumer) | 使用自定义 NettyServerBootstrapFactory | NettyServerBootstrap Factory | |
networkInterface (consumer) | 在使用 UDP 时,可以使用此选项按名称指定网络接口,如 eth0 以加入多播组。 | 字符串 | |
noReplyLogLevel (consumer) | 如果启用了同步,这个选项会指示 NettyConsumer,在记录一个没有回复时要使用的日志记录级别。 | WARN | LoggingLevel |
serverClosedChannel ExceptionCaughtLogLevel (consumer) | 如果服务器(NettyConsumer)捕获 java.nio.channels.ClosedChannelException,然后使用此日志级别进行记录。这用于避免记录关闭的频道异常,因为客户端可以立即断开,然后在 Netty 服务器中造成大量关闭的异常。 | DEBUG | LoggingLevel |
serverExceptionCaughtLog Level (consumer) | 如果服务器(NettyConsumer)捕获异常,则使用此日志级别进行日志记录。 | WARN | LoggingLevel |
serverInitializerFactory (consumer) | 使用自定义 ServerInitializerFactory | ServerInitializer Factory | |
useExecutorService (consumer) | 是否使用排序的线程池,确保同一通道上按顺序处理事件。 | true | 布尔值 |
connectTimeout (producer) | 等待套接字连接可用的时间。值以毫秒为单位。 | 10000 | int |
requestTimeout (producer) | 在调用远程服务器时,允许 Netty producer 使用超时。默认情况下,没有使用超时。该值在 milli 秒内,如 30000 为 30 秒。requestTimeout 使用 Netty 的 ReadTimeoutHandler 来触发超时。 | long | |
clientInitializerFactory (producer) | 使用自定义 ClientInitializerFactory | ClientInitializer Factory | |
correlationManager (producer) | 使用自定义关联管理器来管理在将请求/回复与 netty producer 搭配使用时如何映射请求和回复消息。只有在您有一个将请求与回复一起映射请求时(如请求和回复中有关联 ID)时,才应使用此设置。如果要在 netty 中的同一频道(也称为连接)上有多个并发消息,则可以使用它。当执行此操作时,您必须有一个与请求和回复相关的方法,以便在继续路由前将正确的回复存储在 inflight Camel Exchange 上。当您构建自定义关联管理器时,我们建议扩展 TimeoutCorrelationManagerSupport。这提供了对超时和其他复杂性的支持。如需了解更多详细信息,请参阅 producerPoolEnabled 选项。 | NettyCamelState CorrelationManager | |
lazyChannelCreation (producer) | 如果远程服务器在 Camel producer 启动时未启动并运行,则可以创建频道以避免异常。 | true | 布尔值 |
producerPoolEnabled (producer) | producer 池是否已启用。重要:如果您关闭此设置,则为生成者使用单个共享连接,如果您执行请求/回复。这意味着,如果回复超出顺序,则存在交错响应潜在的问题。因此,您需要在请求和回复消息中有一个关联 ID,以便您可以将回复与负责继续处理 Camel 中消息的 Camel 回调关联。为此,您需要将 NettyCamelStateCorrelationManager 实施为关联管理器,并通过 correlationManager 选项进行配置。如需了解更多详细信息,请参阅 correlationManager 选项。 | true | 布尔值 |
producerPoolMaxActive (producer) | 设置池可分配给客户端或闲置等待签出的对象数量上限。对没有限制,使用负值。 | -1 | int |
producerPoolMaxIdle (producer) | 设置池中空闲实例数量上限。 | 100 | int |
producerPoolMinEvictable Idle (producer) | 设置对象在空闲对象驱除有资格驱除前,对象可能会在池中闲置的最小时间(值为 millis))。 | 300000 | long |
producerPoolMinIdle (producer) | 设置制作者池中允许的最小实例数量,然后再驱除线程(如果活跃)生成新对象。 | int | |
udpConnectionlessSending (producer) | 这个选项支持连接较少的 udp 发送,这是实际触发和忘记的。如果没有端口侦听接收端口,则已连接的 udp 发送 PortUnreachableException。 | false | 布尔值 |
useByteBuf (producer) | 如果 useByteBuf 为 true,netty producer 会在发送前将消息正文转换为 ByteBuf。 | false | 布尔值 |
allowSerializedHeaders (advanced) | 仅在 transferExchange 为 true 时用于 TCP。当设置为 true 时,标头和属性中的串行对象将添加到交换中。否则,Camel 将排除任何非序列化对象,并将其记录在 WARN 级别。 | false | 布尔值 |
bootstrapConfiguration (advanced) | 使用自定义配置的 NettyServerBootstrapConfiguration 来配置此端点。 | NettyServerBootstrap Configuration | |
channelGroup (advanced) | 使用显式 ChannelGroup。 | ChannelGroup | |
nativeTransport (advanced) | 是否使用原生传输而不是 NIO。原生传输利用主机操作系统,且仅在某些平台上受支持。您需要为正在使用的主机操作系统添加 netty JAR。详情请查看 :http://netty.io/wiki/native-transports.html | false | 布尔值 |
选项 (advanced) | 允许使用选项配置其他 netty 选项作为前缀。例如: option.child.keepAlive=false 设置 netty 选项 child.keepAlive=false。有关可以使用的选项,请参阅 Netty 文档。 | Map | |
receiveBufferSize (advanced) | 在入站通信中使用的 TCP/UDP 缓冲区大小。大小为字节。 | 65536 | int |
receiveBufferSizePredictor (advanced) | 配置缓冲区大小预测。请参阅 Jetty 文档和此邮件线程的详细信息。 | int | |
sendBufferSize (advanced) | 在出站通信中使用的 TCP/UDP 缓冲大小。大小为字节。 | 65536 | int |
同步 (高级) | 设置是否应严格使用同步处理,还是允许 Camel 使用异步处理(如果支持)。 | false | 布尔值 |
transferExchange (advanced) | 仅用于 TCP。您可以通过线线传输交换,而不是只传输正文。以下字段被传输: 在 body, Out body, fault body, In headers, Out headers, fault headers, Exchange properties, Exchange exception。这要求对象是序列化的。Camel 将排除任何非序列化对象,并将其记录在 WARN 级别。 | false | 布尔值 |
udpByteArrayCodec (advanced) | 仅限 UDP。如果启用了,则使用 byte 数组 codec 而不是 Java 序列化协议。 | false | 布尔值 |
workerCount (advanced) | 当 netty 适用于 nio 模式时,它会使用来自 Netty 的默认 workerCount 参数,即 cpu_core_threads x 2。用户可以使用此操作从 Netty 覆盖默认的 workerCount。 | int | |
workerGroup (advanced) | 使用显式 EventLoopGroup 作为 boss 线程池。例如,要与多个消费者或生成者共享线程池。默认情况下,每个消费者或生成者都有自己的 worker 池,有 2 个 x cpu count 内核线程。 | EventLoopGroup | |
allowDefaultCodec (codec) | 如果两者都是 null,netty 组件会安装默认的 codec,则 encoder/decoder 为 null,文本为 false。将 allowDefaultCodec 设置为 false 可防止 netty 组件将默认 codec 安装为过滤器链中的第一个元素。 | true | 布尔值 |
autoAppendDelimiter (codec) | 使用文本 codec 发送时是否自动附加缺少的结束分隔符。 | true | 布尔值 |
decoder (codec) | 弃用了 一个自定义 ChannelHandler 类,可用于执行入站有效负载的特殊汇总。 | ChannelHandler | |
decoderMaxLineLength (codec) | 用于文本行 codec 的最大行长度。 | 1024 | int |
decoders (codec) | 要使用的解码器列表。您可以使用以逗号分开的值的 String,并在 Registry 中查找值。只需记住使用 # 前缀,以便 Camel 知道它应该查找。 | 字符串 | |
delimiter (codec) | 用于文本行代码的分隔符。可能的值有 LINE 和 NULL。 | 行 | TextLineDelimiter |
encoder (codec) | 弃用了 一个自定义 ChannelHandler 类,可用于执行出站有效负载的特殊汇总。 | ChannelHandler | |
编码器 (codec) | 要使用的编码器列表。您可以使用以逗号分开的值的 String,并在 Registry 中查找值。只需记住使用 # 前缀,以便 Camel 知道它应该查找。 | 字符串 | |
编码 (codec) | 用于文本编码的编码(charset 名称)。如果没有提供,Camel 将使用 JVM 默认 Charset。 | 字符串 | |
文本行 (codec) | 仅用于 TCP。如果没有指定 codec,您可以使用此标志来指示基于文本的 codec;如果没有指定,或者值为 false,则通过 TCP 假设 Object Serialization。 | false | 布尔值 |
enabledProtocols (security) | 使用 SSL 时要启用的协议 | TLSv1,TLSv1.1,TLSv1.2 | 字符串 |
keyStoreFile (security) | 用于加密的客户端侧证书密钥存储 | File | |
keyStoreFormat (security) | 用于有效负载加密的密钥存储格式。如果没有设置,则默认为 JKS | 字符串 | |
keyStoreResource (security) | 用于加密的客户端侧证书密钥存储。默认情况下从 classpath 加载,但您可以使用 classpath:、file: 或 http: 前缀来加载来自不同系统的资源。 | 字符串 | |
needClientAuth (security) | 配置服务器在使用 SSL 时是否需要客户端身份验证。 | false | 布尔值 |
密码短语 (security) | 要使用 SSH 加密/解密有效负载的密码设置 | 字符串 | |
securityProvider (security) | 用于有效负载加密的安全供应商。如果没有设置,则默认为 SunX509。 | 字符串 | |
SSL (security) | 设置以指定是否将 SSL 加密应用到此端点 | false | 布尔值 |
sslClientCertHeaders (security) | 启用和 SSL 模式时,Netty 使用者将增强 Camel 消息,其中包含客户端证书的信息,如主题名称、签发者名称、序列号和有效日期范围。 | false | 布尔值 |
sslContextParameters (security) | 使用 SSLContextParameters 配置安全性 | SSLContextParameters | |
sslHandler (security) | 引用可用于返回 SSL 处理程序的类 | SslHandler | |
trustStoreFile (security) | 用于加密的服务器端证书密钥存储 | File | |
trustStoreResource (security) | 用于加密的服务器端证书密钥存储。默认情况下从 classpath 加载,但您可以使用 classpath:、file: 或 http: 前缀来加载来自不同系统的资源。 | 字符串 |