Spring Integration如何通过Java配置实现HTTP入站通道适配器？

认知正误澄清 #

1. 你对消息载体的理解逻辑是对的，但选错了组件：Http.inboundChannelAdapter是服务端角色组件，作用是你暴露HTTP接口给外部系统调用，外部的请求内容会被封装为消息进入Spring Integration通道，和你要的「主动调用外部接口拿结果」的需求完全不匹配。
2. 你需要的主动调用外部REST接口、拿响应结果作为消息payload推送到通道的场景，应该用客户端角色的Http.outboundGateway组件实现。

现有代码问题修正与完整实现 #

你现有代码用错了HTTP组件，调整后的完整流程实现如下（按你给出的完整业务链路编写，默认按5秒轮询拉取第一个接口的需求实现，可自行替换触发逻辑）：

import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.http.dsl.Http;
import org.springframework.integration.ip.dsl.Tcp;
import org.springframework.messaging.MessageHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.integration.annotation.ServiceActivator;
import java.time.Duration;

// 第一步：触发拉取第一个外部接口，获取TransferRequest
@Bean
public IntegrationFlow pullTransferRequestFlow() {
    return IntegrationFlows
            // 定时触发轮询，可自行调整周期，或替换为其他触发源
            .fromSupplier(() -> "", e -> e.poller(p -> p.fixedDelay(Duration.ofSeconds(5))))
            // 调用第一个REST接口，获取TransferRequest对象
            .handle(Http.outboundGateway("http://myRest/transfer/next")
                    .httpMethod(HttpMethod.GET)
                    .expectedResponseType(TransferRequest.class)
                    .headerMapper(myHeaderMapper)
            )
            .channel("transfer_next_channel")
            .get();
}

// 第二步：调用第二个外部接口，转换为DataMessage
@Bean
public IntegrationFlow convertToDataMessageFlow() {
    return IntegrationFlows.from("transfer_next_channel")
            .handle(Http.outboundGateway("http://myRest/message/{personId}")
                    .httpMethod(HttpMethod.GET)
                    // 从TransferRequest中提取personId作为路径参数
                    .uriVariable("personId", message -> ((TransferRequest) message.getPayload()).getPersonId())
                    .expectedResponseType(DataMessage.class)
            )
            .channel("tcp_data_channel")
            .get();
}

// 第三步：推送DataMessage到TCP端口
@Bean
public IntegrationFlow tcpOutboundFlow() {
    return IntegrationFlows.from("tcp_data_channel")
            // 可自定义DataMessage转TCP字符串的序列化逻辑
            .transform(DataMessage::toString)
            // 按你实际的TCP协议调整地址、端口、报文分割规则
            .handle(Tcp.outboundAdapter(Tcp.netClient("127.0.0.1", 9999))
                    .serializer(Tcp.codec().lf())
            )
            .get();
}

// 调试用的打印Handler，可按需保留
@Bean
@ServiceActivator(inputChannel = "transfer_next_channel")
public MessageHandler debugHandler() {
    return message -> {
        System.out.println("TransferRequest payload: " + message.getPayload());
        System.out.println("Headers: " + message.getHeaders());
    };
}

可选调整说明 #

• 若不需要定时轮询，可将第一个流的fromSupplier替换为对应的事件触发源即可
• TCP配置需根据你实际的TCP协议调整，包括报文分割规则、字节序、连接超时等参数
• 可自行在HTTP调用节点添加重试、降级逻辑，适配外部接口不稳定的场景

内容的提问来源于stack exchange，提问作者JBStonehenge