本文主要是介绍atomikos JTA 源码解读，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
一.DataSource
1.AbstractDataSourceBean 是抽象方法，统一实现了ConnectionPoolProperties接口，及HeuristicDataSource接口，用于设置数据源的属性及进行数据源连接（调用ConnectionPool）
除上面的功能外，他还可以进行数据源连接池的管理，主要的方法有：
intcom.atomikos.jdbc.AbstractDataSourceBean.poolAvailableSize() 连接池中可用（已创建空闲的）的连接数量
intcom.atomikos.jdbc.AbstractDataSourceBean.poolTotalSize() 连接池中总连接数量（正在使用+空闲）
voidcom.atomikos.jdbc.AbstractDataSourceBean.refreshPool() 刷新连接池，会把没有正在使用的连接销毁掉，如果销毁后的连接数小于最小连接池的数量，将新建连接到达到最小数量的要求
AtomikosDataSourceBean 分布式数据源
AtomikosNonXADataSourceBean 非分布式数据源
2.相关属性：对应到美创CRM
<datasource>
<id>default</id>
<driver-class>oracle.jdbc.driver.OracleDriver</driver-class>
<url>jdbc:oracle:thin:@192.168.1.201:1521:orcl</url>
<user>xxx</user>
<password>xxx</password>
<min-pool-size>3</min-pool-size>
<max-pool-size>10</max-pool-size>
<max-lifetime>0</max-lifetime> <!--连接最大存活时间，超过这个且没有正在使用的连接将自动销毁,0无限制，1000 =1000s,对于一些会自动中断连接的数据库如mysql，可以设置这个参数，在达到这个时间的时候会自动关闭连接，下次数据库调用的时候就会新建-->
<borrow-connection-timeout>30</borrow-connection-timeout> <!--获取连接失败重新获等待最大时间，在这个时间内如果有可用连接，将返回-->
<!--default-isolation-level>-1</default-isolation-level-->
<login-timeout>0</login-timeout> <!--java数据库连接池，最大可等待获取datasouce的时间-->
<maintenance-interval>60</maintenance-interval> <!--连接回收时间-->
<max-idle-time>60</max-pool-size> <!--最大闲置时间，超过最小连接池连接的连接将将关闭-->
<reap-timeout>0</reap-timeout> <!--最大获取数据时间，如果不设置这个值，Atomikos使用默认的5分钟，那么在处理大批量数据读取的时候，一旦超过5分钟，就会抛出类似 Resultset is close 的错误.-->
</datasource>
二. com.atomikos.datasource.pool.ConnectionPool 连接池具体实现类
1.voidcom.atomikos.datasource.pool.ConnectionPool.launchMaintenanceTimer()连接池回收处理定时器，会根据maintenanceinterval设置的重复时间进行重复执行，每次执行会：
1)reapPool 是否有超过最大数据获取时间的连接，如果有，这抛出获取时间超时的异常
2)removeConnectionsThatExceededMaxLifetime 删除超过最大生命周期的没有正在使用的连接
3)addConnectionsIfMinPoolSizeNotReached 添加连接数达到最小连接
removeIdleConnectionsIfMinPoolSizeExceeded 删除连接数，如果超过最大连接
2. 获取连接
Reapablecom.atomikos.datasource.pool.ConnectionPool.borrowConnection(HeuristicMessagehmsg) throws CreateConnectionException, PoolExhaustedException,ConnectionPoolException
获取连接的时候首先调用
findExistingOpenConnectionForCallingThread 直接获取连接，如果获取失败将调用
findOrWaitForAnAvailableConnection根据borrowTimeout进行等待，如果在borrowTimeout时间内有连接处于可用（未超过最大连接将创建）将立即返回，否则将抛出异常
Connection pool exhausted - try increasing'maxPoolSize' and/or 'borrowConnectionTimeout' on the DataSourceBean
3.销毁连接
voidcom.atomikos.datasource.pool.ConnectionPool.destroyPooledConnection(XPooledConnectionxpc)
4. voidcom.atomikos.datasource.pool.ConnectionPool.growPool() throws CreateConnectionException
连接不足时创建连接
5. voidcom.atomikos.datasource.pool.ConnectionPool.refresh()
刷新连接池，同AbstractDataSourceBean.refreshPool()
6.intcom.atomikos.datasource.pool.ConnectionPool.availableSize()
可用的连接数
7.intcom.atomikos.datasource.pool.ConnectionPool.totalSize()
总连接数
三、事务超时管理：
com.atomikos.icatch.imp.CoordinatorImp在这个里面会启用的一个定时器，后台管理事务
voidcom.atomikos.icatch.imp.ActiveStateHandler.onTimeout()事务超时的时候会执行这个方法进行回滚
更多atomikos 分析请参考豆蔻网上的文章：http://exception.handlecode.com/share/1038187.html
四、属性加载方法：
五、同一个tomcat 不同的应用需要修改配置，否则出现异常
Caused by: com.atomikos.persistence.LogException: Old file could not be deleted
at com.atomikos.persistence.imp.FileLogStream.writeCheckpoint(FileLogStream.java:168)
... 48 more
解决方法，设置属性：
com.atomikos.icatch.console_file_name = tm_api.out
com.atomikos.icatch.log_base_name = tmlog_api
属性可以是 jta.properties 放置到classpath，或者设置一个环境变量
System.setProperty("com.atomikos.icatch.file", sc.getRealPath("WEB-INF/config/atomikos-jta.properties"));
这篇关于atomikos JTA 源码解读的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
