java - 带有 c3p0 数据库池和故障转移的 Spring Boot JDBCTemplate

标签 java spring-boot jdbc spring-jdbc c3p0

我需要在 SpringBoot 应用程序(嵌入式 tomcat)中使用 jdbctemplate 为 ibatis 建立数据库连接故障转移,它使用 c3p0 进行连接池。下面是我的应用程序的 applicaiton.properties。我有主要和次要数据库。如果主要失败,那么次要应该用于运行时的数据库连接故障转移。请帮助我实现这一目标。我尝试将多个数据库 URL 作为配置的一部分包含在内,但这是行不通的。

c3p0 Java Database Pooling, failover configuration https://docs.genesys.com/Documentation/Composer/8.1.4/Help/ConnectionPooling

application.properties:(错误来了)

#      connection properties for data source
##########################################################################################################
spring.datasource.c3p0.driverClass=oracle.jdbc.driver.OracleDriver
spring.datasource.c3p0.maxConnectionAge=3600
spring.datasource.c3p0.maxIdleTime=600
spring.datasource.c3p0.initialPoolSize=5
spring.datasource.c3p0.maxPoolSize=10
spring.datasource.c3p0.minPoolSize=5
spring.datasource.c3p0.acquireIncrement=1

##########################################################################################################


spring.datasource.url=jdbc:oracle:thin:@primary.com:1521:db1,jdbc:oracle:thin:@secondary.com:1521:db2
spring.datasource.username=user
spring.datasource.password=password

最佳答案

据我所知,故障转移配置取决于 JDBC 驱动程序。对于 Oracle,您可以使用连接描述符对其进行配置。所以在你的情况下你会把它放在 tnsnames.ora 中:

CONNECTION_WITH_FAILOVER = 
    (DESCRIPTION =
        (ADDRESS_LIST =
            (ADDRESS = (PROTOCOL = TCP)(HOST = primary.com)(PORT = 1521))
            (ADDRESS = (PROTOCOL = TCP)(HOST = secondary.com)(PORT = 1521))
            (LOAD_BALANCE = no)
            (FAILOVER = yes)
        )
        (CONNECT_DATA =
            (SERVER = DEDICATED)
            (SERVICE_NAME = db)
            (FAILOVER_MODE =
                (TYPE = select)
                (METHOD = preconnect)
                (RETRIES = 180)
                (DELAY = 10)
            )
        )
    )

然后在你的配置中:

spring.datasource.url=jdbc:oracle:thin:@CONNECTION_WITH_FAILOVER 

当然,您可能没有或不想使用tnsnames.ora,在这种情况下您可以使用连接描述符作为JDBC 连接字符串的一部分:

spring.datasource.url=jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=primary.com)(PORT=1521))(ADDRESS=(PROTOCOL=TCP)(HOST=secondary.com)(PORT=1521))(LOAD_BALANCE=no)(FAILOVER=yes))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=db)(FAILOVER_MODE=(TYPE=select)(METHOD=preconnect)(RETRIES=180)(DELAY=10))))

有关连接描述符、tnsnames.ora 和为 Oracle DB 配置故障转移的更多详细信息,请参阅这些链接:

请注意,所有数据库上的服务名称必须相同,因此我将配置中的 db1db2 替换为 db.

如果您想拥有不同的服务名称,您必须以编程方式配置单独的数据源(如 Sheetal Mohan Sharma 所述)。

编辑:

  • 您收到的错误表明您正在尝试连接到服务器上不存在的服务名称 - 更多 here
  • 我今天更仔细地重新阅读了文档(特别是我上面链接的 PDF),似乎可以在连接字符串中指定辅助服务名称,因此在您的情况下,tnsnames.ora 中的条目将是:

    CONNECTION_WITH_FAILOVER = (说明 = (地址列表 = (地址 =(协议(protocol) = TCP)(主机 = primary.com)(端口 = 1521)) (地址 =(协议(protocol) = TCP)(主机 = secondary.com)(端口 = 1521)) (LOAD_BALANCE = 否) (故障转移 = 是) ) (连接数据 = (服务器 = 专用) (SERVICE_NAME = db1) (故障转移模式 = (类型 = 选择) (方法 = 预连接) (重试 = 180) (延迟 = 10) (备份 = db2) ) ) )

并作为 application.properties 中的 JDBC URL:

spring.datasource.url=jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=primary.com)(PORT=1521))(ADDRESS=(PROTOCOL=TCP)(HOST=secondary.com)(PORT=1521))(LOAD_BALANCE=no)(FAILOVER=yes))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=db1)(FAILOVER_MODE=(TYPE=select)(METHOD=preconnect)(RETRIES=180)(DELAY=10)(BACKUP = db2))))
  • 我目前没有配置这样的设置,所以我把它放在我的 tnsnames.ora 中:

    CONNECTION_WITH_FAILOVER = (说明 = (地址列表 = (地址 =(协议(protocol) = TCP)(主机 = google.com)(端口 = 1521)) (ADDRESS = (PROTOCOL = TCP)(HOST = my-actual-database)(PORT = my-db-port)) (LOAD_BALANCE = 否) (故障转移 = 是) ) (连接数据 = (服务器 = 专用) (SERVICE_NAME = 我的服务名称) (故障转移模式 = (类型 = 选择) (方法 = 预连接) (重试 = 1) (延迟 = 1) ) ) )

模拟主连接失败(因为显然没有 Oracle DB 在 google.com 上运行)并使用连接 URL 设法通过 DataGrip 连接到我的数据库:jdbc:oracle:thin:@CONNECTION_WITH_FAILOVER

我还直接在 JDBC URL 中尝试使用连接描述符:

jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=google.com)(PORT=1521))(ADDRESS=(PROTOCOL=TCP)(HOST=my-actual-database)(PORT=my-db-port))(LOAD_BALANCE=no)(FAILOVER=yes))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=my-service-name)(FAILOVER_MODE=(TYPE=select)(METHOD=preconnect)(RETRIES=1)(DELAY=5))))

它也能正常工作,尽管两次都需要相当长的时间才能建立连接(但这可能与我的网络配置或驱动程序的连接超时值有关)

  • 确保配置 FAILOVER_MODE 参数以满足您的需要 - 特别考虑 RETIRES 和 DELAY 值 - 在我提供的示例中,我使用了 180 次重试和 10 秒重试之间的延迟,添加连接每次重试都会超时,并且在驱动程序实际切换到故障转移连接之前可能需要很长时间。

关于java - 带有 c3p0 数据库池和故障转移的 Spring Boot JDBCTemplate,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51023561/

相关文章:

java - 新版本的 Netbeans 刚刚问世。我能做些什么来避免再次手动搜索我的插件吗?

java - 使用带有 Spring Boot 和 Spring Security 的 javafx 客户端

java - 与 python psycopg2 相比,使用 clojure jdbc 将文件记录插入 postgres db 需要很长时间

jdbc - 在哪里可以下载与 JDK 1.5 兼容的 DB2 JDBC 驱动程序?

java - 普通 Spring Batch 示例中非作业方法的 Bean 注释的目的

java - Spring PropertyPlaceholderConfigurer 不注入(inject)值

java - SCM 管理器 REST POST xml 返回 415 不支持的媒体类型

java - 如何更改 Android 中 Exoplayer 中的音轨

java - 如何进一步验证 Java 中的 jTextBox 以允许点和逗号?

java - 在 Spring Boot 中使用自定义代码进行响应