java - 什么是相当于 tcp-outbound-gateway 的 java 配置？

Question

我有以下 spring-integration XML 配置

<ip:tcp-outbound-gateway id="outboundClient"
        request-channel="requestChannel"
        reply-channel="string2ObjectChannel"
        connection-factory="clientConnectionFactory"
        request-timeout="10000"
        reply-timeout="10000"/>

我怎样才能写出等同于上面的 Java 配置？我认为等同于

@Bean
public TcpOutboundGateway outboundClient() {
    TcpOutboundGateway tcpOutboundGateway = new TcpOutboundGateway();
    tcpOutboundGateway.setConnectionFactory(clientConnectionFactory());
    tcpOutboundGateway.setRequiresReply(true);
    tcpOutboundGateway.setReplyChannel(string2ObjectChannel());
    tcpOutboundGateway.setRequestTimeout(10000);
    tcpOutboundGateway.setSendTimeout(10000);
    return tcpOutboundGateway;
}

但是我找不到设置请求 channel 的方法。任何帮助将不胜感激。

谢谢

Answer 1

您的配置看起来不错，但您还应该知道任何 Spring Integration Consumer 组件都包含两个主要对象:MessageHandler(在您的例子中为 TcpOutboundGateway)和 EventDrivenConsumer 用于 subscriable input-channel 或 PollingConsumer 如果 input-channel 是 Pollable 。

因此，既然您已经有了第一个处理部分，您还需要另一个消耗部分。为此，Spring Integration 建议使用端点注释标记您的 @Bean:

@Bean
@ServiceActivator(inputChannel = "requestChannel")
public TcpOutboundGateway outboundClient() {

在 Spring Integration Reference Manual 中查看更多信息.

然而，要允许这样的注释过程(或任何其他 Spring Integration 基础设施)，您必须使用 @EnableIntegration 标记您的 @Configuration。

也可以考虑使用 Spring Integration Java DSL从 JavaConfig 中获得更多 yield 。