如何从我的 IntegrationFlow 发送 HTTP 请求？

Question

我收到来自客户端的请求，该请求返回具有 HttpMethod、路径和要发送的数据的 SendRequest-Object。 现在我想根据获取到 API 的对象发送请求。

发送后我会收到回复。

现在的问题是如何发送有效载荷并接收响应。

@Bean
    public IntegrationFlow httpPostSendRawData() {
        return IntegrationFlows.from(
                Http.inboundGateway("/api/data/send")
                        .requestMapping(r -> r.methods(HttpMethod.POST))
                        .statusCodeExpression(dataParser().parseExpression("T(org.springframework.http.HttpStatus).BAD_REQUEST"))
                        .requestPayloadType(ResolvableType.forClass(DataSend.class))
                        .crossOrigin(cors -> cors.origin("*"))
                        .headerMapper(dataHeaderMapper())
        )
                .channel("http.data.send.channel")
                .handle("rawDataEndpoint", "send")
                .transform(/* here i have some transformations*/)
                .handle(Http.outboundGateway((Message<SendRequest> r)->r.getPayload().getPath())
                        .httpMethod(/* Here I would like to get the Method of SendRequest*/)
                        //add payload
                        .extractPayload(true))
.get();

Answer 1

不清楚您的SendRequest 是什么，但method 的想法与您为url 所做的完全一样：

.httpMethodFunction((Message<SendRequest> r)->r.getPayload().getMethod())

虽然，由于您希望对请求正文进行一些提取，因此您需要提前在 transform() 中执行此操作，并将 url 和 method 的值移动到标头。 Http.outboundGateway 中没有任何有效负载提取：它将整个请求有效负载作为 HTTP 请求正文的实体处理。