DB故障未按预期工作的异常处理

Question

我正在开发一个小型的camel应用程序，它从文件中读取数据，并将数据写入数据库。一切正常。现在，我想在其中添加DB故障转移功能，这意味着当将数据写入DB时，如果DB由于网络故障（或者某人关闭了DB）而不可用，我的应用程序应该重试5次，间隔1000毫秒，如果到那时DB已经启动或者（网络连接重新建立）应用程序应该继续，或者到那时DB还没有恢复，应用程序应该关闭。现在，我最初尝试了Camel的重新传递特性，但这里的问题是，即使DB在5次重试内恢复，现有的DB连接也已经失效，因此应用程序无法继续使用它。所以，我尝试编写自己的类来处理这个可恢复的错误。

RouteBuilder如下所示：

   public class MyRouteBuilder extends SpringRouteBuilder {
       @Override
       public void configure() throws Exception {
         registerExceptionHandler();
         addRoute();
       }

       private addRoute() {
         from("file:/DHBSI/data/input?fileName=whdh90151.csv")
         .id("MyRoute") 
         .policy(transactionRequiredPolicy)
         .process(new Processor() {
          @Override
          public void process(Exchange exchange) throws Exception {
            ...
            StudentJPAEntity student = new StudentJPAEntity ();
            ...
            studentJPARepository.save(student);
          }
        }).end();
       }

       private registerExceptionHandler() {
         onException(JDBCConnectionException.class, 
           SocketException.class)
           .process(new RecoverableExceptionHandlingStrategy());

         onException(Exception.class)
           .process(new Processor() {
             @Override
             public void process(Exchange exchange) throws Exception {
               System.exit(-1);
             }
           });
       }
   }

TransactionRequiredPolicy使用的JPATransactionManager与用于StudentJParePository.Save（student）；的JPATransactionManager相同

假设RecoverableExceptionHandlingStrategy类似于：

    public class RecoverableExceptionHandlingStrategy implements Processor {
        static int count = 0; 
        static int maxCount = 5;

        @Override
        public void process(Exchange exchange) throws Exception {
          count++;
          if(count<=maxCount) {
            Thread.sleep(1000);
          } else {
            System.exit(-1);
          }
        }
    }

日志中出现以下错误：

Answer 1

如果不在onException（）子句中指定maximumRedeliveries的默认值为0。这就是为什么交换没有被重新交付的原因。由于交换没有被重新传递，因此RecoverableExceptionHandlingStrategy中的计数器没有被递增，应用程序也没有关闭。

为实现重新交付，应将例外条款修改如下

onException(...)
.maximumRedeliveries(5)
.logRetryAttempted(true)                    ---> This will log the retries
.retryAttemptedLogLevel(LoggingLevel.INFO)  ---> at INFO level
.handled(true)
.process(<---- shutdown code ---->)