博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
连接池并发的实现原理
阅读量:6541 次
发布时间:2019-06-24

本文共 2302 字,大约阅读时间需要 7 分钟。


1 . 概述和说明 在数据库操作中,和数据库建立连接(Connection)是最为耗时的操作之一,而且数据库都有最大连接数目的限制,
如何很多用户访问的是同一数据库,所进行的都是相同的操作,比如查询记录,那么,为每个用户都建立一个连接是不合理的 连接池的思想:Tomcat服务器可以事先预备好若干个连接对象,
将这些连接对象存放在一个称为连接池的容器中(通常由链表承担这一角色)当某用户需要操作数据库时,
只要从连接池中取出一个连接对象即可,当用户使用完改连接对象后,将该连接对象放回到连接池中,
如果某用户需要操作数据库时,连接池中已没有连接对象可用,那么该用户就必须等待,
直到连接池中有了连接对象为止。 例:WebLogic,WebSphere 连接池和数据源都是由自己操作管理
2 . 案例 IBM项目在读写MQ消息队列中,用的是此思想 3 . 程序的调用注释和配置文件的说明
 
package database.operation; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.LinkedList; public class ApplicationCon { private static ApplicationCon manager = new ApplicationCon(); private static LinkedList
list;// 存放Connection 对象的链表 private static final int MAX = 10;// 最大连接数 public static String DRIVERNAME = "com.newatlanta.jturbo.driver.Driver" public static String URL = "jdbc:JTurbo://127.0.0.1/DBA/charset=GBK" public static String UID = "sa" public static String PWD = "" private Connection con = null //单例模式 public static ApplicationCon getInstance() { return manager } public ApplicationCon() { try { Class.forName(DRIVERNAME); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } listnew LinkedList
(); for (int i = 0; i <= MAX; i++) { try { con = DriverManager.getConnection(URL , UID , PWD ); list.add(con); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } //单线程,当前线程没有结束,其他线程处于等待 public synchronized Connection getOneConnection() { if (list.size() > 0) return list.removeFirst();// 链表删除第一个节点,并返回该节点中的连接对象; else return null } //单线程,当前线程没有结束,其他线程处于等待 public synchronized void puBackOneConnection(Connection con) { list.addFirst(con); } /** * 该方法执行增,删,改操作 */ public void executeUpdate(String strSql) throws SQLException { Statement stat = con.createStatement(); stat.executeUpdate(strSql); } /** * 该方法执行查询操作,并返回结果集 */ public ResultSet executeQuerry(String strSql) throws SQLException { Statement stat = con.createStatement(); return stat.executeQuery(strSql); }
4 . 如何调用
/** * 调用规则:ApplicationCon m =ApplicationCon.getInstance(); * Connection connection =m.getOneConnection(); * 执行增删改查操作 * m.puBackOneConnection(connection); */

转载于:https://www.cnblogs.com/shiGuangShiYi/p/10117544.html

你可能感兴趣的文章
Silverlight 游戏开发小技巧:技能冷却效果2(Cool“.NET研究”down)2
查看>>
Mysql的优化一则
查看>>
An Introduction to Asynchronous Programming and Twisted (2)
查看>>
vue 组件编码规范
查看>>
IEC61850与MMS的服务映射
查看>>
我的友情链接
查看>>
Java 泛型: 什么是PECS(Producer Extends, Consumer Super)
查看>>
软件包管理-打包解包压缩解压
查看>>
maven构建scala项目
查看>>
linux 高级编程看的书
查看>>
Memcached分布式缓存-windows上初步使用-网摘
查看>>
IIS无法启动的问题
查看>>
如何通过结构中的某个变量获取结构本身的指针?(container_of详解)
查看>>
Android 关于mnt/sdcard和sdcard的区别
查看>>
特征变换(7)总结
查看>>
网络工程师之路怎么走?
查看>>
go语言unix域套接字发送udp报文
查看>>
2.并发和并行
查看>>
OpenGL学习(二)用户与交互
查看>>
神奇的代码-常见错误代码注意点
查看>>