IP 配置属性

下表描述了您可以设置以配置 IP 连接的属性

表 1. 连接工厂属性
属性名称 客户端？ 服务器？ 允许的值 属性描述

type

Y

Y

client, server

确定连接工厂是客户端还是服务器。

host

Y

N

目标的主机名或 IP 地址。

port

Y

Y

端口。

serializer

Y

Y

用于序列化有效负载的 Serializer 实现。默认为 ByteArrayCrLfSerializer

deserializer

Y

Y

用于反序列化有效负载的 Deserializer 实现。默认为 ByteArrayCrLfSerializer

using-nio

Y

Y

true, false

连接是否使用 NIO。有关更多信息，请参阅 java.nio 包。参见 关于非阻塞 I/O (NIO)。默认值：false。

using-direct-buffers

Y

N

true, false

使用 NIO 时，连接是否使用直接缓冲区。有关更多信息，请参阅 java.nio.ByteBuffer 文档。如果 using-nio 为 false，则必须为 false。

apply-sequence

Y

Y

true, false

当您使用 NIO 时，可能需要重新排序消息。当此属性设置为 true 时，correlationId 和 sequenceNumber 标头将添加到接收到的消息中。参见 关于非阻塞 I/O (NIO)。默认值：false。

so-timeout

Y

Y

默认值为0（无穷大），但对于single-use="true"的服务器连接工厂除外。在这种情况下，它默认为默认的回复超时时间（10 秒）。

so-send-buffer-size

Y

Y

参见java.net.Socket. setSendBufferSize()。

so-receive-buffer-size

Y

Y

参见java.net.Socket. setReceiveBufferSize()。

so-keep-alive

Y

Y

true, false

参见java.net.Socket.setKeepAlive()。

so-linger

Y

Y

将linger设置为true，并使用提供的 value。参见java.net.Socket.setSoLinger()。

so-tcp-no-delay

Y

Y

true, false

参见java.net.Socket.setTcpNoDelay()。

so-traffic-class

Y

Y

参见java.net.Socket. setTrafficClass()。

local-address

N

Y

在多宿主系统上，指定套接字绑定到的接口的 IP 地址。

task-executor

Y

Y

指定用于套接字处理的特定执行器。如果未提供，则使用内部缓存线程执行器。在某些需要使用特定任务执行器的平台上需要，例如WorkManagerTaskExecutor。

single-use

Y

Y

true, false

指定连接是否可用于多个消息。如果为true，则每个消息使用新的连接。

pool-size

N

N

此属性不再使用。为了向后兼容，它设置了 backlog，但您应该使用backlog来指定服务器工厂中的连接 backlog。

backlog

N

Y

设置服务器工厂的连接 backlog。

lookup-host

Y

Y

true, false

指定是否对 IP 地址执行反向查找以转换为主机名，以便在消息头中使用。如果为 false，则使用 IP 地址。默认值：false。

interceptor-factory-chain

Y

Y

参见TCP 连接拦截器.

ssl-context-support

Y

Y

参见SSL/TLS 支持。

socket-factory-support

Y

Y

参见SSL/TLS 支持。

socket-support

Y

Y

参见SSL/TLS 支持.

nio-connection-support

Y

Y

参见高级技术.

read-delay

Y

Y

long > 0

上次尝试由于线程不足而失败后，重试读取之前的延迟（以毫秒为单位）。默认值：100。仅在using-nio为true时适用。

下表描述了您可以设置以配置 UDP 入站通道适配器的属性

表 2. UDP 入站通道适配器属性
属性名称 允许的值 属性描述

port

适配器监听的端口。

multicast

true, false

UDP 适配器是否使用多播。

multicast-address

当多播为 true 时，适配器加入的多播地址。

pool-size

指定可以同时处理的包数。仅在未配置 task-executor 时适用。默认值：5。

task-executor

指定用于套接字处理的特定执行器。如果未提供，则使用内部池化执行器。在某些需要使用特定任务执行器（例如 WorkManagerTaskExecutor）的平台上需要此项。有关线程要求，请参阅 pool-size。

receive-buffer-size

用于接收 DatagramPackets 的缓冲区大小。通常设置为最大传输单元 (MTU) 大小。如果使用的缓冲区小于发送的数据包的大小，则可能会发生截断。您可以使用 check-length 属性检测此情况。

check-length

true, false

UDP 适配器是否期望在接收到的数据包中包含数据长度字段。用于检测数据包截断。

so-timeout

有关更多信息，请参阅 java.net.DatagramSocket 中的 setSoTimeout() 方法。

so-send-buffer-size

用于 UDP 确认数据包。有关更多信息，请参阅 java.net.DatagramSocket 中的 setSendBufferSize() 方法。

so-receive-buffer-size

有关更多信息，请参阅 java.net.DatagramSocket.setReceiveBufferSize()。

local-address

在多宿主系统上，指定套接字绑定到的接口的 IP 地址。

error-channel

如果下游组件抛出异常，则包含异常和失败消息的 MessagingException 消息将发送到此通道。

lookup-host

true, false

指定是否对 IP 地址执行反向查找以转换为主机名，以便在消息头中使用。如果为 false，则使用 IP 地址。默认值：false。

下表描述了您可以设置以配置 UDP 出站通道适配器的属性

表 3. UDP 出站通道适配器属性
属性名称 允许的值 属性描述

host

目标的主机名或 IP 地址。对于多播 UDP 适配器，则是多播地址。

port

目标上的端口。

multicast

true, false

UDP 适配器是否使用多播。

acknowledge

true, false

UDP 适配器是否需要来自目标的确认。启用后，需要设置以下四个属性：ack-host、ack-port、ack-timeout 和 min-acks-for- success。

ack-host

当 acknowledge 为 true 时，指示应将确认发送到的主机或 IP 地址。通常是当前主机，但可能不同，例如，当使用网络地址转换 (NAT) 时。

ack-port

当 acknowledge 为 true 时，指示应将确认发送到的端口。适配器在此端口上侦听确认。

ack-timeout

当 acknowledge 为 true 时，指示适配器等待确认的时间（以毫秒为单位）。如果在指定时间内未收到确认，适配器将抛出异常。

成功所需的最小确认数

默认值为 1。对于多播适配器，您可以将其设置为更大的值，这需要来自多个目的地的确认。

check-length

true, false

UDP 适配器是否在发送到目的地的数据包中包含数据长度字段。

生存时间

对于多播适配器，指定 MulticastSocket 的生存时间属性。控制多播的范围。有关更多信息，请参阅 Java API 文档。

so-timeout

有关更多信息，请参阅 java.net.DatagramSocket setSoTimeout() 方法。

so-send-buffer-size

有关更多信息，请参阅 java.net.DatagramSocket 中的 setSendBufferSize() 方法。

so-receive-buffer-size

用于 UDP 确认数据包。有关更多信息，请参阅 java.net.DatagramSocket 中的 setReceiveBufferSize() 方法。

local-address

在多宿主系统上，对于 UDP 适配器，指定用于将套接字绑定到回复消息的接口的 IP 地址。对于多播适配器，它还确定发送多播数据包的接口。

task-executor

指定要用于确认处理的特定执行器。如果未提供，则使用内部单线程执行器。在某些需要使用特定任务执行器的平台上需要，例如 WorkManagerTaskExecutor。一个线程专门用于处理确认（如果 acknowledge 选项为 true）。

目标表达式

SpEL 表达式

要评估的 SpEL 表达式，以确定将哪个 SocketAddress 用作传出 UDP 数据包的目标地址。

套接字表达式

SpEL 表达式

要评估的 SpEL 表达式，以确定将哪个数据报套接字用于发送传出 UDP 数据包。

下表描述了您可以设置以配置 TCP 入站通道适配器的属性

表 4. TCP 入站通道适配器属性
属性名称 允许的值 属性描述

通道

发送入站消息的通道。

连接工厂

如果连接工厂的类型为 server，则该工厂由该适配器“拥有”。如果它的类型为 client，则它由出站通道适配器“拥有”，并且该适配器接收出站适配器创建的连接上的任何传入消息。

error-channel

如果下游组件抛出异常，则包含异常和失败消息的MessagingException消息将发送到此通道。

client-mode

true, false

当设置为true时，入站适配器在建立连接方面充当客户端，然后接收该连接上的传入消息。默认值：false。另请参见retry-interval和scheduler。连接工厂必须是client类型，并且single-use设置为false。

retry-interval

在client-mode模式下，指定连接尝试之间或连接失败后等待的毫秒数。默认值：60000（60 秒）。

scheduler

true, false

指定一个TaskScheduler来用于管理client-mode连接。如果未指定，则默认为全局 Spring Integration taskScheduler bean，该 bean 的默认池大小为 10。请参见配置任务调度程序。

下表描述了可以设置以配置 TCP 出站通道适配器的属性

表 5. TCP 出站通道适配器属性
属性名称 允许的值 属性描述

通道

出站消息到达的通道。

连接工厂

如果连接工厂的类型为client，则该工厂由此适配器“拥有”。如果其类型为server，则它由入站通道适配器“拥有”，并且此适配器尝试将消息与接收原始入站消息的连接相关联。

client-mode

true, false

当设置为true时，出站适配器尝试在启动后立即建立连接。当设置为false时，在发送第一条消息时建立连接。默认值：false。另请参见retry-interval和scheduler。连接工厂必须是client类型，并且single-use设置为false。

retry-interval

在client-mode模式下，指定连接尝试之间或连接失败后等待的毫秒数。默认值：60000（60 秒）。

scheduler

true, false

指定一个TaskScheduler来用于管理client-mode连接。如果未指定，则默认为全局 Spring Integration taskScheduler bean，该 bean 的默认池大小为 10。请参见配置任务调度程序。

下表描述了可以设置以配置 TCP 入站网关的属性

表 6. TCP 入站网关属性
属性名称 允许的值 属性描述

连接工厂

连接工厂必须是 server 类型。

request-channel

发送传入消息的通道。

reply-channel

回复消息可能到达的通道。通常，回复会到达添加到入站消息头部的临时回复通道。

reply-timeout

网关等待回复的时间（毫秒）。默认值：1000（1 秒）。

error-channel

如果下游组件抛出异常，则包含异常和失败消息的 MessagingException 消息将发送到此通道。来自该流的任何回复随后将作为网关的响应返回。

client-mode

true, false

当为 true 时，入站网关在建立连接方面充当客户端，然后接收（并回复）该连接上的传入消息。默认值：false。另请参见 retry-interval 和 scheduler。连接工厂必须是 client 类型，并且 single-use 设置为 false。

retry-interval

在client-mode模式下，指定连接尝试之间或连接失败后等待的毫秒数。默认值：60000（60 秒）。

scheduler

true, false

指定一个TaskScheduler来用于管理client-mode连接。如果未指定，则默认为全局 Spring Integration taskScheduler bean，该 bean 的默认池大小为 10。请参见配置任务调度程序。

下表描述了可以设置以配置 TCP 出站网关的属性

表 7. TCP 出站网关属性
属性名称 允许的值 属性描述

连接工厂

连接工厂必须是 client 类型。

request-channel

传出消息到达的通道。

reply-channel

可选。回复消息发送到的通道。

remote-timeout

网关等待远程系统回复的时间（毫秒）。与 remote-timeout-expression 相互排斥。默认值：10000（10 秒）。注意：在 4.2 之前的版本中，此值默认为 reply-timeout（如果已设置）。

remote-timeout-expression

针对消息评估的 SpEL 表达式，以确定网关等待远程系统回复的时间（毫秒）。与 remote-timeout 相互排斥。

request-timeout

如果未使用单次使用连接工厂，则网关等待获取共享连接的访问权限的时间（毫秒）。

reply-timeout

网关在将回复发送到回复通道时等待的时间（毫秒）。仅在回复通道可能阻塞时适用（例如，当前已满的有界 QueueChannel）。

async

在发送后释放发送线程；回复（或错误）将在接收线程上发送。

unsolicited MessageChannel

一个用于发送非预期消息和延迟回复的渠道。