如何用Java实现Apache Camel路由从授权服务器获取Access Token？

没问题，结合你的Spring Boot授权服务器场景，我来一步步教你用Java实现Apache Camel路由，通过请求体传递参数获取Access Token。

1. 先添加必要依赖 #

首先确保你的Spring Boot项目里引入了Camel核心和HTTP组件的starter依赖（版本请对应你的Spring Boot版本，比如Spring Boot 3.x搭配Camel 4.x）：

<dependencies>
    <!-- Camel Spring Boot核心依赖 -->
    <dependency>
        <groupId>org.apache.camel.springboot</groupId>
        <artifactId>camel-spring-boot-starter</artifactId>
        <version>4.3.0</version>
    </dependency>
    <!-- Camel HTTP4组件（基于Apache HttpClient 4.x） -->
    <dependency>
        <groupId>org.apache.camel.springboot</groupId>
        <artifactId>camel-http4-starter</artifactId>
        <version>4.3.0</version>
    </dependency>
    <!-- JSON解析依赖（用于解析token响应） -->
    <dependency>
        <groupId>org.apache.camel.springboot</groupId>
        <artifactId>camel-jackson-starter</artifactId>
        <version>4.3.0</version>
    </dependency>
</dependencies>

2. 编写Camel路由逻辑 #

创建一个继承RouteBuilder的组件类，Camel会自动扫描并加载这个路由。下面示例包含两种常见触发方式，你可以根据需求选择：

方式一：定时自动获取Token（适合后台刷新场景） #

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.model.dataformat.JsonLibrary;
import org.springframework.stereotype.Component;
import java.util.Base64;

@Component
public class OAuthTokenFetchRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        // 每小时触发一次Token获取（可根据过期时间调整周期）
        from("timer:tokenRefreshTimer?period=3600000")
            .log("=== 开始获取OAuth2 Access Token ===")
            // 1. 构造请求体：键值对格式，对应你POSTMAN里的参数
            .setBody(constant("grant_type=password&username=your_user&password=your_pwd&client_id=your_client_id&client_secret=your_client_secret"))
            // 2. 设置请求头：指定表单格式
            .setHeader("Content-Type", constant("application/x-www-form-urlencoded"))
            // 如果你的授权服务器要求Client通过Basic Auth认证，取消下面注释（替换client_id和client_secret）
            // .setHeader("Authorization", constant("Basic " + Base64.getEncoder().encodeToString("your_client_id:your_client_secret".getBytes())))
            // 3. 发送POST请求到Token端点
            .to("http4://localhost:8080/oauth/token?httpMethod=POST")
            // 4. 解析JSON响应，提取Access Token
            .unmarshal().json(JsonLibrary.Jackson)
            .setBody(simple("${body['access_token']}"))
            .log("=== 获取到的Access Token: ${body} ===")
            // 5. 可选：将Token存储到缓存/数据库（示例用日志代替）
            .to("direct:storeToken");

        // 子路由：处理Token存储逻辑
        from("direct:storeToken")
            .log("已将Token存入指定存储：${body}");
    }
}

方式二：通过REST接口触发获取（适合按需调用场景） #

如果需要手动触发获取Token，可以改成REST端点触发：

// 替换上面的from部分
from("rest:get:/fetch-token")
    .log("=== 接收到Token获取请求 ===")
    // 后续逻辑和上面一致...

3. 关键细节说明 #

• HTTP组件选择：示例用http4（基于HttpClient 4.x），如果用HttpClient 5.x可以换成http组件，依赖对应camel-http-starter。
• 请求体格式：必须设置Content-Type: application/x-www-form-urlencoded，请求体是键值对拼接的字符串，和你POSTMAN里的参数一致。
• Client认证：如果你的授权服务器要求Client通过Basic Auth验证，就添加Authorization头，值为Basic 加上client_id:client_secret的Base64编码，此时请求体里可以省略client_id和client_secret参数。
• 响应处理：用Jackson组件解析JSON响应，通过simple表达式提取access_token字段，方便后续使用。

4. 配置与测试 #

• 在application.properties里可以配置HTTP组件的超时、连接池等参数：

# HTTP4连接超时（毫秒）
camel.component.http4.connect-timeout=5000
# HTTP4读取超时（毫秒）
camel.component.http4.socket-timeout=10000

• 启动Spring Boot应用，Camel会自动加载路由，定时器会按时触发请求，或者访问REST端点http://localhost:8081/fetch-token（假设你的应用端口是8081）触发获取。

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