Camel捕获SQL异常并配置3次重试：数据库连接失败时的异常识别与重试实现

我来帮你梳理清楚这两个问题，结合实际使用Camel SQL组件的经验来给你解答：

一、先解决你的异常捕获困惑：toF("sql:...")连接失败时抛出的异常 #

你之前尝试捕获CannotCreateTransactionException和ConnectionException没成功，核心原因是Camel SQL组件在数据库连接失败时，抛出的是JDBC层面的原生异常，而非Spring事务类的异常。

实际场景中，你应该关注这些异常类型：

• java.sql.SQLTransientConnectionException：JDBC标准的临时连接异常（这类异常是重试后有机会恢复的，非常适合配置重试）
• 具体数据库驱动的专属异常，比如MySQL的com.mysql.cj.jdbc.exceptions.CommunicationsException、PostgreSQL的org.postgresql.util.PSQLException（当连接超时、断开时会抛出）

你之前用的CannotCreateTransactionException是Spring事务管理器在创建事务上下文时才会抛出的，单纯用Camel SQL组件执行insert操作，不会触发这个异常。

二、捕获SQL异常+配置3次重试的完整实现 #

不管是单路由还是全局复用，核心都是用Camel的onException块来定义异常处理逻辑，下面给你两种常用的实现方式：

1. 单路由内的局部异常处理（仅作用于当前路由） #

如果只有这一条路由需要这个重试逻辑，直接在路由内定义即可：

from("direct:insertUser")
    // 捕获JDBC临时连接异常
    .onException(SQLTransientConnectionException.class)
        .maximumRedeliveries(3) // 最多重试3次
        .redeliveryDelay(10000) // 每次重试间隔10秒
        .process("connectionExceptionProcess") // 调用你的异常处理Bean
        .logStackTrace(true) // 打印异常栈，方便排查
        .end() // 结束异常处理块
    // 执行SQL插入
    .toF("sql:insert into user(name, age) values (:#name, :#age)");

2. 全局异常处理（作用于所有路由） #

如果多个路由都需要相同的重试逻辑，建议在Camel上下文里配置全局的异常处理规则，避免重复代码：

@Override
public void configure() throws Exception {
    // 全局异常处理规则
    onException(SQLTransientConnectionException.class)
        .maximumRedeliveries(3)
        .redeliveryDelay(10000)
        .process("connectionExceptionProcess")
        .logExhaustedMessageHistory(true) // 记录重试耗尽后的消息历史
        .end();

    // 业务路由1：插入用户
    from("direct:insertUser")
        .toF("sql:insert into user(name, age) values (:#name, :#age)");
    
    // 业务路由2：插入订单
    from("direct:insertOrder")
        .toF("sql:insert into order(order_id, amount) values (:#orderId, :#amount)");
}

额外小贴士 #

• 如果不确定具体抛出的异常类型，可以先临时捕获SQLException.class（最通用的JDBC异常），然后在process里打印异常的完整类名（exception.getClass().getName()），再替换成更精准的异常类型，这样能避免漏捕。
• 确保connectionExceptionProcess这个Bean已经正确注册到Spring（或Camel）容器中，Camel才能通过名称找到它。
• 如果需要区分不同数据库的异常，可以同时捕获多个异常类型，比如：

  .onException(SQLTransientConnectionException.class, CommunicationsException.class)
  

内容的提问来源于stack exchange，提问作者Julia