如何将UDP DatagramSocket转换为Spring Integration实现请求响应

要实现UDP请求-响应模式，你需要替换仅做单向发送的UnicastSendingMessageHandler，改用**UdpOutboundGateway**——这个组件原生封装了UDP消息的发送与阻塞式接收逻辑，完美匹配你原DatagramSocket代码的需求。

核心配置与使用步骤 #

1. 配置UdpOutboundGateway #

创建Spring配置类，定义网关实例，对应原代码中DatagramSocket的初始化与超时设置：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.ip.udp.UdpOutboundGateway;

@Configuration
public class UdpIntegrationConfig {

    @Bean
    public UdpOutboundGateway udpRequestResponseGateway() {
        // 本地端口设为0表示随机分配，和原代码new DatagramSocket()行为一致
        UdpOutboundGateway gateway = new UdpOutboundGateway("0.0.0.0", 0);
        gateway.setSoTimeout(1000); // 设置接收超时，对应原代码setSoTimeout(1000)
        return gateway;
    }
}

2. 动态指定目标地址并发送请求 #

由于你的目标主机、端口和消息内容会动态变化，可通过消息头UdpHeaders.DESTINATION动态指定PLC地址，无需重复创建网关实例：

import org.springframework.integration.ip.udp.UdpHeaders;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageBuilder;
import org.springframework.stereotype.Component;

@Component
public class PlcUdpClient {

    private final UdpOutboundGateway udpGateway;

    // 构造注入网关
    public PlcUdpClient(UdpOutboundGateway udpGateway) {
        this.udpGateway = udpGateway;
    }

    public byte[] sendCommandToPlc(byte[] cmd, String plcIp, int plcPort) {
        // 构建请求消息，设置目标地址头
        Message<byte[]> requestMsg = MessageBuilder.withPayload(cmd)
                .setHeader(UdpHeaders.DESTINATION, plcIp + ":" + plcPort)
                .build();

        // 发送并阻塞等待响应，超时会抛出SocketTimeoutException
        Message<byte[]> responseMsg = (Message<byte[]>) udpGateway.sendAndReceive(requestMsg);
        return responseMsg != null ? responseMsg.getPayload() : null;
    }
}

3. 异常处理 #

当接收超时时，sendAndReceive会抛出SocketTimeoutException，你可以在业务代码中捕获并处理，和原DatagramSocket.receive()的异常逻辑一致。

与原DatagramSocket代码的对应关系 #

内容的提问来源于stack exchange，提问作者Andrea P.