3

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

轮询远程 REST 端点，将返回的有效负载拆分为多行并将其发送到 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似乎不接受Pollera 。在我之前使用文件的尝试中，我创建了一个FileReadingMessageSource这样我的流程看起来像：

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

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

4

1 回答 1

3

好吧，您错过了 HTTP 本质上是事件驱动的事实，并且它在这里是服务器。您从最终用户的角度使用它，就像从浏览器或某些命令行工具或任何其他 HTTP 客户端调用 URL 一样。

不确定是什么让您认为 HTTP 服务器正在轮询。并且不确定它应该轮询什么......

也许你需要的恰恰相反——Http.outboundGateway()你调用一些远程 REST 服务并等待回复。但这已经不是一个来源，它是一个处理器。

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

IntegrationFlows.from(() -> new GenericMessage<>(""),
      .poller(Pollers.fixedDelay(period))
  .handle(Http.outboundGateway("http://localhost:8080/data"))
于 2018-02-27T14:01:52.790 回答