使用Camel调用需独立认证的REST API：两种认证方式的实现方案咨询

我来给你分享两个简洁的Apache Camel实现方案，分别对应你提到的两种API认证场景，比你找到的复杂示例更直观：

这种场景的核心是先同步获取令牌，再携带原载荷发起主请求，重点要保证原队列载荷不被认证请求覆盖。我们可以用Camel的pollEnrich组件实现同步调用，同时保留原消息体：

from("activemq:queue:api-requests")
    // 同步调用认证服务器，获取令牌后不修改原消息体
    .pollEnrich("http://auth-server/token?grant_type=client_credentials&client_id=your-id&client_secret=your-secret",
        (originalExchange, authResponseExchange) -> {
            // 解析认证响应（实际项目建议用Jackson/Gson等JSON库，这里用字符串分割仅作示例）
            String authResponseBody = authResponseExchange.getIn().getBody(String.class);
            String accessToken = authResponseBody.split("\"access_token\":\"")[1].split("\"")[0];
            
            // 将令牌存入原消息的Header，供后续主请求使用
            originalExchange.getIn().setHeader("Authorization", "Bearer " + accessToken);
            return originalExchange;
        })
    // 携带原载荷和令牌发起主API请求
    .toD("http://main-api/service-endpoint?headerName=Authorization")
    // 可选：处理主请求响应
    .log("主API请求响应：${body}");

关键说明： #

• pollEnrich是同步调用，会等待认证接口返回后再继续路由，确保令牌到手后才发主请求
• 自定义的合并逻辑保留了原队列的载荷，仅添加认证令牌Header，完全满足你的业务流程需求

这种场景需要缓存有效令牌，避免重复调用认证接口，我们可以用Camel内置的Cache组件实现令牌的自动过期复用：

// 先配置缓存组件，设置令牌过期时间（示例为3600秒）
CacheConfiguration tokenCacheConfig = new CacheConfiguration("authTokenCache")
    .setExpiryPolicyFactory(CacheExpiryPolicy.factoryOf(3600));
context.addComponent("tokenCache", CacheComponent.newInstance(context, tokenCacheConfig));

from("activemq:queue:api-requests")
    .choice()
        // 判断缓存中是否存在有效令牌
        .when(exchange -> {
            Cache cache = exchange.getContext().getComponent("tokenCache", CacheComponent.class).getCache("authTokenCache");
            return !cache.containsKey("validToken");
        })
            // 缓存无有效令牌，调用认证接口获取并存入缓存
            .to("http://auth-server/token?grant_type=client_credentials&client_id=your-id&client_secret=your-secret")
            .process(exchange -> {
                String authResponseBody = exchange.getIn().getBody(String.class);
                String accessToken = "Bearer " + authResponseBody.split("\"access_token\":\"")[1].split("\"")[0];
                
                // 存入缓存
                Cache cache = exchange.getContext().getComponent("tokenCache", CacheComponent.class).getCache("authTokenCache");
                cache.put("validToken", accessToken);
                
                // 同时放到当前请求Header
                exchange.getIn().setHeader("Authorization", accessToken);
            })
        .otherwise()
            // 缓存有有效令牌，直接从缓存取出放到Header
            .process(exchange -> {
                Cache cache = exchange.getContext().getComponent("tokenCache", CacheComponent.class).getCache("authTokenCache");
                String accessToken = (String) cache.get("validToken");
                exchange.getIn().setHeader("Authorization", accessToken);
            })
    .end()
    // 发起主API请求
    .toD("http://main-api/service-endpoint?headerName=Authorization")
    .log("主API请求响应：${body}");

关键说明： #

• 缓存组件自带过期策略，令牌会在设定时间后自动失效，无需手动管理
• 路由逻辑清晰，通过choice分支判断是否需要调用认证接口，避免重复请求
• 缓存是线程安全的，不用担心并发场景下的令牌冲突问题

额外优化建议： #

• 解析认证响应时，不要用字符串分割，建议引入Jackson或Gson库解析JSON结构，避免格式变更导致的错误
• 如果令牌需要刷新，可以在缓存过期前提前触发刷新逻辑（比如设置过期时间为令牌有效期的90%，到期前自动重新获取）

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