Spring集成超文本传输协议入站网关参数

Question

我有一个SpringBoot 2.2.6应用程序，我想设置一个带有spring-集成的endpoint，因此我有以下配置：

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

@Bean
public IntegrationFlow inbound(TestTransformer testTransformer) {
    return IntegrationFlows.from(Http.inboundGateway("/foo")
            .requestMapping(m -> m.methods(HttpMethod.GET))
            .replyChannel("reply")
            .requestPayloadType(String.class))
            .channel("httpRequest")
            .get();
}

@Bean
@ServiceActivator(inputChannel = "httpRequest", outputChannel = "reply")
public Function<Message<?>, String> handler() {
    return new Function<Message<?>, String>() {
        public String apply(Message<?> message) throws MessagingException {
            log.info("myHandler: " + message.getPayload());
            log.info("myHandler: " + message.getHeaders());
            return "ok";
        }
    };
}

现在，如果我调用enpoint传递参数为http://localhost:8080/MyApp/foo?q=test

可以在MVC中接收类似@PathVariable的内容，例如编写：

return IntegrationFlows.from(Http.inboundGateway("/foo/{name}")

我已经试过了，但没有成功，我找不到任何文档讨论过这一点（至少在JavaBean配置中是这样）

谢谢




Answer 1

也许：

@Bean
public IntegrationFlow test(TestTransformer testTransformer, Jackson2JsonObjectMapper obj) {
    return IntegrationFlows.from(Http.inboundGateway("/foo/{name}")
            .requestMapping(m -> m.methods(HttpMethod.GET))
            .payloadExpression("#pathVariables.name")
            .replyChannel("reply")
            .requestPayloadType(String.class))
            .transform(testTransformer)
            .transform(new ObjectToJsonTransformer(obj))
            .channel("httpRequest")
            .get();
}

更有用。。。文档中充满了xml配置，我阅读了它，但我无法将它们全部转换为java DSL