Spring 集成:JDBC 入站通道适配器

Spring Integration: JDBC inbound channel adapter

我试图使用 JDBC 入站通道适配器,但遇到了一些困惑。

首先,在查询语句中指定 max-rows-per-poll 还是使用 limit 哪个更有效? 其次,为避免重复读数,在处理每个轮询的最后一条消息后,是否仍然运行 poller 而不是 fixed-rate ?我可以使用 update 但在流中有动态更新查询。

我的集成流程有点像 jdbc:inbound-channel-adapter -> http:outbound-channel-adapter -> jdbc:outbound-channel-adapter(根据 http:outbound-channel-adapter 的响应更新每一行)。它应该处理大量的行。

  1. LIMIT效率更高。
  2. 只要您使用 DirectChannels(默认值),并且轮询器上没有任务执行器,下一次轮询不会 运行 直到当前轮询完成,无论触发器如何.