Tomcat jdbc pool - Tomcat 7 新的数据库连接池使用教程
fmms
13年前
<p>Tomcat 在 7.0 以前的版本都是使用 commons-dbcp 做为连接池的实现,但是 dbcp 饱受诟病,原因有:</p> <ol> <li>dbcp 是单线程的,为了保证线程安全会锁整个连接池</li> <li>dbcp 性能不佳</li> <li>dbcp 太复杂,超过 60 个类</li> <li>dbcp 使用静态接口,在 JDK 1.6 编译有问题</li> <li>dbcp 发展滞后</li> </ol> <p>因此很多人会选择一些第三方的连接池组件,例如 c3p0 , bonecp, druid (<span class="referer">@wenshao</span> ) 等。</p> <p>为此,Tomcat 从 7.0 开始引入一个新的模块:Tomcat jdbc pool</p> <ol> <li>tomcat jdbc pool 近乎兼容 dbcp ,性能更高</li> <li>异步方式获取连接</li> <li>tomcat jdbc pool 是 tomcat 的一个模块,基于 tomcat JULI,使用 Tomcat 的日志框架</li> <li>使用 javax.sql.PooledConnection 接口获取连接</li> <li>支持高并发应用环境</li> <li>超简单,核心文件只有8个,比 c3p0 还</li> <li>更好的空闲连接处理机制</li> <li>支持 JMX</li> <li>支持 XA Connection</li> </ol> <p>tomcat jdbc pool 的优点远不止这些,详情请看<a href="/misc/goto?guid=4959517510070720458" rel="nofollow" target="_blank">这里</a>。</p> <p>tomcat jdbc pool 可在 Tomcat 中直接使用,也可以在独立的应用中使用。</p> <p>Tomcat 中直接使用的方法:</p> <p>数据源配置:</p> <pre class="brush:xml; toolbar: true; auto-links: false;"><Resource name="jdbc/TestDB" auth="Container" type="javax.sql.DataSource" factory="org.apache.tomcat.jdbc.pool.DataSourceFactory" testWhileIdle="true" testOnBorrow="true" testOnReturn="false" validationQuery="SELECT 1" validationInterval="30000" timeBetweenEvictionRunsMillis="30000" maxActive="100" minIdle="10" maxWait="10000" initialSize="10" removeAbandonedTimeout="60" removeAbandoned="true" logAbandoned="true" minEvictableIdleTimeMillis="30000" jmxEnabled="true" jdbcInterceptors= "org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer" username="root" password="password" driverClassName="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost:3306/mysql"/></pre> <p>异步获取连接的方法:</p> <pre class="brush:java; toolbar: true; auto-links: false;">Connection con = null; try { Future<Connection> future = datasource.getConnectionAsync(); while (!future.isDone()) { System.out.println("Connection is not yet available. Do some background work"); try { Thread.sleep(100); //simulate work }catch (InterruptedException x) { Thread.currentThread().interrupted(); } } con = future.get(); //should return instantly Statement st = con.createStatement(); ResultSet rs = st.executeQuery("select * from user");</pre> <p>在独立的应用中使用:</p> <pre class="brush:java; toolbar: true; auto-links: false;">import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import org.apache.tomcat.jdbc.pool.DataSource; import org.apache.tomcat.jdbc.pool.PoolProperties; public class SimplePOJOExample { public static void main(String[] args) throws Exception { PoolProperties p = new PoolProperties(); p.setUrl("jdbc:mysql://localhost:3306/mysql"); p.setDriverClassName("com.mysql.jdbc.Driver"); p.setUsername("root"); p.setPassword("password"); p.setJmxEnabled(true); p.setTestWhileIdle(false); p.setTestOnBorrow(true); p.setValidationQuery("SELECT 1"); p.setTestOnReturn(false); p.setValidationInterval(30000); p.setTimeBetweenEvictionRunsMillis(30000); p.setMaxActive(100); p.setInitialSize(10); p.setMaxWait(10000); p.setRemoveAbandonedTimeout(60); p.setMinEvictableIdleTimeMillis(30000); p.setMinIdle(10); p.setLogAbandoned(true); p.setRemoveAbandoned(true); p.setJdbcInterceptors("org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;"+ "org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer"); DataSource datasource = new DataSource(); datasource.setPoolProperties(p); Connection con = null; try { con = datasource.getConnection(); Statement st = con.createStatement(); ResultSet rs = st.executeQuery("select * from user"); int cnt = 1; while (rs.next()) { System.out.println((cnt++)+". Host:" +rs.getString("Host")+ " User:"+rs.getString("User")+" Password:"+rs.getString("Password")); } rs.close(); st.close(); } finally { if (con!=null) try {con.close();}catch (Exception ignore) {} } } }</pre> <p>以上只是简单的介绍,具体的使用方法还需参考:</p> <p><a href="/misc/goto?guid=4959517510070720458" rel="nofollow" target="_blank">https://tomcat.apache.org/tomcat-7.0-doc/jdbc-pool.html</a></p>