Sprint集成DSL-Http入站适配器和轮询器

Question

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

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

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

return IntegrationFlows
  .from
    (
      Http.inboundChannelAdapter("http://localhost:8080/data")
        .requestMapping(m -> m.methods(HttpMethod.GET))
        .replyTimeout(20)
      )
  .channel(INBOUND_DEMO_CHANNEL)
  .get();

inboundChannelAdapter似乎不接受轮询器。在我之前使用文件的尝试中，我创建了一个文件读取消息源（FileReadingMessageSource），因此我的流看起来像：

return IntegrationFlows.from(fileReadingMessageSource,
    // POLLER CONFIGURATION
    .poller(Pollers.fixedDelay(period)
    ...
    .get();

但我找不到与HTTP消息源等效的消息源。

Answer 1

好吧，你忽略了一个事实，HTTP是一个由自然驱动的事件，它是这里的服务器。您可以从最终用户的角度使用它，就像从浏览器或某些命令行工具或任何其他HTTP客户端调用URL一样。

不确定是什么让您认为HTTP服务器正在轮询。但不确定应该投票什么。。。

也许你需要的恰恰相反-Http。outboundGateway（），在这里调用一些远程REST服务并等待回复。但这已经不是一个来源，而是一个处理器。

如果您确实需要定期调用这样的服务，您可以考虑使用简单的轮询MessageSource：

IntegrationFlows.from(() -> new GenericMessage<>(""),
      .poller(Pollers.fixedDelay(period))
  .handle(Http.outboundGateway("http://localhost:8080/data"))