Spring Boot JCA CCI连接池实现方案咨询（EJB3.1迁移场景）

当然可以！你已经通过LocalConnectionFactoryBean完成了非托管模式下的JCA集成，在此基础上添加连接池完全可行，不需要依赖IronJacamar这类容器级组件。下面是两种实用的方案：

方案1：使用Spring自带的CachedConnectionFactory #

Spring提供了org.springframework.jca.cci.connection.CachedConnectionFactory，这是一个轻量级的连接缓存/池化实现，专门适配CCI（JCA的客户端接口）连接。它会缓存已创建的连接，避免每次调用都重新初始化JCA连接的开销，非常适合非托管环境。

配置示例 #

@Configuration
public class JcaConfig {

    @Bean
    public LocalConnectionFactoryBean rawJcaConnectionFactory() {
        LocalConnectionFactoryBean factory = new LocalConnectionFactoryBean();
        // 设置你的JCA资源适配器实例
        factory.setResourceAdapter(new YourLegacySystemResourceAdapter());
        // 配置适配器的连接属性（比如遗留系统的地址、凭证等）
        factory.getAdapter().setConnectionProperties(yourConnectionProps());
        return factory;
    }

    @Bean
    public CachedConnectionFactory pooledJcaConnectionFactory() throws Exception {
        CachedConnectionFactory pooledFactory = new CachedConnectionFactory();
        // 关联原始的非托管连接工厂
        pooledFactory.setTargetConnectionFactory(rawJcaConnectionFactory().getObject());
        // 设置最大缓存连接数，根据你的并发需求调整
        pooledFactory.setMaxCacheSize(15);
        return pooledFactory;
    }
}

关键说明 #

• CachedConnectionFactory会自动管理连接的缓存与复用，当你从池获取连接后，Spring会确保在会话结束或事务完成时正确回收连接。
• 如果你的JCA连接是非线程安全的，这个类默认会为每个线程缓存一个独立连接，避免线程安全问题。

方案2：自定义连接池（基于通用池化库） #

如果你需要更精细的池化控制（比如超时、空闲连接回收、监控等），可以用通用的对象池化库（比如Apache Commons Pool2）来包装JCA连接。

核心思路 #

1. 实现一个PooledObjectFactory，负责JCA连接的创建、验证和销毁。
2. 用GenericObjectPool创建连接池实例。
3. 封装一个自定义的ConnectionFactory，从池中获取/归还连接。

简化示例 #

// 1. 实现连接池的对象工厂
public class JcaConnectionPoolFactory extends BasePooledObjectFactory<Connection> {

    private final ConnectionFactory rawConnectionFactory;

    public JcaConnectionPoolFactory(ConnectionFactory rawConnectionFactory) {
        this.rawConnectionFactory = rawConnectionFactory;
    }

    @Override
    public Connection create() throws Exception {
        return rawConnectionFactory.createConnection();
    }

    @Override
    public PooledObject<Connection> wrap(Connection connection) {
        return new DefaultPooledObject<>(connection);
    }

    @Override
    public void destroyObject(PooledObject<Connection> p) throws Exception {
        p.getObject().close();
    }
}

// 2. 配置连接池
@Bean
public GenericObjectPool<Connection> jcaConnectionPool() throws Exception {
    JcaConnectionPoolFactory poolFactory = new JcaConnectionPoolFactory(rawJcaConnectionFactory().getObject());
    GenericObjectPoolConfig<Connection> poolConfig = new GenericObjectPoolConfig<>();
    poolConfig.setMaxTotal(20);
    poolConfig.setMinIdle(5);
    poolConfig.setMaxWaitDuration(Duration.ofSeconds(10));
    return new GenericObjectPool<>(poolFactory, poolConfig);
}

// 3. 封装成可注入的ConnectionFactory
@Bean
public ConnectionFactory pooledConnectionFactory(GenericObjectPool<Connection> pool) {
    return () -> pool.borrowObject();
}

注意事项 #

• 无论用哪种方案，都要确保你的JCA资源适配器支持连接复用（大部分商用/开源适配器都支持）。
• 非托管模式下，连接的生命周期完全由Spring或你的池化代码管理，务必确保连接在使用后被正确关闭或归还到池中，避免资源泄漏。

内容的提问来源于stack exchange，提问作者Ranjith Raj D