如何使用 Apache Camel 路由从授权服务器获取访问令牌?

本文介绍了如何使用 Apache Camel 路由从授权服务器获取访问令牌?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

限时送ChatGPT账号..

我有一个授权服务器 [用 @SpringBootApplication 注释的简单类，@RestController,@Configuration,@EnableAuthorizationServer &oauth2 安全性] 运行在端口 8081 上，工作正常 &使用 POST 方法从 POSTMAN 请求时提供访问令牌以及键值对形式的必要参数，http://localhost:8080/oauth/token，但是我应该如何在java中实现camel路由通过在body中传递参数来获取访问令牌?

I have an authorization server [Simple Class annotated with @SpringBootApplication, @RestController,@Configuration,@EnableAuthorizationServer & oauth2 security] running on port 8081 which works fine & provides the access token when requested from POSTMAN using POST method along with needful parameters in the form of key value pair, http://localhost:8080/oauth/token, but how should i implement the camel route in java to get the access token by passing parameters in body ?

推荐答案

这个问题更多是关于使用 Apache Camel 发送 multipart/form-data.前段时间我在玩它，并使用自定义处理器解决了它，将标题转换为 multipart/form-data 格式，并使用 Content-Disposition: form-data.

This question is more about sending multipart/form-data with Apache Camel. I was playing with it some time ago and solved it with custom Processor, converting headers to multipart/form-data format with Content-Disposition: form-data.

这是我的处理器将标头转换为 multipart/form-data 格式:

This is my Processor converting headers to multipart/form-data format:

public class PrepareMultipartFormData implements Processor {
    private String[] multipartHeaders;

    public PrepareMultipartFormData(String... multipartHeaders) {
        this.multipartHeaders = multipartHeaders;
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        addMultipart(exchange.getIn(), multipartHeaders);
    }

    private static void addMultipart(Message message, String... multipartKeys){
        final String boundary = "---------------------------"+RandomStringUtils.randomAlphanumeric(9);
        message.setHeader(Exchange.CONTENT_TYPE, "multipart/form-data;boundary="+boundary);
        StringBuilder sb = new StringBuilder("--").append(boundary);

        for (String key: multipartKeys) {
                    sb.append("\r\n")
                    .append("Content-Disposition: form-data; name=\"").append(key).append("\"")
                    .append("\r\n\r\n")
                    .append(message.getHeader(key, String.class))
                    .append("\r\n")
                    .append("--").append(boundary);
        }
        message.setBody(sb.toString());
    }
}

您需要向 OAuth 请求令牌发送:

HTTP 标头授权标头 - 这是由端点选项指定的标准HTTP组件的一部分authUsername 和 authPassword Content-Type - 这是添加到我的 PrepareMultipartFormData 处理器 HTTP headers Authorization header - This is part of standard HTTP component specified by endpoint options authUsername and authPassword Content-Type - This is added in my PrepareMultipartFormData Processor grant_type用户名密码client_id

最终路线可以这样实现:
(用一些表达式替换常量，以动态设置它.如果您只需要 token 响应，请添加一些解组，因为此路由返回 JSON)

Final route can be implemented in this way:
(Replace constants with some expressions, to set it dynamically. If you need only token in response, add some unmarshalling, since this route returns JSON)

from("direct:getTokenResponse")
        .setHeader(Exchange.HTTP_METHOD, constant("POST"))
        .setHeader(Exchange.HTTP_PATH, constant("oauth/token"))
        .setHeader("grant_type", constant("password"))
        .setHeader("username", constant("admin"))
        .setHeader("password", constant("admin1234"))
        .setHeader("client_id", constant("spring-security-oauth2-read-write-client"))
        .process(new PrepareMultipartFormData("grant_type", "username", "password", "client_id"))
        .to("http://localhost:8080?authMethod=Basic&authUsername=oauth-endpoint-username&authPassword=oauth-endpoint-password")
        .convertBodyTo(String.class)
        .to("log:response");

<小时>

使用 PrepareMultipartFormData#addMultipart 实现apache/http/entity/mime/MultipartEntityBuilder.html" rel="nofollow noreferrer">MultipartEntityBuilder.

---

Updating answer to provide a bit shorter implementation of PrepareMultipartFormData#addMultipart using MultipartEntityBuilder.

private static void addMultipart(Message message, String... multipartKeys) throws Exception{
    MultipartEntityBuilder builder = MultipartEntityBuilder.create();
    for (String key: multipartKeys) {
        builder.addTextBody(key, message.getHeader(key, String.class));
    }
    HttpEntity resultEntity = builder.build();
    message.setHeader(Exchange.CONTENT_TYPE, resultEntity.getContentType().getValue());
    message.setBody(resultEntity.getContent());
}

这篇关于如何使用 Apache Camel 路由从授权服务器获取访问令牌?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！