如何在 Shutdown/Redeploy 上关闭 HikariCP JNDI 数据源
How to Close HikariCP JNDI DataSource on Shutdown/Redeploy
我将 HikariCP 2.3.3 与 Spring 和 Jetty 9 一起使用,并试图解决以下问题:当我热部署一个新的 war 文件时,所有 Hikari 数据库池连接到MySQL 处于打开和闲置状态。我在 spring applicationContext 文件中使用 JNDI 查找来从 Jetty 上下文文件中检索数据源。
因为我不能像定义数据源 bean 那样在 jndi 查找中指定销毁方法,所以我提到了这个问题:Should I close JNDI-obtained data source?,其中提到您可以尝试关闭ServletContextListener 的 contextDestroyed() 方法中的数据源。在那种情况下,他们使用了 tomcat 和 c3po,所以我不确定这个例子有多少相关。
我在 contextDestroyed 方法中尝试了以下方法:
InitialContext initial;
DataSource ds;
try
{
initial = new InitialContext();
ds = (DataSource) initial.lookup("jdbc/myDB");
if (ds.getConnection() == null)
{
throw new RuntimeException("Failed to find the JNDI Datasource");
}
HikariDataSource hds = (HikariDataSource) ds;
hds.close();
} catch (NamingException | SQLException ex)
{
Logger.getLogger(SettingsInitializer.class.getName()).log(Level.SEVERE, null, ex);
}
但是在 HikariDataSource hds = (HikariDataSource) ds;我得到以下异常:java.lang.ClassCastException: com.zaxxer.hikari.HikariDataSource cannot be cast to com.zaxxer.hikari.HikariDataSource
在 GitHub 上阅读此问题后,我还尝试了以下方法:Is it essential to call shutdown()
on HikariDataSource?:
InitialContext initial;
DataSource ds;
try
{
initial = new InitialContext();
ds = (DataSource) initial.lookup("jdbc/myDB");
ds.unwrap(HikariDataSource.class).close();
} catch (NamingException | SQLException ex)
{
Logger.getLogger(SettingsInitializer.class.getName()).log(Level.SEVERE, null, ex);
}
但我得到以下异常:java.sql.SQLException: Wrapped connection is not an instance of class com.zaxxer.hikari.HikariDataSource
at com.zaxxer.hikari.HikariDataSource.unwrap(HikariDataSource.java:177)
我觉得我接近于一个可行的解决方案,但还不太明白。关闭 JNDI HikariCP 数据源的正确方法是什么,无论是在 contextDestroyed() 还是在其他地方?
我找不到 2.3.3 code 与上面的 HikariDataSource.java:177
行号对齐的位置。一个建议是升级到最新的 HikariCP 版本 2.3.8。
虽然您的代码 看起来正确,但我怀疑您 运行 遇到了 class 加载程序问题,因此 HikariDataSource (class ) 由 Jetty/Spring classloader 加载并在 JNDI 中注册与在您的网络应用程序中加载 HikariDataSource 的 classloader 不同。
一种快速检查方法是 log/print 两个 class 个实例 ,如下所示:
...
ds = (DataSource) initial.lookup("jdbc/myDB");
logger.info("JNDI HikariDataSource : " + System.identityHashCode(ds.getClass()));
logger.info("Local HikariDataSource: " + System.identityHashCode(HikariDataSource.class));
...
如果两个class对象的hashCode不同,则它们不相同class。在这种情况下,您将不得不调查 JNDI 实例是否已在 "global JNDI context" 中注册。如果是,则该数据源可以跨 Web 应用程序实例共享,并且您的 Web 应用程序单方面关闭它是不合适的。
更新:抱歉我错过了。重新阅读你的问题,我的猜测是正确的。您的原始错误:
java.lang.ClassCastException: com.zaxxer.hikari.HikariDataSource cannot be cast to
com.zaxxer.hikari.HikariDataSource
清楚地表明有两个 classloader 加载了 HikariDataSource class 的两个独立实例。第一个是 Jetty classloader (JNDI),第二个是您的 Web 应用程序 classloader.
这表明该池是跨 Web 应用程序共享的,您可能不应该尝试从您的应用程序上下文中关闭它。
我将 HikariCP 2.3.3 与 Spring 和 Jetty 9 一起使用,并试图解决以下问题:当我热部署一个新的 war 文件时,所有 Hikari 数据库池连接到MySQL 处于打开和闲置状态。我在 spring applicationContext 文件中使用 JNDI 查找来从 Jetty 上下文文件中检索数据源。
因为我不能像定义数据源 bean 那样在 jndi 查找中指定销毁方法,所以我提到了这个问题:Should I close JNDI-obtained data source?,其中提到您可以尝试关闭ServletContextListener 的 contextDestroyed() 方法中的数据源。在那种情况下,他们使用了 tomcat 和 c3po,所以我不确定这个例子有多少相关。
我在 contextDestroyed 方法中尝试了以下方法:
InitialContext initial;
DataSource ds;
try
{
initial = new InitialContext();
ds = (DataSource) initial.lookup("jdbc/myDB");
if (ds.getConnection() == null)
{
throw new RuntimeException("Failed to find the JNDI Datasource");
}
HikariDataSource hds = (HikariDataSource) ds;
hds.close();
} catch (NamingException | SQLException ex)
{
Logger.getLogger(SettingsInitializer.class.getName()).log(Level.SEVERE, null, ex);
}
但是在 HikariDataSource hds = (HikariDataSource) ds;我得到以下异常:java.lang.ClassCastException: com.zaxxer.hikari.HikariDataSource cannot be cast to com.zaxxer.hikari.HikariDataSource
在 GitHub 上阅读此问题后,我还尝试了以下方法:Is it essential to call shutdown()
on HikariDataSource?:
InitialContext initial;
DataSource ds;
try
{
initial = new InitialContext();
ds = (DataSource) initial.lookup("jdbc/myDB");
ds.unwrap(HikariDataSource.class).close();
} catch (NamingException | SQLException ex)
{
Logger.getLogger(SettingsInitializer.class.getName()).log(Level.SEVERE, null, ex);
}
但我得到以下异常:java.sql.SQLException: Wrapped connection is not an instance of class com.zaxxer.hikari.HikariDataSource
at com.zaxxer.hikari.HikariDataSource.unwrap(HikariDataSource.java:177)
我觉得我接近于一个可行的解决方案,但还不太明白。关闭 JNDI HikariCP 数据源的正确方法是什么,无论是在 contextDestroyed() 还是在其他地方?
我找不到 2.3.3 code 与上面的 HikariDataSource.java:177
行号对齐的位置。一个建议是升级到最新的 HikariCP 版本 2.3.8。
虽然您的代码 看起来正确,但我怀疑您 运行 遇到了 class 加载程序问题,因此 HikariDataSource (class ) 由 Jetty/Spring classloader 加载并在 JNDI 中注册与在您的网络应用程序中加载 HikariDataSource 的 classloader 不同。
一种快速检查方法是 log/print 两个 class 个实例 ,如下所示:
...
ds = (DataSource) initial.lookup("jdbc/myDB");
logger.info("JNDI HikariDataSource : " + System.identityHashCode(ds.getClass()));
logger.info("Local HikariDataSource: " + System.identityHashCode(HikariDataSource.class));
...
如果两个class对象的hashCode不同,则它们不相同class。在这种情况下,您将不得不调查 JNDI 实例是否已在 "global JNDI context" 中注册。如果是,则该数据源可以跨 Web 应用程序实例共享,并且您的 Web 应用程序单方面关闭它是不合适的。
更新:抱歉我错过了。重新阅读你的问题,我的猜测是正确的。您的原始错误:
java.lang.ClassCastException: com.zaxxer.hikari.HikariDataSource cannot be cast to
com.zaxxer.hikari.HikariDataSource
清楚地表明有两个 classloader 加载了 HikariDataSource class 的两个独立实例。第一个是 Jetty classloader (JNDI),第二个是您的 Web 应用程序 classloader.
这表明该池是跨 Web 应用程序共享的,您可能不应该尝试从您的应用程序上下文中关闭它。