春季集成http入站网关参数

Question

我想设置一个使用spring-integration设置端点

@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";
        }
    };
}

我有一个springboot 2.2.6应用程序， http：// localhost：8080/myapp/foo？q = test＆amp; q1 = test2我以json表单接收参数。

可以在MVC中收到@pathvariable的东西，例如写作：

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

我已经尝试过但不起作用，但我找不到任何文档在谈论这一点（至少使用Java Bean Configuration）

谢谢

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中