插件窝 干货文章 Mysql中的超时时间设置方式

Mysql中的超时时间设置方式

超时 java 设置 mysql 401    来源:    2024-10-16

1、建立数据库连接超时设置

jdbc:mysql://localhost:3306/gjm?connectTimeout=3000

  • connectTimeout:表示的是数据库驱动(mysql-connector-java) 与 mysql服务器建立TCP连接的超时时间。属于TCP层面的超时。

假设正常与数据建立连接需要3ms,我们可以通过设置 connectTimeout=1ms 来模拟。

将会出现如下错误:

com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failureThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.    
  at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)    
  at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)    
  ...
Caused by: java.net.SocketTimeoutException: connect timed out    
  at java.net.PlainSocketImpl.socketConnect(Native Method)    
  at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)    
  ...

当抛出异常后,调用 conn.isClosed() 返回 true。 

2、socket 读取超时设置

jdbc:mysql://localhost:3306/gjm?connectTimeout=1000&socketTimeout=60000

  • socketTimeout:是通过TCP连接发送数据(要执行的sql)后,等待响应的超时时间。属于TCP层面的超时。

我们可以通过在查询中设置 sleep(n) 来进行模拟。

将会出现如下错误:

Last packet sent to the server was 60000 ms ago.
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:406)
    at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1074)
    at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2985)
    at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2871)
    at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3414)
    at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1936)
    at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2060)
    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2536)
    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2465)
    at com.mysql.jdbc.StatementImpl.executeQuery(StatementImpl.java:1383)
    ...
Caused by: java.net.SocketTimeoutException: Read timed out
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
    at java.net.SocketInputStream.read(SocketInputStream.java:171)
    at java.net.SocketInputStream.read(SocketInputStream.java:141)
    at com.mysql.jdbc.util.ReadAheadInputStream.fill(ReadAheadInputStream.java:113)
    at com.mysql.jdbc.util.ReadAheadInputStream.readFromUnderlyingStreamIfNecessary(ReadAheadInputStream.java:160)
    at com.mysql.jdbc.util.ReadAheadInputStream.read(ReadAheadInputStream.java:188)
    at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:2428)
    at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2882)
    ... 9 more

当抛出异常后,调用 conn.isClosed() 返回 true。 

3、单个 sql 执行超时设置

Connection conn = datasource.getConnection();
PreparedStatement ps = conn.prepareStatement("select sleep(5)"); // 设置服务端休眠5秒再返回
ps.setQueryTimeout(1); // 设置语句执行超时时间为1秒

将出现如下错误:

com.mysql.jdbc.exceptions.MySQLTimeoutException: Statement cancelled due to timeout or client request
  at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1881)    
  at com.mysql.jdbc.PreparedStatement.executeQuery(PreparedStatement.java:1962)    
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)    
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)    
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)    
  at java.lang.reflect.Method.invoke(Method.java:498)    
  at org.apache.tomcat.jdbc.pool.StatementFacade$StatementProxy.invoke(StatementFacade.java:114)    
  at com.sun.proxy.$Proxy6.executeQuery(Unknown Source)    
  ...

通过提示信息,可以看到 "Statement cancelled due to timeout or client request",表示 sql 由于执行超时而被取消了。

通过statement timeout,我们可以更加灵活的为不同的sql设置不同的超时时间。

但是,需要注意的是,尽管statement timeout很灵活,但是在高并发的情况下,会创建大量的线程,一些场景下笔者并不建议使用。

原因在于,mysql-connector-java底层是通过定时器Timer来实现statement timeout的功能,也就是说,对于设置了statement timeout的sql,将会导致mysql创建定时Timer来执行sql,意味着高并发的情况下,mysql驱动可能会创建大量线程。

通过源码可以看到,在指定statement timeout的情况下,mysql内部会将sql执行操作包装成一个CancelTask,然后通过定时器Timer来运行。

Timer实际上是与ConnectionImpl绑定的,同一个ConnectionImpl执行的多个sql,会共用这个Timer。

默认情况下,这个Timer是不会创建的,一旦某个ConnectionImpl上执行的一个sql,指定了statement timeout,此时这个Timer才创建,一直到这个ConnectionImpl被销毁时,Timer才会取消。

在一些场景下,如分库分表、读写分离,如果使用的数据库中间件是基于smart-client方式实现的,会与很多库建立连接,由于其底层最终也是通过mysql-connector-java创建连接,这种场景下,如果指定了statement timeout,那么应用中将会存在大量的Timer线程,在这种场景下,并不建议设置。

最后,需要提醒的是,socket timeout是TCP层面的超时,是操作系统层面进行的控制,statement timeout是驱动层面实现的超时,是应用层面进行的控制,如果同时设置了二者,那么后者必须比前者大,否则statement timeout无法生效。

当抛出异常后,调用 conn.isClosed() 返回 false。 

4、事务执行超时设置

前面提到的的socket timeout、statement timeout,都是限制单个sql的最大执行超时。

在事务的情况下,可能需要执行多个sql,我们想针对整个事务设置一个最大的超时时间。

例如,我们在采用spring配置事务管理器的时候,可以指定一个defaultTimeout属性,单位是秒,指定所有事务的默认超时时间。

在 spring 中,通过在 @Transactional 注解上针对某个事务,指定超时时间,如:

@Transactional(timeout = 3)

transaction timeout的实现原理可以用以下流程进行描述,假设事务超时为5秒,需要执行3个sql:

 start transaction  
 #事务超时为5秒
 
 sql1  
 #statement timeout设置为5秒
 #执行耗时1s,那么整个事务超时还剩4秒
 
 sql2
 #设置statement timeout设置为4秒
 #执行耗时2秒,整个事务超时还是2秒
 
 sql3  
 #设置statement timeout设置为2秒
 #假设执行耗时超过2s,那么整个事务超时,抛出异常  

这里只是一个简化的流程,但是可以帮助我们了解spring事务超时的原理。

从这个流程中,我们可以看到,spring事务的超时机制,实际上是还是通过Statement.setQueryTimeout进行设置,每次都是把当前事务的剩余时间,设置到下一个要执行的sql中。

事实上,spring的事务超时机制,需要ORM框架进行支持,例如mybatis-spring提供了一个SpringManagedTransaction,里面有一个getTimeout方法,就是通过从spring中获取事务的剩余时间。

当抛出异常后,调用 conn.isClosed() 返回 false。 

总结

以上为个人经验,希望对您有所帮助。