Spring集成阻塞轮询器，异步下游，流完成信号

Question

我正在尝试配置一个轮询器，该轮询器每X秒查询一个bean，以将列表放入一个通道。该通道有一个下游流，该流将列表拆分并输出到发布/子通道（进一步的异步流）。我如何确保在任何给定的时间，只有在流执行过程中，轮询器必须等待/阻止流完成，直到为下一次轮询做好准备（固定速率/延迟）？

<int:channel id="configListChannel" />
<task:executor id="pollExecutor" pool-size="1" queue-capacity="1" rejection-policy="ABORT" />
<int:inbound-channel-adapter expression="configMap().values()" auto-startup="true" channel="configListChannel">
    <int:poller fixed-delay="30" time-unit="SECONDS" task-executor="pollExecutor"/>
</int:inbound-channel-adapter>

<task:executor id="configExecutor" pool-size="5"/>
<int:channel id="configChannel" >
    <int:dispatcher task-executor="configExecutor"/>
</int:channel>
<int:chain input-channel="configListChannel" output-channel="configChannel" id="configChain">
    <int:splitter/>
    <int:filter expression="payload.enablePolling"/>
</int:chain>

...在confiChannel上进一步异步流以发送出站消息

有没有使用异步切换的阻塞轮询器示例，以及使用barrier向轮询器线程发送完成流信号的示例？而且一次只能进行一次投票。

Answer 1

我建议您实现一个ReceiveMessageAdvice（从5.3或AbstractMessageSourceAdvice开始）。它是afterReceive（）应该按原样返回消息，但是beforeceive（）应该检查一些状态，如果此时无法轮询，则返回false。

您可能不需要为该任务设置障碍，但只需简单的原子布尔bean即可检查该中的状态，然后在下游完成任务时将其返回到true。