Surveiller l'utilisation du pool de connexion des sources de données

Contexte

Page précédente《Problème avec le pool de connexion de la source de données non fermé Could not open JDBC Connection for transaction》Analyse du code sourceMyBatisCadre etSpringLa gestion des transactions désactive automatiquement la fonction du pool de connexion des sources de données,Résoudre un problème avec un pool de connexion de source de données en ligne plein.
Mais on a résolu un problème, et peut - être un autre,Il faut maintenant un pool de connexion capable de surveiller l'utilisation des sources de données、Presque plein de plans d'alarme.

Programme I

Ce qui est utilisé ici estDruidSource des données,D'autres sources de données peuvent utiliser le scénario II ci - dessous.
DruidLa source de données elle - même a unfilter,Obtenir la connexion de la source de données（AppelezgetConnectionMéthodes）Tous lesfilter.
Alors,Nous pouvons ajouter unfilter,Pour voir l'état actuel du pool de connexions,Les codes sont les suivants:：

List<Filter> filters = new ArrayList<Filter>();
filters.add(new FilterAdapter(){
    
	@Override
	public DruidPooledConnection dataSource_getConnection(FilterChain chain, DruidDataSource dataSource, long maxWaitMillis) throws SQLException {
    
		int activeCount = dataSource.getActiveCount();
		if (activeCount > (dataSource.getMaxActive() * 0.8)) {
    
			log.error("Druid Warning,the current active count of Druid Connection Pool is " + activeCount + "!");
		}
		return chain.dataSource_connect(dataSource, maxWaitMillis);
	}
});
dataSource.setProxyFilters(filters);

Lorsque le nombre actuel de connexions est supérieur au nombre maximum de connexions 80%Le Journal des erreurs sera imprimé, Bien sûr, d'autres types de codes d'alarme peuvent être ajoutés à nouveau .

Programme II

L'option 2 peut être appliquée aux sources générales de données ,IllimitéDruidSource des données.L'idée de base est, Écrivez une sous - classe de sources de données héritées , Outrepasser la méthode d'obtention de la connexion , Code permettant la surveillance avant d'obtenir la connexion ,Voici un exemple de code:：

DruidDataSource dataSource = new DruidDataSource(){
    
	protected Logger log = LoggerFactory.getLogger(BaqiDataSource.class);
	@Override
	public DruidPooledConnection getConnectionDirect(long maxWaitMillis) throws SQLException {
    
		int activeCount = this.getActiveCount();
		if (activeCount > (dataSource.getMaxActive() * 0.8)) {
    
			log.error("Druid Warning,the current active count of Druid Connection Pool is " + activeCount + "!");
		}
		return super.getConnectionDirect(maxWaitMillis);
	}
};
// Initialiser le pool de connexion comme suit 
dataSource.setUrl("xxx");
dataSource.setUsername("xxx");
dataSource.setPassword("xxx"));
dataSource.setDriverClassName("xxx"));
...

Conclusions

L'option 1 s'applique: DruidSource des données, Le scénario II s'applique à toutes les sources de données ,Peut être utilisé selon le cas.