java - 如何在 Java 类配置中定义 `TcpOutboundGateway` bean

Question

当我尝试定义TcpOutboundGatewaybean 时，我发现该类没有requestChannel和replyChannelNamesetter。如何在我的 Java 类配置中正确定义该 bean？

哪个 Java 类配置与下面介绍的 XML 配置相同？

<int-ip:tcp-outbound-gateway id="outGateway"
        request-channel="input"
        reply-channel="clientBytes2StringChannel"
        connection-factory="client"
        request-timeout="10000"
        reply-timeout="10000"/>

Answer 1

此代码等同于链接提供的客户端 xml 配置。

public static final String STRING_TO_BYTES_CHANNEL = "stringToBytesChannel";
public static final String REQUEST_CHANNEL = "requestChannel";

private String host = "localhost";
private int port = 2020;

@Bean
public TcpNetClientConnectionFactory connectionFactory() {
    TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory(host, port);
    factory.setSingleUse(true);
    factory.setSoTimeout(10000);
    return factory;
}

@Bean
public MessageChannel requestChannel() {
    return new DirectChannel();
}

@Bean
public MessageChannel stringToBytesChannel() {
    return new DirectChannel();
}

@Bean
@Transformer(inputChannel = STRING_TO_BYTES_CHANNEL)
public ObjectToStringTransformer objectToStringTransformer() {
    return new ObjectToStringTransformer();
}

@Bean
@ServiceActivator(inputChannel = REQUEST_CHANNEL)
public TcpOutboundGateway outboundGateway() {
    TcpOutboundGateway gateway = new TcpOutboundGateway();
    gateway.setConnectionFactory(connectionFactory());
    gateway.setReplyChannel(stringToBytesChannel());
    gateway.setRequestTimeout(10000);
    gateway.setRemoteTimeout(10000);
    return gateway;
}

@MessagingGateway(defaultRequestChannel = REQUEST_CHANNEL)
public interface RequestGateway {
    String send(String message);
}