稳，从数据库连接池 testOnBorrow 看架构设计

左晓平

本文从 Commons DBCP testOnBorrow 的作用机制着手，管中窥豹，从一点去分析数据库连接池获取的过程以及架构分层设计。
以下内容会按照每层的作用，贯穿分析整个调用流程。
1️⃣框架层 commons-pool

The indication of whether objects will be validated before being borrowed from the pool.
If the object fails to validate, it will be dropped from the pool, and we will attempt to borrow another.
testOnBorrow 不是 dbcp 定义的，是commons-pool 定义的。commons-pool 详细的定义了资源池使用的一套规范和运行流程。

1. /**
2. * Borrow an object from the pool. get object from 资源池
3. * @see org.apache.commons.pool2.impl.GenericObjectPool#borrowObject(long)
4. */
5. public T borrowObject(final long borrowMaxWaitMillis) throws Exception {
6.        
7.         PooledObject<T> p = null;
8.        
9.     // if validation fails, the instance is destroyed and the next available instance is examined.
10.     // This continues until either a valid instance is returned or there are no more idle instances available.
11.         while (p == null) {
12.         // If there is one or more idle instance available in the pool,
13.         // then an idle instance will be selected based on the value of getLifo(), activated and returned.
14.                 p = idleObjects.pollFirst();
15.                 if (p != null) {
16.             // 设置 testOnBorrow 就会进行可用性校验
17.                         if (p != null && (getTestOnBorrow() || create && getTestOnCreate())) {
18.                                 boolean validate = false;
19.                                 Throwable validationThrowable = null;
20.                                 try {
21.                     // 具体的校验实现由实现类完成。
22.                     // see org.apache.commons.dbcp2.PoolableConnectionFactory
23.                                         validate = factory.validateObject(p);
24.                                 } catch (final Throwable t) {
25.                                         PoolUtils.checkRethrow(t);
26.                                         validationThrowable = t;
27.                                 }
28.                                 if (!validate) {
29.                                         try {
30.                         // 如果校验异常，会销毁该资源。
31.                         // obj is not valid and should be dropped from the pool
32.                                                 destroy(p);
33.                                                 destroyedByBorrowValidationCount.incrementAndGet();
34.                                         } catch (final Exception e) {
35.                                                 // Ignore - validation failure is more important
36.                                         }
37.                                         p = null;
38.                                 }
39.                         }
40.                 }
41.         }
43.         return p.getObject();
44. }

复制代码

2️⃣应用层 commons-dbcp

dbcp 是特定于管理数据库连接的资源池。
PoolableConnectionFactory is a PooledObjectFactory
PoolableConnection is a PooledObject

1. /**
2. * @see PoolableConnectionFactory#validateObject(PooledObject)
3. */
4. @Override
5. public boolean validateObject(final PooledObject<PoolableConnection> p) {
6.         try {
7.                 /**
8.                  * 检测资源池对象的创建时间，是否超过生存时间
9.                  * 如果超过 maxConnLifetimeMillis, 不再委托数据库连接进行校验，直接废弃改资源
10.                  * @see PoolableConnectionFactory#setMaxConnLifetimeMillis(long)
11.                  */
12.                 validateLifetime(p);
13.                 // 委托数据库连接进行自我校验
14.                 validateConnection(p.getObject());
15.                 return true;
16.         } catch (final Exception e) {
17.                 return false;
18.         }
19. }
21. /**
22. * 数据库连接层的校验。具体到是否已关闭、是否与 server 连接可用
23. * @see Connection#isValid(int)
24. */
25. public void validateConnection(final PoolableConnection conn) throws SQLException {
26.         if(conn.isClosed()) {
27.                 throw new SQLException("validateConnection: connection closed");
28.         }
29.         conn.validate(_validationQuery, _validationQueryTimeout);
30. }

复制代码

3️⃣基础层 mysql-connector-java

Returns true if the connection has not been closed and is still valid.
这个是 java.sql.Connection 定义的规范。具体实现根据对应数据库的driver 来完成。使用某种机制用来探测连接是否可用。
[code]/** * 调用 com.mysql.jdbc.MysqlIO， 发送ping 请求，检测是否可用 * 对比 H2 数据库，是通过获取当前事务级别来检测连接是否可以。但是忽略了 timeout 配置，毕竟是 demo 数据库
来源:https://www.cnblogs.com/Jcloud/p/17496579.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！