数据连接池升级记：SpringBoot原生Hikari切换动态多数据源的坑与RocketMQ吞掉异常排查

升级SpringBoot Hikari数据连接池：经验教训和最佳实践

作为微服务开发的首选框架，SpringBoot因其轻量、快速和约定优于配置而受到广泛欢迎。而数据库连接池作为Java应用不可或缺的组件，其性能与稳定性对于应用程序的运行至关重要。本文将分享我们在升级SpringBoot原生Hikari数据连接池到动态多数据源过程中踩过的坑，并总结一些最佳实践，以帮助其他开发者规避常见错误，提升应用程序的稳定性。

引入动态多数据源

在微服务架构中，通常需要连接多个异构数据库，以满足不同业务场景的需求。SpringBoot原生支持的Hikari数据连接池虽然性能优异，但对于异构数据库的支持却稍显不足。因此，引入动态多数据源成为了一种常见解决方案。

踩过的坑

坑一：默认数据源配置错误

在引入dynamic-datasource数据源后，如果未正确配置数据源，那么就会使用默认配置的数据源连接池。这可能会导致连接不可用等异常，而这些异常很有可能被RocketMQ捕获，导致难以发现问题。

// 错误配置
@Configuration
public class DefaultDataSourceConfig {

    @Bean
    @Primary
    public DataSource defaultDataSource() {
        // ...
    }
}

// 正确配置
@Configuration
public class DefaultDataSourceConfig {

    @Bean("defaultDataSource")
    public DataSource defaultDataSource() {
        // ...
    }
}

坑二：连接池参数设置不当

Hikari数据连接池提供了丰富的参数配置选项，以满足不同的应用场景。然而，如果参数设置不当，也可能导致连接不可用等异常。

// 错误配置
@Configuration
public class DataSourceConfig {

    @Bean
    public DataSource dataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setMaximumPoolSize(10); // 最大连接数设置过小
        // ...
        return dataSource;
    }
}

// 正确配置
@Configuration
public class DataSourceConfig {

    @Bean
    public DataSource dataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setMaximumPoolSize(100); // 根据实际业务场景调整连接池参数
        // ...
        return dataSource;
    }
}

坑三：RocketMQ吞掉异常

在使用RocketMQ进行消息队列处理时，我们发现某些异常会被RocketMQ捕获，导致异常无法被应用程序感知。这可能会导致应用程序陷入未知状态，难以进行故障排查。

// 错误配置
@Configuration
public class RocketMQConfig {

    @Bean
    public RocketMQTemplate rocketMQTemplate() {
        RocketMQTemplate template = new RocketMQTemplate();
        template.setRetryToConsumer(true); // 错误：异常会被RocketMQ捕获
        // ...
        return template;
    }
}

// 正确配置
@Configuration
public class RocketMQConfig {

    @Bean
    public RocketMQTemplate rocketMQTemplate() {
        RocketMQTemplate template = new RocketMQTemplate();
        template.setRetryToConsumer(false); // 正确：异常不会被RocketMQ捕获
        // ...
        return template;
    }
}

解决之道

经过一系列的排查和调整，我们最终解决了这些问题，应用程序得以正常运行。在此过程中，我们积累了一些经验教训，总结如下：

• 仔细检查数据源配置，确保所有数据源都已正确配置。
• 根据实际业务场景调整连接池参数，以确保能够满足应用程序的并发需求。
• 在RocketMQ的配置中设置 message.retry.to.consumer 为 false，以确保异常能够被应用程序感知。

结论

在SpringBoot原生Hikari数据连接池升级到动态多数据源的过程中，我们踩了一些坑，也从中学习到了很多经验教训。希望本文能够帮助其他开发者规避常见错误，提升应用程序的稳定性。

最后，感谢dynamic-datasource和RocketMQ这两个优秀的开源项目，它们为我们的应用程序开发提供了强大的支持。

常见问题解答

1. 如何配置动态多数据源？

   可以使用dynamic-datasource项目来配置动态多数据源。具体配置方式可以参考项目文档。

2. 如何设置连接池参数？

   Hikari数据连接池提供了丰富的参数配置选项。可以根据实际业务场景进行调整。更多详情可以参考Hikari官方文档。

3. RocketMQ捕获异常后，如何让应用程序感知？

   在RocketMQ的配置中设置 message.retry.to.consumer 为 false。

4. 除了本文提到的坑之外，还有其他需要注意的点吗？

   除了本文提到的坑之外，在升级过程中还可能遇到其他问题。建议仔细检查配置并进行充分测试。

5. 如何避免踩坑？

   在升级过程中，建议遵循最佳实践，仔细检查配置并进行充分测试。同时，可以参考本文中的经验教训来规避常见错误。