Spring Integration Poller触发过于频繁问题排查咨询

你的两个判断完全正确，该现象是Spring Integration轮询器的设计特性与通知作用范围共同导致的，不属于配置错误。

问题根因说明 #

1. 轮询间隔的作用范围
   你配置的1秒fixedDelay是两次轮询调度批次之间的间隔，而非单次消息拉取动作的间隔。你在AbstractPollingEndpoint中看到的while循环就是轮询批次的处理逻辑：单次调度被触发后，会在当前线程内循环执行消息拉取动作，直到满足以下两个条件之一才会终止本次批次，等待下一次调度：

• 已拉取的消息数量达到maxMessagesPerPoll的配置上限
• 调用pollForMessage()返回null（当前无消息可拉取）
  当有大量AMQP消息涌入时，单次批次可以拉取到多条消息，因此会在短时间内触发多次拉取动作，这就是你看到1秒内多次日志的核心原因。

2. PollSkipAdvice的作用范围
   PollSkipAdvice的切点就是单次pollForMessage()方法调用，每次拉取单条消息前都会调用你定义的skipPoll()逻辑，而非每个调度批次只调用一次，进一步放大了短时间内的日志输出次数。

解决方案 #

根据你的业务需求可以选择不同的修复方式：

• 如果需要每个调度周期最多只处理1条消息，直接将maxMessagesPerPoll设置为1，即可保证skipPoll()每1秒只会被调用1次。
• 如果需要保留批量拉取能力，仅需每个调度批次执行一次跳过判断，不要使用PollSkipAdvice，改为自定义Trigger实现调度逻辑，或者对轮询批次的入口方法添加环绕通知即可。
• 如果需要控制单条消息拉取的间隔，可以调整轮询器的receiveTimeout参数，或者在skipPoll()返回true时添加短时间的休眠逻辑。

内容的提问来源于stack exchange，提问作者Bojan Vukasovic