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

瑞安·韦格迈尔(Ryan Wegmeier):

我从客户端收到一个请求,该请求返回一个SendRequest-Object,该对象具有HttpMethod,要发送的路径和数据。现在,我想根据获取到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();
Artem Bilan:

不清楚您是什么人SendRequest,但是的想法与对的想法method完全相同url

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

虽然,因为你希望有一些萃取请求主体,你需要做的是,在事先在transform()和移动值url,并method在头文件。:中没有任何有效负载提取Http.outboundGateway:它将整个请求有效负载作为HTTP请求主体的实体来处理。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

Spring IntegrationFlow http请求到amqp队列

我如何获取我实际上在node.js http请求中发送的http请求标头

(Heroku) 如何从我的 Web dyno 向我的服务器 dyno 发送 HTTP 请求

如何将请求永久发送到我的http服务器

如何从本地主机向我的Docker容器发送HTTP请求?

如何跟踪我和游戏服务器之间发送的 HTTP 请求?

如何查看 AngularJS 发送的 HTTP 请求?

如何在Java中发送HTTP请求?

如何保护通过HTTP请求发送的值?

如何从Haxe / Neko发送HTTP PUT请求?

HTTP 重定向请求如何发送 cookie?

如何使用Python发送多个HTTP请求

如何发送多个HTTP请求python

如何从@ angular / http使用http发送帖子请求

Django如何读取http请求并发送http响应

我的应用停止运行(强制停止)在发送HTTP请求的Web

无法以我想要的格式发送HTTP发布请求

我如何使用rxjs将HTTP请求排队,以使其等待现有请求完成,然后仅发送最新请求?

快速发送http请求

发送http请求的表单

我如何在 Alamofire 中检查我的请求已发送?

我如何更改我在python中发送请求的位置

如何将HTTP请求从我的FastAPI应用发送到另一个站点?

如何解决我的http请求问题?

我如何获得http请求的内容?

HTTP请求查询:我可以通过HTTP请求发送视频吗?并发送回json数据和图像?

您将如何在Swift中发送重复的HTTP请求?

如何使用angularjs $ http.delete()请求发送数据?

(转到)发送HTTP请求时如何控制gzip压缩?