如何在Tomcat中实现Java应用SQL Server长时查询自动超时？

Tomcat的常规超时配置（如HTTP连接超时、异步请求超时）无法直接终止后台执行的SQL查询——这些配置仅控制Tomcat对HTTP请求的响应超时逻辑（比如停止等待响应返回给客户端），但数据库端的SQL查询仍会继续执行，无法达到终止查询、释放数据库资源的目的。

要实现SQL查询超时自动终止，需从JDBC/数据库层面入手，结合应用代码或框架配置来控制，以下是具体方案：

1. 直接通过JDBC API设置查询超时 #

在创建Statement或PreparedStatement时，调用setQueryTimeout()方法，单位为秒（比如设置2分钟超时就是120秒）：

// 示例：JDBC原生代码设置查询超时
Connection conn = ...; // 获取数据库连接
String sql = "SELECT * FROM large_table WHERE ...";
PreparedStatement stmt = conn.prepareStatement(sql);
stmt.setQueryTimeout(120); // 设置2分钟超时
ResultSet rs = stmt.executeQuery();
// 后续处理结果集

当查询执行时间超过设定值时，JDBC会抛出SQLTimeoutException，同时数据库会终止该查询进程。

2. 基于持久化框架配置超时 #

如果使用MyBatis、Spring等框架，可通过框架配置统一设置超时：

MyBatis #

在mybatis-config.xml中全局设置默认查询超时：

<settings>
  <!-- 设置默认查询超时为2分钟（120秒） -->
  <setting name="defaultStatementTimeout" value="120"/>
</settings>

也可在单个Mapper的SQL语句上单独设置：

<select id="queryLargeData" timeout="120">
  SELECT * FROM large_table WHERE ...
</select>

Spring（JdbcTemplate/Transactional） #

• 使用JdbcTemplate时，可设置查询超时：

JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.setQueryTimeout(120); // 设置2分钟超时
List<Map<String, Object>> result = jdbcTemplate.queryForList(sql);

• 基于声明式事务设置超时（注意：事务超时是整个事务的执行超时，包含其中的所有SQL操作）：

@Transactional(timeout = 120) // 2分钟超时
public List<Data> queryLargeData() {
  return jdbcTemplate.queryForList("SELECT * FROM large_table WHERE ...");
}

3. 结合Tomcat异步请求的补充处理（可选） #

如果你的请求是异步处理的（比如Servlet 3.0+的AsyncContext），可以在Tomcat中配置异步超时，同时在超时回调中手动中断SQL执行线程：

1. 在web.xml或Tomcat的context.xml中配置全局异步超时：

<!-- web.xml中配置全局异步超时 -->
<web-app>
  <async-supported>true</async-supported>
  <session-config>
    <async-timeout>120</async-timeout> <!-- 2分钟 -->
  </session-config>
</web-app>

2. 在Servlet代码中处理异步超时回调：

protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  AsyncContext asyncCtx = req.startAsync();
  asyncCtx.setTimeout(120000); // 2分钟，单位毫秒
  asyncCtx.addListener(new AsyncListener() {
    @Override
    public void onTimeout(AsyncEvent event) throws IOException {
      // 获取执行SQL的线程并中断（需确保线程可被中断）
      Thread sqlThread = (Thread) event.getAsyncContext().getAttribute("sqlThread");
      if (sqlThread != null) {
        sqlThread.interrupt();
      }
      event.getAsyncContext().complete();
    }
    // 实现其他AsyncListener方法
    @Override public void onStartAsync(AsyncEvent event) {}
    @Override public void onError(AsyncEvent event) {}
    @Override public void onComplete(AsyncEvent event) {}
  });

  // 启动线程执行SQL
  Thread sqlThread = new Thread(() -> {
    try {
      // 执行SQL查询逻辑（需确保JDBC已设置queryTimeout）
      executeLongRunningQuery();
      asyncCtx.dispatch("/result.jsp");
    } catch (Exception e) {
      asyncCtx.setError(e);
    }
  });
  asyncCtx.setAttribute("sqlThread", sqlThread);
  sqlThread.start();
}

这种方式需配合JDBC的setQueryTimeout使用，因为线程中断本身无法直接终止JDBC查询，setQueryTimeout内部会利用线程中断机制来触发数据库终止查询。

内容的提问来源于stack exchange，提问作者Gourav