Spring AOP Обработка исключений

Question

Я пытаюсь проверить, жив ли некоторые хосты базы данных. Класс ConfigReader анализирует XML-файл и получает список некоторых узлов базы данных. Я хочу видеть журналы, как это, если некоторые хосты не доступны:

running check for host:dbhost1 
Some Exception is ... 
running check for host:dbhost2 
host is alive 

и так далее.

Но я вижу это исключение, если хост не жив. Приложение выходит из строя вместо того, чтобы регистрировать и выдавать исключение.

#### running check for host:dbhost1 
Exception in thread "main" java.sql.SQLException: Cannot create PoolableConnectionFactory (I/O-Fehler: The Network Adapter could not establish the connection) 
    at org.apache.commons.dbcp2.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:2291) 
    at org.apache.commons.dbcp2.BasicDataSource.createDataSource(BasicDataSource.java:2038) 
    at org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1533) 
    at com.csinfra.jdbmon.app.CheckDatabase.runCheckGroup(CheckDatabase.java:108) 

Вот классы:

@Component 
public class ScheduleCheck { 
    public ConfigReader configReader; 
    public CheckDatabase checkDatabase; 

    public void runHostCheck() throws Exception { 
     configReader.readConfig(); 
     checkDatabase.setConfigReader(configReader);   
     for(Host host:configReader.getHostMap().values()){    
       System.out.println("#### running check for host:"+host.getId()); 
       checkDatabase.runCheckGroup(host, getCheckFromCheckGroup(host));       
     } 
    } 
} 



@Component 
public class CheckDatabase { 
    public void runCheckGroup(Host host) throws Exception{    
      createConnections(host.getJdbcurl(), host.getJdbcuser(), host.getJdbcpassword(), host.getDriverclassname()); 
      Connection connection_single = jdbcPool.getConnection(); 
      if(connection_single!=null){      
       System.out.println("host is alive"); 
      }       
    } 

    public void createConnections(String url, String username, String password, String driverClassname) throws Exception{ 
      jdbcPool = new BasicDataSource();      
      jdbcPool.setDriverClassName(driverClassname); 
      jdbcPool.setUsername(username); 
      jdbcPool.setUrl(url); 
      jdbcPool.setPassword(password); 
      jdbcPool.setInitialSize(2); 
      jdbcPool.setCacheState(false); 
      jdbcPool.setMaxTotal(2); 
      jdbcPool.setMaxWaitMillis(6000); 
      jdbcPool.setMaxIdle(2); 
      jdbcPool.setDefaultReadOnly(true); 
    } 
} 


@Configurable 
@Aspect 
@Component 
public class AopMethodLogger { 

    private static final Logger LOGGER = RootLogger.getLogger(AopMethodLogger.class); 

    @AfterThrowing(pointcut = "execution(* com.csinfra.app..*.*(..))", throwing = "exception") 
    public void logAfterThrowing(JoinPoint joinPoint, Throwable exception) throws Throwable { 
     LOGGER.debug("Some Exception is "+exception.getLocalizedMessage()); 
     throw exception; 
    } 
} 


<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xmlns:tx="http://www.springframework.org/schema/tx" 
    xmlns:aop="http://www.springframework.org/schema/aop" 
    xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd 
     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd"> 

    <aop:aspectj-autoproxy proxy-target-class="true" /> 
    <context:component-scan base-package="com.csinfra.app /> 

    <bean id="aopMethod" class="com.csinfra.app.log.AopMethodLogger" /> 

    <bean id="scheduleCheck" class="com.csinfra.app.ScheduleCheck"> 
     <property name="configReader" ref="configReader" /> 
     <property name="checkDatabase" ref="checkDatabase" /> 
    </bean> 

    <bean id="checkDatabase" class="com.csinfra.app.CheckDatabase"> 
    </bean> 

</beans> 

Answer 1

CheckDatabase.runCheckGroup бросает исключение, и оно не обрабатывается, то почему приложение закрывается. Окружите свой вызов runCheckGroup с TRY/поймать и войти исключение:

try{ 
    checkDatabase.runCheckGroup(host, getCheckFromCheckGroup(host));    
} catch(Exception e){ 
    System.out.println("Exception occured :"+e); 
} 

Количество подключений к базе данных ограничено, поэтому создание нового подключения, просто проверить, что база данных жив, кажется, довольно дорого. Это может быть лучше, чтобы пружинная INJECT всех доступных источников данных:

@Autowire 
List<DataSource>dataSources; 

Это имеет также преимущество для автоматической проверки всех сконфигурированных источников данных, без дополнительной настройки.

И чем перебирать те, для каждого делать что-то вроде

new JdbcTemplate(dataSource).queryForInt("SELECT 1") 

, чтобы проверить его в живых.