Spring Integration SMB入站通道适配器性能问题求助

1. 频繁创建SMB会话的问题 #

日志中频繁出现SMB share init:说明每次文件操作都在新建SMB会话，这是性能瓶颈的核心原因。默认SmbSessionFactory未启用会话池，每次请求都会重新建立SMB连接、初始化共享，导致大量耗时。

修复方案：启用会话池 #

修改smbSessionFactory() Bean配置，添加会话池参数：

@Bean
public SmbSessionFactory smbSessionFactory() {
    SmbSessionFactory smbSession = new SmbSessionFactory();
    smbSession.setHost(host);
    smbSession.setPort(port);
    smbSession.setDomain(domain);
    smbSession.setUsername(username);
    smbSession.setPassword(password);
    smbSession.setShareAndDir("sambashare");
    smbSession.setSmbMinVersion(DialectVersion.SMB210);
    smbSession.setSmbMaxVersion(DialectVersion.SMB311);
    // 启用会话池
    smbSession.setMaxSessions(10); // 根据并发需求调整
    smbSession.setSessionWaitTimeout(30000); // 会话等待超时时间，单位毫秒
    return smbSession;
}

启用会话池后，SMB连接会被复用，避免重复初始化共享，大幅降低操作延迟。

2. 单次获取文件数量无法控制的问题 #

你设置了maxMessagesPerPoll = "10"和maxFetchSize = 100但未生效，核心原因是会话未复用导致每次轮询只能建立一次连接，无法批量获取文件；同时maxMessagesPerPoll与maxFetchSize的配合逻辑需要明确：前者是轮询周期内处理的消息数，后者是单次远程文件列表查询的最大数量。

修复方案： #

1. 确保会话池已启用（见上述配置），让单次轮询可复用会话批量获取文件
2. 调整轮询器配置，使用fixedRate替代fixedDelay，避免等待上一轮完全结束才开始下一轮：

@Bean
@InboundChannelAdapter(channel = "stream", poller = @Poller(maxMessagesPerPoll = "10", fixedRate = "1000"))
public MessageSource<InputStream> smbMessageSource(CompositeFileListFilter filter, SmbRemoteFileTemplate template) {
    SmbStreamingMessageSource messageSource = new SmbStreamingMessageSource(template);
    messageSource.setRemoteDirectory("test/");
    messageSource.setMaxFetchSize(100);
    messageSource.setFilter(filter);
    // 添加文件排序，确保批量获取时的顺序稳定
    messageSource.setComparator((f1, f2) -> f1.getName().compareTo(f2.getName()));
    return messageSource;
}

3. 添加防重复读取过滤器（可选但推荐），避免重复处理文件：

@Bean
public CompositeFileListFilter<SmbFile> compositeFileListFilter() {
    CompositeFileListFilter<SmbFile> filters = new CompositeFileListFilter<>();
    // 使用持久化过滤器记录已处理文件
    filters.addFilter(new SmbPersistentAcceptOnceFileListFilter(new SimpleMetadataStore(), "smb-files"));
    return filters;
}

3. 单文件处理间隔7秒的问题 #

该问题本质是频繁新建会话导致的连接初始化耗时，启用会话池后，连接复用会大幅降低这个间隔。如果仍有延迟，可检查：

• SMB服务器的网络延迟，尝试优化网络连接
• 调整会话池的maxSessions参数，增加并发会话数
• 若文件处理逻辑（serviceActivator）存在阻塞，可开启异步处理：

@ServiceActivator(inputChannel = "xml", async = "true")
void serviceActivator(String xml) {
    log.info(xml);
}

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