Spring自定义工厂创建的动态DataSource销毁时是否需手动关闭？

首先明确一点：Spring容器只会自动管理它自己创建并纳入上下文的Bean。如果你是自己通过new关键字创建DataSource，然后只存在自己维护的Map里，Spring根本不知道这些实例的存在，所以当服务销毁时，这些DataSource不会被自动关闭，大概率会导致数据库连接泄漏、资源占用等问题。

接下来分两种场景给出解决方案：

方案一：将动态DataSource注册为Spring Bean，让容器接管生命周期 #

如果你的动态DataSource数量和创建时机允许注册为Bean，这是最省心的方式，Spring会自动处理销毁逻辑。你可以显式指定destroyMethod="close"（不过很多主流DataSource实现比如HikariCP，Spring会自动识别它的close方法作为销毁方法，显式写出来更保险）。

要动态注册Bean，可以借助BeanDefinitionRegistry来实现，示例代码如下：

@Autowired
private BeanDefinitionRegistry registry;

private final Map<String, DataSource> dataSourceCache = new ConcurrentHashMap<>();

public void createAndRegisterDataSource(String dataSourceKey, DataSourceProperties config) {
    // 创建具体的DataSource实例，这里以HikariCP为例
    HikariDataSource hikariDs = new HikariDataSource();
    hikariDs.setJdbcUrl(config.getUrl());
    hikariDs.setUsername(config.getUsername());
    hikariDs.setPassword(config.getPassword());
    // 按需配置连接池参数，比如最大连接数、超时时间等
    
    // 注册为Spring Bean，指定销毁方法
    GenericBeanDefinition beanDef = new GenericBeanDefinition();
    beanDef.setBeanClass(HikariDataSource.class);
    beanDef.setInstanceSupplier(() -> hikariDs);
    beanDef.setDestroyMethodName("close");
    // 用唯一的key作为Bean名称，避免重复覆盖
    registry.registerBeanDefinition(dataSourceKey, beanDef);
    
    // 存入自定义Map方便快速获取
    dataSourceCache.put(dataSourceKey, hikariDs);
}

这样当Spring容器销毁时，会遍历所有注册的Bean，调用它们的销毁方法，你的DataSource就会被正确关闭，释放连接池资源。

方案二：手动管理DataSource的销毁逻辑 #

如果因为业务特殊性，不想把这些DataSource注册为Spring Bean，那你需要自己在服务销毁时手动关闭所有动态创建的DataSource。

可以通过实现DisposableBean接口或者使用@PreDestroy注解来触发销毁逻辑，示例代码如下：

@Component
public class DynamicDataSourceManager implements DisposableBean {
    // 用线程安全的Map存储动态DataSource，避免并发操作问题
    private final Map<String, DataSource> dataSourceMap = new ConcurrentHashMap<>();

    // 动态创建并添加DataSource的方法
    public void addDataSource(String key, DataSource dataSource) {
        dataSourceMap.put(key, dataSource);
    }

    // 从Map中获取DataSource的方法，包含你的有效性验证逻辑
    public DataSource getDataSource(String key) throws SQLException {
        DataSource ds = dataSourceMap.get(key);
        if (ds != null && ds.getConnection().isValid(1)) {
            return ds;
        }
        // 这里可以按需处理失效的DataSource，比如重新创建或移除
        return null;
    }

    @Override
    public void destroy() throws Exception {
        // 遍历Map，逐个关闭DataSource
        for (DataSource ds : dataSourceMap.values()) {
            try {
                // 主流连接池（Hikari、Druid等）都实现了AutoCloseable接口
                if (ds instanceof AutoCloseable) {
                    ((AutoCloseable) ds).close();
                    log.info("Successfully closed dynamic DataSource");
                }
            } catch (Exception e) {
                // 捕获异常，避免一个DataSource关闭失败影响其他实例
                log.error("Failed to close dynamic DataSource", e);
            }
        }
        // 清空Map释放引用
        dataSourceMap.clear();
    }
}

当Spring容器销毁时，会自动调用这个destroy方法，帮你完成所有动态DataSource的关闭操作。

关键注意事项 #

• 不管用哪种方案，都要确保你使用的DataSource实现了AutoCloseable接口（主流连接池都已实现），这样才能通过close方法释放资源。
• 手动管理时，一定要用线程安全的Map（比如ConcurrentHashMap），避免并发访问时出现异常。
• 验证DataSource有效性时，记得捕获SQLException，防止因连接失效抛出未处理的异常影响业务流程。

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