Java如何通过Apache Mina SSHD SFTP客户端处理传入文件并监听变更

首先明确核心结论：Apache Mina SSHD自带的SftpEventListener是仅服务端SFTP子系统可用的扩展点，客户端侧无法直接复用这个组件捕获远端SFTP服务器上的文件变更——本质原因是标准SFTP协议本身没有定义服务端主动推送文件系统事件的能力，要实现客户端侧的文件变更监听，可以根据你是否能控制服务端，选下面几种可行方案：

这是兼容性最好的实现，不需要服务端做任何改造，适配所有标准SFTP服务端，核心逻辑是固定间隔拉取目标目录的文件元数据，和本地存储的上一次快照做对比识别变更。
实现要点：

• 监听启动时，先递归拉取目标监听路径下所有文件/目录的属性（调用SftpClient.readAttributes()方法），生成本地快照：key为文件全路径，value存储文件大小、最后修改时间、文件类型属性
• 按配置的时间间隔重复拉取当前路径的全量属性，和快照做差集比对：
  • 快照中不存在的路径 = 新增文件/目录
  • 快照存在但本次拉取不存在的路径 = 已删除文件/目录
  • 路径存在但大小/修改时间和快照不一致的 = 已修改文件
• 比对完成后更新本地快照，触发对应变更的业务回调
• 优化点：轮询间隔不要低于1秒，避免给服务端造成过大压力；监听上传文件时可以加稳定判定逻辑——连续2-3次拉取文件大小无变化，再判定为文件传输完成，避免处理传输到一半的不完整文件。

核心逻辑代码参考：

// 基于已建立的SSH会话初始化SFTP客户端
try (SftpClient sftp = SftpClientFactory.instance().createSftpClient(sshSession)) {
    // 初始化第一份目录快照
    Map<String, SftpClient.Attributes> lastSnapshot = buildPathSnapshot(sftp, LISTEN_TARGET_PATH);
    while (isRunning.get()) {
        Thread.sleep(pollIntervalMillis);
        Map<String, SftpClient.Attributes> currentSnapshot = buildPathSnapshot(sftp, LISTEN_TARGET_PATH);
        // 对比两个快照的差异，处理新增、修改、删除事件
        handleSnapshotDiff(lastSnapshot, currentSnapshot);
        lastSnapshot = currentSnapshot;
    }
}

如果你要对接的SFTP服务端也是基于Apache Mina SSHD搭建的，可以通过少量定制实现无轮询的准实时事件推送：

• 服务端侧正常注册SftpEventListener，捕获文件创建、修改、删除、重命名的所有事件
• 服务端在事件触发时，通过SSH连接的自定义全局请求、或者独立的端口转发通道，把事件内容推送给对端客户端
• 客户端侧提前注册对应通道/请求的处理器，收到推送事件后直接触发业务逻辑即可
  这种方案的事件延迟和资源开销远低于轮询，但要求你能修改服务端代码，对接第三方通用SFTP服务（比如系统自带的OpenSSH）时无法使用。

如果对接的是标准SFTP服务、无法修改服务端代码，也可以借助服务端自带的机制实现事件通知：

• 针对Linux环境的OpenSSH服务，可以在服务端用inotifywait监控目标目录，文件变更时通过ssh的客户端消息发送接口给已连接的客户端推送事件，客户端侧监听SSH会话的全局请求即可接收
• 如果对接的服务端支持SFTP v5+的文件通知协议扩展，可以自行扩展Apache Mina SSHD的客户端报文解析逻辑，对接该扩展接收事件——不过目前主流SFTP服务端很少默认开启这个扩展，实用性不高。

注意：不要尝试直接在客户端实例上注册自定义SftpEventListener实现监听，这个组件在客户端的SFTP实现逻辑里没有被事件回调的入口，就算注册了也不会被触发。

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