boneCP原理研究.doc

boneCP原理研究 boneCP是一款关注高性能的数据库连接池产品 github主页 。 不过最近作者好像没有心思更新了，因为他发现了一款更快的连接池产品，但是这不影响我学习它。 连接的生存时间 MySQL有一个重要的参数wait_timeout，用于规定一个connection最大的idle时间，默认是28800秒，即每个connection连续的sleep状态不能超过该值，否则MySQL会自动回收该connection。 连接池的作用是管理连接，任何想要请求数据库连接的行为都和连接池发生交互，从连接池里申请连接，使用完成后将连接交还给连接池。 在一个比较空闲的系统上，连接可能长时间的处于sleep状态，那么一旦达到了MySQL wait_timeout的规定时间，MySQL就要回收连接，这时连接池如果仍然认为该connection可用，待应用向连接池请求时，就会将不存在的connection资源交给应用，这样就会报错。 因此连接池需要一套机制保证每一个connection在连接池生存期内是始终可用的。 我推测应该有两种机制：定期检测和申请时检测。 boneCP采用定期检测机制，即每隔一个时间间隔就会检查其管理的连接处于sleep状态的时间，如果超过了设定的值，则会将此connection重建。 boneCP中有两个很重要的参数：idleConnectionTestPeriodInSeconds和idleMaxAgeInSeconds，分别是连接探测时间阈值和连接最大空闲时间，默认值为4小时和1小时。 boneCP会启动三个线程来进行定期任务： this.keepAliveScheduler = Executors.newScheduledThreadPool(this.config.getPartitionCount(), new CustomThreadFactory(BoneCP-keep-alive-scheduler+suffix, true)); this.maxAliveScheduler = Executors.newScheduledThreadPool(this.config.getPartitionCount(), new CustomThreadFactory(BoneCP-max-alive-scheduler+suffix, true)); this.connectionsScheduler = Executors.newFixedThreadPool(this.config.getPartitionCount(), new CustomThreadFactory(BoneCP-pool-watch-thread+suffix, true)); 其中keepAliveScheduler用来每隔一段时间检查connection的sleep状态时间是否达到了idleMaxAgeInSeconds或者是否已经失效，如果是，则会将连接kill掉，主要的逻辑见ConnectionTesterThread.java。 需要注意的是，在默认的配置下，该检查的调度是这样定义的： this.keepAliveScheduler.scheduleAtFixedRate(connectionTester,delayInSeconds, delayInSeconds, TimeUnit.SECONDS); 此时delayInSeconds的值是取idleMaxAgeInSeconds值，即1小时，实际上只要idleMaxAgeInSeconds小于idleConnectionTestPeriodInSeconds，则delayInSeconds一定是idleMaxAgeInSeconds。这样，该线程每1小时就会启动一次，同时要检查时间阈值就会变成1小时。 keepalive线程要执行的命令是这样的： final Runnable connectionTester = new ConnectionTesterThread(connectionPartition, this, this.config.getIdleMaxAge(TimeUnit.MILLISECONDS), this.config.getIdleConnectionTestPeriod(TimeUnit.MILLISECONDS), queueLIFO); 下面是对ConnectionTesterThread类的解析： protected ConnectionTesterThread(ConnectionPartition connectionPartition, BoneCP pool, long idleMaxA