（三）以jdbc步骤来分析atomikos 源码-获取连接

com.atomikos.jdbc.AbstractDataSourceBean#getConnection()

public Connection getConnection() throws SQLException {if (LOGGER.isDebugEnabled()) {LOGGER.logDebug(this + ": getConnection()...");}Connection connection = null;this.init();try {//比较关键的一行代码，调用的com.atomikos.datasource.pool.ConnectionPoolWithSynchronizedValidation方法//该方法最终拿到的就是AtomikosConnectionProxyconnection = (Connection)this.connectionPool.borrowConnection();} catch (CreateConnectionException var3) {this.throwAtomikosSQLException("Failed to grow the connection pool", var3);} catch (PoolExhaustedException var4) {this.throwAtomikosSQLException("Connection pool exhausted - try increasing 'maxPoolSize' and/or 'borrowConnectionTimeout' on the DataSourceBean.");} catch (ConnectionPoolException var5) {this.throwAtomikosSQLException("Error borrowing connection", var5);}if (LOGGER.isTraceEnabled()) {LOGGER.logTrace(this + ": returning " + connection);}return connection;}

AtomikosConnectionProxy类分析

com.atomikos.jdbc.AtomikosConnectionProxy#invoke

public Object invoke(Object proxy, Method method, Object[] args) throws SQLException {String methodName = method.getName();if (methodName.equals("getInvocationHandler")) {return this;} else if (methodName.equals("reap")) {if (LOGGER.isDebugEnabled()) {LOGGER.logDebug(this + ": reaping pending connection...");}this.reap();if (LOGGER.isTraceEnabled()) {LOGGER.logTrace(this + ": reap done!");}return null;} else if (methodName.equals("isClosed")) {if (LOGGER.isDebugEnabled()) {LOGGER.logDebug(this + ": isClosed()...");}Object ret = this.closed;if (LOGGER.isTraceEnabled()) {LOGGER.logTrace(this + ": isClosed() returning " + ret);}return ret;} else if (this.closed && !this.methodAllowedAfterClose(method)) {String msg;if (this.reaped) {msg = "Connection has been reaped - calling " + methodName + " is no longer allowed! Increase reapTimeout to avoid this problem.";AtomikosSQLException.throwAtomikosSQLException(msg);} else {msg = "Connection was already closed - calling " + methodName + " is no longer allowed!";AtomikosSQLException.throwAtomikosSQLException(msg);}return null;} else {//在这里，获取连接时，第一步会走这里，这一步会去根据当前线程创建CompositeTransaction放到本地线程里面if (this.isEnlistedInGlobalTransaction()) {if (XA_INCOMPATIBLE_METHODS.contains(methodName)) {AtomikosSQLException.throwAtomikosSQLException("Cannot call method '" + methodName + "' while a global transaction is running");}if (methodName.equals("setAutoCommit") && args[0].equals(Boolean.TRUE)) {AtomikosSQLException.throwAtomikosSQLException("Cannot call 'setAutoCommit(true)' while a global transaction is running");}if (methodName.equals("getAutoCommit")) {return Boolean.FALSE;}}if (ENLISTMENT_METHODS.contains(methodName)) {try {this.enlist();} catch (Exception var8) {this.sessionHandleState.notifySessionErrorOccurred();JdbcConnectionProxyHelper.convertProxyError(var8, "Error enlisting in transaction - connection might be broken? Please check the logs for more information...");}}Object ret = null;if (CLOSE_METHODS.contains(methodName) && args == null) {this.close();return null;} else {try {if (LOGGER.isDebugEnabled()) {LOGGER.logDebug(this + ": calling " + this.formatCallDetails(method, args) + "...");}//com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl去创建一个连接返回ret = method.invoke(this.delegate, args);} catch (Exception var7) {this.sessionHandleState.notifySessionErrorOccurred();JdbcConnectionProxyHelper.convertProxyError(var7, "Error delegating '" + methodName + "' call");}if (LOGGER.isTraceEnabled()) {LOGGER.logTrace(this + ": " + methodName + " returning " + ret);}if (ret instanceof Statement) {Statement s = (Statement)ret;this.addStatement(s);}return ret;}}}

（三）以jdbc步骤来分析atomikos 源码-获取连接相关推荐

Linux内核 eBPF基础：kprobe原理源码分析：源码分析
Linux内核 eBPF基础 kprobe原理源码分析:源码分析荣涛 2021年5月11日在 <Linux内核 eBPF基础:kprobe原理源码分析:基本介绍与使用>中已经介绍了kp ...
struts2 处理请求流程分析(结合源码)1- 孤星随缘ツ http://t.sina.com.cn/samzhxing-iteye技术网站...
struts2 处理请求流程分析(结合源码)1- 孤星随缘ツ http://t.sina.com.cn/samzhxing-iteye技术网站 2011年08月01日 struts2 源码版本2.0. ...
【Android 热修复】热修复原理 ( 类加载分析 | 分析 PathClassLoader 源码 | 分析 BaseDexClassLoader 源码 | 分析 PathDexList 源码 )
文章目录一.分析 PathClassLoader 源码二.分析 BaseDexClassLoader 源码三.分析 PathDexList 源码四. 源码资源一.分析 PathClassLo ...
【Android 电量优化】JobScheduler 源码分析 ( JobServiceContext 源码分析 | 闭环操作总结 | 用户提交任务 | 广播接收者接受相关广播触发任务执行 )★
文章目录一.JobServiceContext 引入二.JobServiceContext 源码分析三.用户在应用层如何使用 JobScheduler 四.用户提交任务五.广播接收者监听广播触 ...
python爬取天气预报源代码_python抓取天气并分析实例源码
[实例简介] Python代码抓取获取天气预报信息源码讲解.这是一个用Python编写抓取天气预报的代码示例,用python写天气查询软件程序很简单.这段代码可以获取当地的天气和.任意城市的天气预报, ...
C语言阿拉伯数字转换为汉语大写数字金额程序分析及源码
C语言阿拉伯数字转换为汉语大写数字金额程序分析及源码数据结构:用一个整型变量储存输入数字大家可能会感觉用字符串取位更方便一些·· 但是相应的,字符串失去了数字原有的意思 00100和100对 ...
Android 事件分发机制分析及源码详解
Android 事件分发机制分析及源码详解文章目录 Android 事件分发机制分析及源码详解事件的定义事件分发序列模型分发序列分发模型事件分发对象及相关方法源码分析事件分发总结一般 ...
如何快速阅读并分析Android源码
很多时候为了解决一个问题必须先理解Android系统的运行原理,这时候就得阅读应用层框架的源码.学会阅读系统源码或者他人的代码,这是研发必备的技能之一,只有了解别人写的东西才能在他之上更好的行事,同时 ...
k8s client-go源码分析 informer源码分析(3)-Reflector源码分析
k8s client-go源码分析 informer源码分析(3)-Reflector源码分析 1.Reflector概述 Reflector从kube-apiserver中list&watc ...

（三）以jdbc步骤来分析atomikos 源码-获取连接

（三）以jdbc步骤来分析atomikos 源码-获取连接相关推荐

最新文章

热门文章