springboot实现监控Oracle连接数,当连接数超过阈值时,清楚无效会话

要实现监控Oracle连接数，可以通过JDBC连接池来管理连接。Spring Boot默认使用的连接池是HikariCP，它提供了很多监控相关的功能。

首先，需要在application.properties文件中配置连接池的相关参数，如下所示：

spring.datasource.url=jdbc:oracle:thin:@localhost:1521:orcl
spring.datasource.username=username
spring.datasource.password=password
spring.datasource.driver-class-name=oracle.jdbc.OracleDriver
 
# HikariCP连接池参数
spring.datasource.hikari.connection-timeout=10000
spring.datasource.hikari.maximum-pool-size=20
spring.datasource.hikari.minimum-idle=5
spring.datasource.hikari.idle-timeout=600000
spring.datasource.hikari.pool-name=HikariCP

其中，maximum-pool-size参数表示连接池中最大的连接数，如果连接数超过这个阈值，就需要清除无效会话。

接下来，可以使用Spring Boot提供的JMX来监控连接池中的连接数，并且可以通过JMX来清除无效会话。

首先，需要在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

然后，在application.properties文件中添加以下配置：

# 开启JMX监控
spring.jmx.enabled=true
management.endpoint.jmx.exposure.include=*
management.endpoints.web.exposure.include=health,info,jolokia

最后，编写一个定时任务，每隔一段时间检查连接池中的连接数，如果超过阈值就清除无效会话，代码如下：

@Component
public class OracleConnectionMonitor {
 
    @Autowired
    private DataSource dataSource;
 
    @Scheduled(fixedDelay = 5000)
    public void monitor() throws SQLException {
        HikariDataSource hikariDataSource = (HikariDataSource) dataSource;
        int activeConnections = hikariDataSource.getHikariPoolMXBean().getActiveConnections();
        int maxPoolSize = hikariDataSource.getHikariConfigMXBean().getMaximumPoolSize();
 
        if (activeConnections > maxPoolSize) {
            clearInvalidSessions(hikariDataSource);
        }
    }
 
    private void clearInvalidSessions(HikariDataSource dataSource) throws SQLException {
        Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement("SELECT sid,serial# FROM v$session WHERE username = ?");
        statement.setString(1, dataSource.getUsername());
        ResultSet resultSet = statement.executeQuery();
 
        while (resultSet.next()) {
            int sid = resultSet.getInt("sid");
            int serial = resultSet.getInt("serial#");
            String killStatement = String.format("ALTER SYSTEM KILL SESSION '%d,%d'", sid, serial);
            Statement killStatementObject = connection.createStatement();
            killStatementObject.executeUpdate(killStatement);
            killStatementObject.close();
        }
 
        resultSet.close();
        statement.close();
        connection.close();
    }
}

在这个定时任务中，首先获取连接池中的活跃连接数和最大连接数，如果活跃连接数超过最大连接数，就调用clearInvalidSessions方法来清除无效会话。

方法中，首先获取连接池中的一个连接，然后执行查询语句SELECT sid,serial# FROM v$session WHERE username = ?，获取当前用户的会话列表。接着，遍历会话列表，对每个会话执行ALTER SYSTEM KILL SESSION语句来杀掉会话。最后，关闭ResultSet、Statement和Connection对象。

需要注意的是，这个定时任务需要在Spring Boot启动时就启动，可以在OracleConnectionMonitor类上添加@PostConstruct注解来实现。

@Component
public class OracleConnectionMonitor {
 
    @PostConstruct
    public void init() {
        // 定时任务代码
    }
 
    // 定时任务代码
}

这样就可以通过Spring Boot来实现监控Oracle连接数，并且在连接数超过阈值时清除无效会话了。