当连接变坏时,有没有办法让JBoss连接池重新连接到Oracle？

Question

我们将JBoss和Oracle放在不同的服务器上.这些连接似乎被丢弃并导致JBoss出现问题.如果连接不好,我怎样才能让JBoss重新连接到Oracle,同时我们弄清楚为什么首先要删除连接？

Answer 1

虽然你可以使用旧的"从双选1"技巧,但这样做的缺点是,每次从池中借用连接时,它都会发出额外的查询.对于大批量,这是浪费.

JBoss提供了一个特殊的连接验证器,应该用于Oracle:

<valid-connection-checker-class-name>
    org.jboss.resource.adapter.jdbc.vendor.OracleValidConnectionChecker
</valid-connection-checker-class-name>

这使得使用上的Oracle JDBC Connection类的专有平()方法,并使用驱动程序的底层网络代码,以确定连接是否还活着.

然而,它仍然是浪费这个连接是借来的每一次运行,所以你可能需要使用其中一个后台线程检查池中的连接,并默默地丢弃死的设施.这样效率更高,但意味着如果连接确实失效,那么在后台线程运行其检查之前使用它们的任何尝试都将失败.

有关如何配置后台检查(查找)的信息,请参阅wiki文档background-validation-millis.

Answer 2

池上通常有一个配置选项,可以在借用时执行验证查询.如果验证查询成功执行,则池将返回该连接.如果查询未成功执行,则池将创建新连接.

在JBoss的维基文档池的各种属性.

<check-valid-connection-sql>select 1 from dual</check-valid-connection-sql>

似乎它应该做的伎俩.

Answer 3

没有足够的代表评论,所以它是一种答案的形式.在'Select 1 from dual'与skaffman的org.jboss.resource.adapter.jdbc.vendor.OracleValidConnectionChecker方法是等效的,虽然连接检查并提供一个抽象层.我们不得不反编译oracle jdbc驱动程序以进行故障排除练习,并且Oracle的内部实现是执行ping操作'Select 'x' from dual'.Natch.

Answer 4

JBoss提供了两种验证连接的方法: - 基于Ping的AND - 基于查询

您可以根据要求使用.这是根据数据源配置文件中定义的持续时间由单独的线程调度的.

<background-validation>true</background-validation> <background-validation-minutes>1</background-validation-minutes>

有时候,如果你没有在Jboss上使用正确的oracle驱动程序,你可能会得到分类广播或相关的错误,并且该连接可能会从连接池中退出.您可以尝试通过实现org.jboss.resource.adapter.jdbc.ValidConnectionChecker接口来创建自己的ConnectionValidator类.此接口仅提供单个方法' isValidConnection()',并期望'NULL'作为有效连接的回报.

例如:

public class OracleValidConnectionChecker implements ValidConnectionChecker, Serializable {

   private Method ping;

   // The timeout (apparently the timeout is ignored?)
   private static Object[] params = new Object[] { new Integer(5000) };

   public SQLException isValidConnection(Connection c) {

       try {
           Integer status = (Integer) ping.invoke(c, params);

           if (status.intValue() < 0) {
               return new SQLException("pingDatabase failed status=" + status);
           }

       }
       catch (Exception e) {
           log.warn("Unexpected error in pingDatabase", e);
       }

       // OK
       return null;
   }
}