问题标签 [spring-integration-http]

以下配置接受带有要创建的用户实例的 JSON 请求正文的 HTTP POST，但如果我能让它返回一个201 Created. 有任何想法吗？

我尝试调用statusCodeFunction，HttpRequestHandlerEndpointSpec但我一定做错了。

我试图指示 DispatcherServlet 使用 WebServiceMessageReceiverHandlerAdapter 委托给 MessageDispatcher，而不是委托给控制器。

但请求有效负载是 JSON 。我们是否有类似于用于 XML 的 org.springframework.ws.soap.server.SoapMessageDispatcher 的 JSON 的默认 messageDispatcher？

我想构建一个带有 spring 集成 http 支持的 Spring Boot 2 应用程序。但我找不到 int-http 命名空间。

我的 XML：

摇篮：

我对 Spring Integration 相当陌生，我正在尝试设置一个简单的用例：

轮询远程 REST 端点，将返回的有效负载拆分为多行并将其发送到 Kafka 出站适配器。我成功地做了类似的事情，它使用了一个文件适配器，但我坚持使用 HTTP 适配器。我不明白如何将轮询器关联到 HTTP 入站适配器。

到目前为止，我的方法是创建一个简单的流程：

inboundChannelAdapter似乎不接受Pollera 。在我之前使用文件的尝试中，我创建了一个FileReadingMessageSource这样我的流程看起来像：

但我找不到 HTTP 消息源的等价物。

我编写了一个查询 SOAP 和 REST WS 并以某种方式聚合结果的 Spring Integration 路由。我使用一个 bean 作为有效负载来收集有用的信息，两个有效负载丰富器来查询 Web 服务，最后一个转换器来构建结果。

现在我的问题是，如果系统没有关于我正在查询的实体的信息，REST WS 会返回（按设计） HttpStatus.NOT_FOUND (404)。这需要被视为一个名义上的用例。Spring Integration 默认认为这是一个错误并退出。我需要正确处理这种情况，将 null 存储在我的 bean 或类似的东西中（我可以在以后处理它）并继续。

所以我尝试向出站网关添加一个错误处理程序，但无法完成这项工作。如果我告诉这不是错误（覆盖 hasError()），那么 SI 会尝试解组响应的主体，这显然不起作用；如果我覆盖 handleError() 并且什么都不做，则相同。

也许我没有朝着正确的方向前进，但我错过了一个更好的主意，所以......任何帮助都会感激地接受。

在基于用户登录的Spring-integration Http请求中要添加动态标头参数。例如，如果“A”用户登录并点击Http请求，现在需要添加动态1个附加标头，对于其他用户，它甚至应该是关键太（即值为空）

对于 A 用户

对于其他用户

我正在尝试使用 Java DSL 为 HTTP 入站网关创建和注册运行时集成流，如下所示

在这种情况下，我的请求 url ("/foo") 没有与服务器映射，因为当我从 HTTP 客户端发送消息时，服务器端没有收到任何消息。但是当我取消注释上面的bean（入站），即为集成流创建一个bean并在运行方法中 注释流创建和注册代码（删除运行时集成流代码）时，它工作正常：

我的 HTTP 出站网关代码如下

如果这种方法不合适，请帮助我解决上述问题或提供在运行时创建 Http 入站网关的解决方案。

有没有办法可以使用 Hystrix 命令包装 http:outbound 网关 REST API 调用。我看到了一些关于使用自定义请求处理程序建议的参考，但不确定我将如何去做。

我有一个这样配置的 HTTP 入站通道适配器：

我想让它回复 201POST请求和 200 其他请求（即OPTIONS），但没有：

• headers.get('http_requestMethod').equals("POST") ? 201 : 200
• :headers[http_requestMethod].equals("POST") ? 201 : 200
• "POST".equals(:headers['http_requestMethod']) ? 201 : 200

对于有效的status-code-expression属性，它们中的大多数以失败的上下文初始化结束：

我在这里使用了错误的语法还是在那个阶段没有这些细节？

我已经在建议网关的地方看到了这个问题，但我现在想坚持使用适配器。

我正在通过 Http.outboundGateway 向 Web 服务发送请求，并且我希望在这三种情况下得到响应

1-响应成功[确定]

2-连接失败[需要重试]

3-带有错误代码的响应返回，例如。400 [保存它]

我在轮询器之后使用advice() 重新尝试连接失败，但问题是在两种情况下都抛出了错误消息异常（连接失败，响应错误代码），所以对这两种情况都调用了重试

我如何区分它们并仅对连接失败 使用重试建议

重试建议创建 bean