新手求教：如何为不同属性复用SAPJCO3连接池（Spring Boot）

针对Spring Boot环境下根据请求动态变化的SAP连接属性（host、sysnr、client、user、密码）复用连接池的需求，你可以按以下方式优化实现：

1. 定义唯一连接标识键 #

不要用字符串拼接做缓存键，而是创建一个不可变的SapConnectionKey类，将核心连接属性（host、sysnr、client、user）作为键的字段，重写equals()和hashCode()方法保证唯一性。如果密码可能独立变化（同一用户/客户端用不同密码连接），需将密码也加入键的字段，但要避免在日志或toString中泄露敏感信息。

示例代码：

public class SapConnectionKey {
    private final String host;
    private final String sysnr;
    private final String client;
    private final String user;
    // 若密码需作为区分条件，添加private final String password;

    public SapConnectionKey(String host, String sysnr, String client, String user) {
        this.host = host;
        this.sysnr = sysnr;
        this.client = client;
        this.user = user;
    }

    // 重写equals和hashCode，确保属性完全一致时才视为同一个键
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        SapConnectionKey that = (SapConnectionKey) o;
        return Objects.equals(host, that.host) &&
                Objects.equals(sysnr, that.sysnr) &&
                Objects.equals(client, that.client) &&
                Objects.equals(user, that.user);
                // 若包含密码，添加Objects.equals(password, that.password)
    }

    @Override
    public int hashCode() {
        return Objects.hash(host, sysnr, client, user);
        // 若包含密码，添加password到hash参数
    }

    // 重写toString时隐藏敏感信息
    @Override
    public String toString() {
        return "SapConnectionKey{" +
                "host='" + host + '\'' +
                ", sysnr='" + sysnr + '\'' +
                ", client='" + client + '\'' +
                ", user='" + user + '\'' +
                '}';
    }
}

2. 使用线程安全的缓存容器替代普通Map #

用ConcurrentHashMap作为连接池的缓存容器，它天生支持并发读写，避免普通HashMap在并发场景下的线程安全问题。如果需要更灵活的缓存策略（比如自动过期、闲置回收），可以集成Spring Cache + Caffeine缓存框架。

示例缓存初始化：

@Service
public class SapPoolManager {
    // 用ConcurrentHashMap缓存连接池实例
    private final ConcurrentHashMap<SapConnectionKey, JCoPool> poolCache = new ConcurrentHashMap<>();

    // 从缓存获取或创建连接池的核心方法
    public JCoPool getOrCreatePool(SapConnectionProps connectionProps) {
        SapConnectionKey key = new SapConnectionKey(
                connectionProps.getHost(),
                connectionProps.getSysnr(),
                connectionProps.getClient(),
                connectionProps.getUser()
                // 若包含密码，传入connectionProps.getPassword()
        );

        // 双重检查锁定，避免并发创建重复连接池
        JCoPool pool = poolCache.get(key);
        if (pool == null) {
            synchronized (poolCache) {
                pool = poolCache.get(key);
                if (pool == null) {
                    pool = buildJcoPool(connectionProps);
                    poolCache.put(key, pool);
                }
            }
        }
        return pool;
    }

    // 封装SAPJCO3连接池创建逻辑
    private JCoPool buildJcoPool(SapConnectionProps props) {
        JCoDestinationManager.registerDestination(props.getDestinationName(), createDestinationData(props));
        // 根据实际项目的连接池实现初始化，比如自定义JCoPool封装JCoDestination
        return new JCoPool(props.getDestinationName());
    }

    // 构建SAP连接属性
    private DestinationDataProvider createDestinationData(SapConnectionProps props) {
        Properties destProps = new Properties();
        destProps.setProperty(DestinationDataProvider.JCO_ASHOST, props.getHost());
        destProps.setProperty(DestinationDataProvider.JCO_SYSNR, props.getSysnr());
        destProps.setProperty(DestinationDataProvider.JCO_CLIENT, props.getClient());
        destProps.setProperty(DestinationDataProvider.JCO_USER, props.getUser());
        destProps.setProperty(DestinationDataProvider.JCO_PASSWD, props.getPassword());
        destProps.setProperty(DestinationDataProvider.JCO_LANG, "zh");
        // 其他连接属性（如池大小）按需配置
        destProps.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, "10");
        destProps.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, "20");

        return new DefaultDestinationDataProvider(destProps);
    }
}

3. 添加闲置连接池回收机制 #

连接池长期闲置会占用SAP系统资源和本地内存，需定时清理：

• 若用ConcurrentHashMap，可以通过Spring定时任务扫描缓存，关闭并移除闲置超过阈值的连接池。
• 若用Caffeine缓存，可直接配置expireAfterAccess参数，自动回收闲置连接池。

示例定时清理逻辑：

@Scheduled(fixedRate = 3600000) // 每小时执行一次
public void cleanIdlePools() {
    Iterator<Map.Entry<SapConnectionKey, JCoPool>> iterator = poolCache.entrySet().iterator();
    while (iterator.hasNext()) {
        Map.Entry<SapConnectionKey, JCoPool> entry = iterator.next();
        JCoPool pool = entry.getValue();
        // 自定义判断闲置的逻辑，比如检查池内所有连接的最后使用时间
        if (pool.isIdleOverThreshold(7200000)) { // 闲置超过2小时
            pool.close(); // 关闭连接池，释放SAP资源
            iterator.remove();
        }
    }
}

4. 在Controller中动态调用 #

接收API传入的连接属性，通过SapPoolManager获取对应的连接池执行操作：

@RestController
@RequestMapping("/sap")
public class SapController {
    @Autowired
    private SapPoolManager sapPoolManager;

    @PostMapping("/execute")
    public String executeSapFunction(@RequestBody SapConnectionProps props) {
        JCoPool pool = sapPoolManager.getOrCreatePool(props);
        // 从池获取连接执行SAP函数
        JCoDestination dest = pool.getDestination();
        // 后续业务逻辑...
        return "执行成功";
    }
}

你之前用全局Map的问题 #

普通全局Map存在三个核心缺陷：

• 非线程安全：并发请求下可能重复创建多个相同属性的连接池，浪费资源。
• 无资源回收：闲置连接池不会自动清理，长期占用内存和SAP连接配额。
• 键可靠性差：字符串拼接做键容易因特殊字符、格式问题导致哈希冲突，出现错误复用或重复创建的情况。

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