当 SFTP 轮询未检测到匹配文件时，默认仅输出 debug 级别日志（如 “0 files transferred”），若需显式、可监控的 INFO 或 WARN 日志，可通过自定义 ReceiveMessageAdvice 实现精准日志控制。
当 sftp 轮询未检测到匹配文件时，默认仅输出 debug 级别日志（如 “0 files transferred”），若需显式、可监控的 info 或 warn 日志，可通过自定义 `receivemessageadvice` 实现精准日志控制。
在 Spring Integration 中，SftpInboundFileSynchronizingMessageSource 的轮询行为由底层 AbstractPollingEndpoint 驱动。默认情况下，当远程目录无匹配文件时，框架仅在 DEBUG 级别输出类似 Received no Message during the poll, returning 'false' 或 0 files transferred from '...' 的日志——这对生产环境的可观测性不足（INFO/WARN 级别缺失，难以告警或追踪空轮询频次）。
推荐方案：使用 ReceiveMessageAdvice 拦截轮询结果并添加定制日志
ReceiveMessageAdvice 是 Spring Integration 提供的扩展点，其 afterReceive() 方法会在每次轮询结束后被调用，接收 Message> 结果（为空则返回 null），非常适合用于“空轮询”场景的日志增强。
以下是完整实现步骤：
-
定义日志增强类（实现 ReceiveMessageAdvice）：
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer; import org.springframework.integration.support.advice.ReceiveMessageAdvice;
public class LoggingOnEmptyPollAdvice implements ReceiveMessageAdvice {
一款AI工具，主要用于产品经理技能，适用于 Claude Code、Codex、Cursor 和 Windsurf。涵盖 SaaS 指标诊断、PRD 评审、路线图规划、需求探索，以及面向产品经理的职业转型辅导等，适合需要提升相关任务效率的用户。
private static final Logger log = LoggerFactory.getLogger(LoggingOnEmptyPollAdvice.class);
@Override
public Object afterReceive(Object result, Object source) {
if (result == null) {
// 可根据需要调整日志级别：INFO 便于监控，WARN 用于异常频发告警
log.info("SFTP polling completed: no files matched filter in remote directory.");
}
return result;
}
}
2. **在配置中注入该 Advice 到 `SftpInboundFileSynchronizingMessageSource`**：
```java
@Bean(name = "sftpMessageSource")
@InboundChannelAdapter(channel = "fileuploaded", poller = @Poller(fixedDelay = "5000"))
public MessageSource<file> sftpMessageSource() {
SftpInboundFileSynchronizingMessageSource source =
new SftpInboundFileSynchronizingMessageSource(synchronizer());
source.setLocalDirectory(new File("tmp/incoming"));
source.setAutoCreateLocalDirectory(true);
source.setMaxFetchSize(1);
// ? 关键：注册自定义 Advice
source.setAdviceChain(Collections.singletonList(new LoggingOnEmptyPollAdvice()));
return source;
}</file>
✅ 优势说明：
- 日志级别可控（建议 INFO，避免 DEBUG 日志淹没关键信息）；
- 日志内容可定制（例如添加时间戳、轮询间隔、远程路径等上下文）；
- 与业务逻辑解耦，符合 Spring Integration 扩展规范；
- 不影响原有同步逻辑和错误处理流程。
⚠️ 注意事项：
- 确保日志框架（如 Logback/Log4j2）已正确配置，且 org.springframework.integration 包的日志级别不低于 INFO（否则 afterReceive 日志可能被过滤）；
- 若同时启用 AbstractInboundFileSynchronizer 的 DEBUG 日志，注意区分框架原生日志与自定义日志，避免重复；
- 生产环境中建议对高频空轮询添加计数器或限流逻辑（例如连续 10 次空轮询后发送告警），进一步提升运维可观测性。
通过该方式，您将获得清晰、可审计、可告警的轮询状态日志，显著增强 SFTP 文件集成链路的稳定性与可维护性。
