Camel 4.6.0 Salesforce组件403错误无法重连问题咨询

一、异常处理器未触发的原因 #

1. 异常类型不匹配
   Camel 4.x的Salesforce组件抛出403错误时，未必直接抛出SalesforceException，可能封装为HttpOperationFailedException（携带403状态码），后续的RejectedExecutionException是线程池耗尽导致的独立异常，不在SalesforceException的捕获范围内。另外，若未设置inheritance=true，onException仅精确匹配指定异常类，无法捕获其子类。

2. bridgeEndpoint=true的影响
   该参数会让Camel跳过Endpoint URI有效性校验，但可能导致组件内部消化部分异常，未将异常传播到路由的全局异常处理器层面。

3. 线程池阻塞导致异常处理无法执行
   组件每30秒自动重连，若重连持续失败会不断占用线程池资源，最终触发RejectedExecutionException，此时线程池无可用线程执行异常处理器逻辑，导致onException完全无法触发。

二、正确的自动重连实现方案 #

1. 修正异常捕获逻辑 #

先通过日志排查实际抛出的异常类型（查看完整异常栈），调整onException的捕获范围，例如同时捕获HttpOperationFailedException和RejectedExecutionException：

onException(HttpOperationFailedException.class, RejectedExecutionException.class)
    .when(exchange -> {
        // 筛选403::Unknown client的情况
        if (exchange.getException() instanceof HttpOperationFailedException) {
            HttpOperationFailedException httpEx = (HttpOperationFailedException) exchange.getException();
            return httpEx.getStatusCode() == 403 && "Unknown client".equals(httpEx.getResponseBody());
        }
        return true;
    })
    .inheritance(true)
    .to("controlbus:route?routeId=yourSalesforceRoute&action=restart")
    .handled(true);

务必添加inheritance=true，确保能捕获指定异常的子类。

2. 调整组件重连策略 #

• 关闭Salesforce组件自带的自动重连（通过autoReconnect=false配置），改用Camel的重试机制控制重连逻辑，避免线程池耗尽：

  from("salesforce:query?sObjectQuery=SELECT Id FROM Account&autoReconnect=false")
      .errorHandler(defaultErrorHandler()
          .retryAttemptedLogLevel(LoggingLevel.WARN)
          .maximumRetryAttempts(5)
          .retryDelay(30000)
          .retryWhile(exchange -> {
              Throwable ex = exchange.getException();
              return ex instanceof HttpOperationFailedException && ((HttpOperationFailedException) ex).getStatusCode() == 403;
          }))
      .to("direct:processSalesforceData");
  

• 若必须保留组件自带重连，需调整线程池配置，例如在Endpoint URI中添加threadPoolSize=10（根据实际情况调整），避免线程池被占满。

3. 优化ControlBus重启路由逻辑 #

• 确保路由ID配置正确，且重启逻辑不会陷入死循环：
  • 添加重试次数限制，例如用exchange.getProperty(Exchange.RETRY_COUNTER, Integer.class)判断重启次数，超过次数则告警并停止重试。
  • 重启路由前可短暂延迟，避免立即重启再次触发相同错误：

    onException(...)
        .delay(10000)
        .to("controlbus:route?routeId=yourSalesforceRoute&action=restart")
        .handled(true);
    

4. 排查Salesforce认证配置 #

403::Unknown client通常与客户端认证失败有关，需核对Camel 4.x Salesforce组件的配置：

• 确认oauthClientId、oauthClientSecret、refreshToken（若使用刷新令牌）配置正确。
• 开启autoRefreshToken=true，确保组件自动刷新过期的访问令牌（Camel 4.x可能调整了该参数的默认值）。

5. 线程池全局优化 #

通过Camel的ThreadPoolProfile配置全局线程池，避免单个组件的线程池耗尽影响整个应用：

ThreadPoolProfile profile = new ThreadPoolProfile("salesforcePool");
profile.setMaxPoolSize(15);
profile.setCorePoolSize(5);
camelContext.getExecutorServiceManager().registerThreadPoolProfile(profile);

然后在Salesforce Endpoint中指定使用该线程池：threadPoolProfile=salesforcePool

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