Micronaut框架中替代Spring Integration的SFTP文件处理方案咨询

Micronaut 生态内置了和Spring Integration SFTP模块能力对齐的原生组件，无需手动编写完整定时任务逻辑即可实现SFTP服务端文件轮询、处理能力，适配方案如下：

依赖引入 #

首先在项目中引入SFTP官方依赖，以Gradle配置为例：

• 核心SFTP组件：implementation("io.micronaut.sftp:micronaut-sftp:4.6.0")
• 声明式调度组件（内置轮询能力，无需自行实现定时逻辑）：implementation("io.micronaut:micronaut-scheduling")

配置SFTP连接与轮询规则 #

直接在application.yml中配置连接参数和扫描规则，无需硬编码：

micronaut:
  sftp:
    default: # 连接标识，支持多SFTP源配置
      host: 你的SFTP服务地址
      port: 22
      username: 登录账号
      password: 登录密码
      remote-directory: /需要扫描的远程目录路径
      filename-pattern: *.csv # 可选，配置文件过滤规则，只扫描匹配规则的文件
      delete-after-process: true # 可选，处理完成后自动删除远程文件，也可配置为移动到其他目录
      poll:
        fixed-delay: 30s # 扫描间隔，支持秒、分钟等时间格式
        max-messages-per-poll: 10 # 单次扫描最多处理文件数

编写文件处理逻辑 #

仅需声明处理Bean，使用@SftpListener注解即可自动接收扫描到的文件，和Spring Integration的@ServiceActivator使用逻辑高度一致，迁移成本极低：

import io.micronaut.sftp.annotation.SftpListener;
import io.micronaut.sftp.event.FileReceivedEvent;
import jakarta.inject.Singleton;

@Singleton
public class SftpFileProcessingService {

    @SftpListener(connection = "default") // 对应配置里的连接标识
    public void processScannedFile(FileReceivedEvent event) {
        // 直接获取扫描到的文件元信息与内容，执行你的业务处理逻辑
        String fileName = event.getFileInfo().getName();
        long fileSize = event.getFileInfo().getSize();
        byte[] fileContent = event.getContent();

        // 你的业务处理逻辑...
    }
}

可选扩展能力 #

• 内置文件去重能力，默认不会重复扫描已经处理过的文件，无需自行实现幂等逻辑
• 支持自定义文件后置操作，直接在处理方法中注入SftpClient即可调用API实现文件移动、重命名等操作
• 支持错误重试、死信队列配置，处理失败的文件可自定义降级逻辑

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