java线程中使用mysql连接查询数据库不建议这样做,一般不符合开发规范 , 如果这样的话 , 你想想在业务量多的情况下,多个线程如果不控制,数据库连接会将数据库服务器爆掉的,会影响业务的
常规做法:数据库连接池(durid了解一下),据某些统计哈,真正用来做查询的资源不超过整个查询数据库的生命周期的30% , 大部分时间都用开创建连接关闭连接等操作,如果这个时候建立数据库连接池的话,可以有效的将这部分时间释放掉
MySQL与Redis数据库连接池介绍(图示 源码 代码演示) 数据库连接池(Connection pooling)是程序启动时建立足够的数据库连接,并将这些连接组成一个连接池,由程序动态地对池中的连接进行申请,使用,释放 。
简单的说:创建数据库连接是一个很耗时的操作,也容易对数据库造成安全隐患 。所以,在程序初始化的时候,集中创建多个数据库连接 , 并把他们集中管理,供程序使用 , 可以保证较快的数据库读写速度,还更加安全可靠 。
不使用数据库连接池
如果不使用数据库连接池,对于每一次SQL操作,都要走一遍下面完整的流程:
1.TCP建立连接的三次握手(客户端与 MySQL服务器的连接基于TCP协议)
2.MySQL认证的三次我收
3.真正的SQL执行
4.MySQL的关闭
5.TCP的四次握手关闭
可以看出来,为了执行一条SQL,需要进行大量的初始化与关闭操作
使用数据库连接池
如果使用数据库连接池,那么会事先申请(初始化)好相关的数据库连接,然后在之后的SQL操作中会复用这些数据库连接,操作结束之后数据库也不会断开连接,而是将数据库对象放回到数据库连接池中
资源重用:由于数据库连接得到重用,避免了频繁的创建、释放连接引起的性能开销,在减少系统消耗的基础上,另一方面也增进了系统运行环境的平稳性(减少内存碎片以及数据库临时进程/线程的数量) 。
更快的系统响应速度:数据库连接池在初始化过程中 , 往往已经创建了若干数据库连接置于池中备用 。此时连接的初始化工作均已完成 。对于业务请求处理而言,直接利用现有可用连接 , 避免了从数据库连接初始化和释放过程的开销,从而缩减了系统整体响应时间 。
统一的连接管理,避免数据库连接泄露:在较为完备的数据库连接池实现中 , 可根据预先的连接占用超时设定,强制收回被占用连接 。从而避免了常规数据库连接操作中可能出现的资源泄露 。
如果说你的服务器CPU是4核i7的,连接池大小应该为((4*2) 1)=9
相关视频推荐
90分钟搞懂数据库连接池技术|linux后台开发
《tcp/ip详解卷一》: 150行代码拉开协议栈实现的篇章
学习地址:C/CLinux服务器开发/后台架构师【零声教育】-学习视频教程-腾讯课堂
【mysql怎么查询连接池 mysql查看连接池】需要C/CLinux服务器架构师学习资料加qun812855908获?。ㄗ柿习?C/C , Linux,golang技术,Nginx,ZeroMQ,MySQL,Redis,fastdfs,MongoDB , ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK,ffmpeg等),免费分享
源码下载
下载方式:(Github中下载)
db_pool目录下有两个目录,mysql_pool目录为MySQL连接池代码 , redis_pool为redis连接池代码
下面介绍mysql_pool
CDBConn解析
概念:代表一个数据连接对象实例
相关成员:
m_pDBPool:该数据库连接对象所属的数据库连接池
构造函数:绑定自己所属于哪个数据库连接池
Init()函数:创建数据库连接句柄
CDBPool解析
概念:代表一个数据库连接池
相关成员:
Init()函数:常见指定数量的数据库实例句柄,然后添加到m_free_list中,供后面使用
GetDBConn()函数:用于从空闲队列中返回可以使用的数据库连接句柄
RelDBConn()函数:程序使用完该数据库句柄之后,将句柄放回到空闲队列中
测试之前,将代码中的数据库地址、端口、账号密码等改为自己的(代码中有好几处)
进入MySQL,创建mysql_pool_test数据库
进入到mysql_pool目录下 , 创建一个build目录并进入:
然后输入如下的命令进行编译
之后就会在目录下生成如下的可执行文件
输入如下两条命令进行测试:可以看到不使用数据库连接池,整个操作耗时4秒左右;使用连接池之后,整个操作耗时2秒左右 , 提升了一倍
源码下载
下面介绍redis_pool
测试
进入到redis_pool目录下,创建一个build目录并进入:
然后输入如下的命令进行编译
之后就会在目录下生成如下的可执行文件
输入如下的命令进行测试:可以看到不使用数据库连接池 , 整个操作耗时182ms;使用连接池之后,整个操作耗时21ms , 提升了很多
进入redis,可以看到我们新建的key:
如何查看mysql数据库连接池信息1、把数据库驱动包 copy 到 蔜ALINA_HOME%\common\lib 下 。
2、修改 蔜ALINA_HOME%\conf\server.xml 文件,在 Host 节点下添加:
XML/HTML code?
!-- appName 为项目名 --!
Context path="/appName" docBase="appName" auth="Container"
Resource name="jdbc/MySQLDS" scope="Shareable"
type="javax.sql.DataSource"
url="jdbc:mysql://localhost:3306/test?useUnicode=truecharact-erEncoding=GBK"
driverClassName="com.mysql.jdbc.Driver"
username="root" password="111111"
maxWait="3000" maxIdle="100" maxActive="10" /
/Context
(或者在 %appName%\META-INF 下建立 context.xml,内容为上面的代码 。)
3、修改 web.xml,在 web-app 节点下添加:
XML/HTML code?
import java.sql.Connection;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
public class DBUtil {
public Connection getConnection() throws Exception {
Context context = new InitialContext();
// 获取数据源
DataSource ds = (DataSource) context.lookup("java:comp/env/jdbc/MySQLDS");
// 获取数据库连接
Connection conn = ds.getConnection();
if (conn != null!conn.isClosed()) {
return conn;
} else {
return null;
}
}
}
如何判断mysql数据库连接池是否连接如果mysql怎么查询连接池你想在action里判断数据库是否链接mysql怎么查询连接池 , 只能创建一个标记 。全局变量 。比如isConn.当创建链接的时候把这个标记设置为1.关闭数据库的时候标记重置 为0.这样在action里不用获取connection对像mysql怎么查询连接池 , 直接判断这个全局标记就可以了 。
还有就是在创建链接之前先判断这个标记是否是0 。在关闭链接之前判断这个标记是否为1
JSP MYSQL 连接池的配置,高手来QQ***********在线等分类:电脑/网络程序设计其他编程语言
问题描述:
JSP MYSQL 连接池的配置,高手来QQ***********在线等详细哦
解析:
Jboss数据库连接池
wwx 为数据库名
UserInfor为表名
数据库用户名和密码分别为:root root
参考 matrix/translation/Wiki.jsp?page=J2EEEJB_JbossJDBC
(该blog 包括几个主要数据库的连接)
MySQL是一个开放源代码的数据库,有很多开源项目和小型的社团都在使用它 。
一 把mysql-connector-java-3.1.11-bin.jar复制到/server/default/lib目录下,
(需要mysql-connector-java-3.0.16-ga.zip包 将里面的jar文件取出)
二 再把/docs/examples/jca/mysql-ds.xml复制到/server/default/deploy目录下 。修改mysql-ds.xml文件,设置为 .mysql.jdbc.Driver再把设置为jdbc:mysql/,其中是数据库主机名是数据库名 。
例:datasources
local-tx-datasource
jndi-nameMySqlDS/jndi-name
connection-urljdbc:mysqllocalhost:3306/wwx/connection-urlwwx
driver-class.mysql.jdbc.Driver/driver-class
user-nameroot/user-name
passwordroot/password
/local-tx-datasource
/datasources
注意:如果localhost不行 就用127.0.0.1 这个一定没问题!
还有就是如果数据库没有密码!那么就这样password/password
三 然后需要设置standardjaws.xml (或 jaws.xml 注: \server\default\conf目录下)文件的和元素:
jaws
datasourcejava:/MySqlDS/datasource
type-mappingmySql/type-mapping
。。。。。。。
/jaws
四 同样也需要把standardjbosscmp-jdbc.xml (或 jbosscmp-jdbc.xml文件 注: \server\default\conf目录下)的 和 元素设置为下面这样:
jbosscmp-jdbc
defaults
datasourcejava:/MySqlDS/datasource
datasource-mappingmySql/datasource-mapping
/defaults /jbosscmp-jdbc
说明:datasource-mappingmySql/datasource-mapping在我的Jboss里面是被注释掉的,但我把拿回来! 就是把 ----和------ 都删掉!
五 最后再修改login-config.xml(\server\default\conf目录下)文件来使用MySQL:
application-policy name = "MySqlDbRealm"
authentication
login-module code = ".jboss.resource.security.ConfiguredIdentityLoginModule" flag = "required"
module-option name ="principal"wwx/module-option
module-option name ="userName"root/module-option
module-option name ="password"root/module-option
module-option name=managedConnectionFactoryName jboss.jca:service=LocalTxCM,name=MySqlDS
/module-option
/login-module
/authentication
/application-policy
说明:这段代码就直接 copy到login-config.xml里面就ok!不知道往哪放吗?
嘿嘿,就放在policy 下面吧!
还有就是如果数据库没有密码!那么就这样module-option name ="password"/module-option
六 修改了mysql-ds.xml, standardjaws.xml, standardjbosscmp-jdbc.xml,和 login-config.xml 文件就可以在Jboss上使用MySQL了 。
七 调试代码
在jboss-4.0.2/server/default/deploy下 建个文件夹 : test.war
里面test.jsp, 代码如下!
%@pageimport="javax.naming.*"%
%@pageimport="javax.sql.*"%
%@pageimport="java.sql.*"%
%
try {
Context ctx = new InitialContext(); 得到初始化上下文
Object obj = ctx.lookup("java:/MySqlDS");查找连接池
DataSource ds = (DataSource) obj;转换成DataSource
Connection connect = ds.getConnection();从连接池中得到一个连接
Statement stmt = connect.createStatement();
ResultSet rs = stmt.executeQuery("select * from num");这是你的数据库的表噢!
while(rs.next()){
out.println(rs.getObject("NO"));取出一个字段
}
} catch (NamingException e) {
e.printStackTrace();
} catch(SQLException e1){
e1.printStackTrace();
}
out.flush();
out.close();
%
高并发的MySQL数据查询时,会不会选择数据库连接池?现象
Sysbench对MySQL进行压测, 并发数过大(5k)时, Sysbench建立连接的步骤会超时.
猜想
猜想: 直觉上这很简单, Sysbench每建立一个连接, 都要消耗一个线程, 资源消耗过大导致超时.
验证: 修改Sysbench源码, 调大超时时间, 仍然会发生超时.
检查环境
猜想失败, 回到常规的环境检查:
MySQL error log 未见异常.
syslog 未见异常.
tcpdump 观察网络包未见异常, 连接能完成正常的三次握手; 只观察到在出问题的连接中, 有一部分的TCP握手的第一个SYN包发生了重传, 另一部分没有发生重传.
自己写一个简单的并发发生器, 替换sysbench, 可重现场景. 排除sysbench的影响
猜想2
怀疑 MySQL 在应用层因为某种原因, 没有发送握手包, 比如卡在某一个流程上:
检查MySQL堆栈未见异常, 仿佛MySQL在应用层没有看到新连接进入.
通过strace检查MySQL, 发现 accept() 调用确实没有感知到新连接.
怀疑是OS的原因, Google之, 得到参考文档: A TCP “stuck” connection mystery【】
分析
参考文档中的现象跟目前的状况很类似, 简述如下:
正常的TCP连接流程:
Client 向 Server 发起连接请求, 发送SYN.
Server 预留连接资源, 向 Client 回复SYN-ACK.
Client 向 Server 回复ACK.
Server 收到 ACK, 连接建立.
在业务层上, Client和Server间进行通讯.
当发生类似SYN-flood的现象时, TCP连接的流程会使用SYN-cookie, 变为:
Client 向 Server 发起连接请求, 发送SYN.
Server 不预留连接资源, 向 Client 回复SYN-ACK, 包中附带有签名A.
Client 向 Server 回复ACK, 附带 f(签名A) (对签名进行运算的结果).
Server 验证签名, 分配连接资源, 连接建立.
在业务层上, Client和Server间进行通讯.
当启用SYN-cookie时, 第3步的ACK包因为 某种原因 丢失, 那么:
从Client的视角, 连接已经建立.
从Server的视角, 连接并不存在, 既没有建立, 也没有”即将建立” (若不启用SYN-cookie, Server会知道某个连接”即将建立”)
发生这种情况时:
若业务层的第一个包应是从 Client 发往 Server, 则会进行重发或抛出连接错误
若业务层的第一个包应是从 Server 发往 Client的, Server不会发出第一个包. MySQL的故障就属于这种情况.
TCP握手的第三步ACK包为什么丢失
参考文档中, 对于TCP握手的第三步ACK包的丢失原因, 描述为:
Some of these packets get lost because some buffer somewhere overflows.
我们可以通过Systemtap进一步探究原因. 通过一个简单的脚本:
probe kernel.function("cookie_v4_check").return
{
source_port = @cast($skb-head$skb-transport_header, "struct tcphdr")-source
printf("source=%d, return=%d\n",readable_port(source_port), $return)
}
function readable_port(port) {
return (port((19)-1))8 | (port8)
}
观察结果, 可以确认cookie_v4_check (syn cookie机制进行包签名检查的函数)会返回 NULL(0). 即验证是由于syn cookie验证不通过, 导致TCP握手的第三步ACK包不被接受.
之后就是对其中不同条件进行观察, 看看是哪个条件不通过. 最终原因是accept队列满(sk_acceptq_is_full):
static inline bool sk_acceptq_is_full(const struct sock*sk){return sk-sk_ack_backlogsk-sk_max_ack_backlog;}
恢复故障与日志的正关联
在故障处理的一开始, 我们就检查了syslog, 结论是未见异常.
当整个故障分析完成, 得知了故障与syn cookie有关, 回头看syslog, 里面是有相关的信息, 只是和故障发生的时间不匹配, 没有正关联, 因此被忽略.
检查Linux源码:
if (!queue-synflood_warned
sysctl_tcp_syncookies != 2
xchg(queue-synflood_warned, 1) == 0)
pr_info("%s: Possible SYN flooding on port %d. %s.
Check SNMP counters.\n",
proto, ntohs(tcp_hdr(skb)-dest), msg);
可以看到日志受到了抑制, 因此日志与故障的正关联被破坏.
粗看源码, 每个listen socket只会发送一次告警日志, 要获得日志与故障的正关联, 必须每次测试重启MySQL.
解决方案
这种故障一旦形成, 难以检测; 系统日志中只会出现一次, 在下次重启MySQL之前就不会再出现了; Client如果没有合适的超时机制, 万劫不复.
解决方案:
1. 修改MySQL的协议, 让Client先发握手包. 显然不现实.
2. 关闭syn_cookie. 有安全的人又要跳出来了.
3. 或者调高syn_cookie的触发条件 (syn backlog长度). 降低系统对syn flood的敏感度, 使之可以容忍业务的syn波动.
有多个系统参数混合影响syn backlog长度, 参看【】
下图为精华总结
请点击输入图片描述
关于mysql怎么查询连接池和mysql查看连接池的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站 。
推荐阅读
- 爱情正在直播设备,爱情正在直播主题曲
- CPU是什么编码,CPU开票编码
- u盘插电脑上为什么那么烫,u盘插在电脑上为什么会发热
- 直播间视频拍摄技巧,直播怎么拍段子
- c语言数学函数库对数 c语言实现对数运算
- 鸿蒙系统和没有鸿蒙的区别,鸿蒙系统和原来有什么区别
- 关于新建的css样式可以重复使用的信息
- 熊小猫直播录屏怎么录,小熊猫在哪直播
- linux命令改变ip linux变更ip