此版本仍在开发中,尚未被视为稳定版本。如需最新稳定版本,请使用 Spring Security 7.0.4spring-doc.cadn.net.cn

授权许可支持

本节介绍 Spring Security 对授权许可(authorization grants)的支持。spring-doc.cadn.net.cn

授权码

有关授权码许可的更多详细信息,请参阅 OAuth 2.0 授权框架。spring-doc.cadn.net.cn

获取授权

参见授权请求/响应协议流程,了解授权码许可类型。spring-doc.cadn.net.cn

发起授权请求

OAuth2AuthorizationRequestRedirectFilter 使用一个 OAuth2AuthorizationRequestResolver 来解析 OAuth2AuthorizationRequest,并通过将最终用户的用户代理重定向到授权服务器的授权端点来启动授权码许可流程。spring-doc.cadn.net.cn

OAuth2AuthorizationRequestResolver 的主要作用是从提供的 Web 请求中解析出一个 OAuth2AuthorizationRequest。 默认实现 DefaultOAuth2AuthorizationRequestResolver 会匹配(默认)路径 /oauth2/authorization/{registrationId},从中提取 registrationId,并使用该 ID 为关联的 OAuth2AuthorizationRequest 构建 ClientRegistrationspring-doc.cadn.net.cn

请考虑以下用于 OAuth 2.0 客户端注册的 Spring Boot 属性:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            client-id: okta-client-id
            client-secret: okta-client-secret
            authorization-grant-type: authorization_code
            redirect-uri: "{baseUrl}/authorized/okta"
            scope: read, write
        provider:
          okta:
            authorization-uri: https://dev-1234.oktapreview.com/oauth2/v1/authorize
            token-uri: https://dev-1234.oktapreview.com/oauth2/v1/token

根据上述属性,一个以 /oauth2/authorization/okta 为基本路径的请求将由 OAuth2AuthorizationRequestRedirectFilter 触发授权请求重定向,并最终启动授权码许可流程。spring-doc.cadn.net.cn

AuthorizationCodeOAuth2AuthorizedClientProviderOAuth2AuthorizedClientProvider 的一个实现,用于授权码许可(Authorization Code grant), 它还会通过 OAuth2AuthorizationRequestRedirectFilter 触发授权请求重定向。spring-doc.cadn.net.cn

如果 OAuth 2.0 客户端是公共客户端,请按如下方式配置 OAuth 2.0 客户端注册:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            client-id: okta-client-id
            client-authentication-method: none
            authorization-grant-type: authorization_code
            redirect-uri: "{baseUrl}/authorized/okta"
            # ...

通过使用代码交换证明密钥(PKCE)来支持公共客户端。 如果客户端运行在不受信任的环境中(例如原生应用程序或基于Web浏览器的应用程序),因此无法保证其凭据的机密性,则在满足以下条件时将自动使用PKCE:spring-doc.cadn.net.cn

  1. client-secret 被省略(或为空)spring-doc.cadn.net.cn

  2. client-authentication-method 被设置为 noneClientAuthenticationMethod.NONEspring-doc.cadn.net.cn

  1. ClientRegistration.clientSettings.requireProofKeytrue 时(在此情况下,ClientRegistration.authorizationGrantType 必须为 authorization_codespring-doc.cadn.net.cn

如果 OAuth 2.0 授权服务器不支持机密客户端使用 PKCE,则需要通过将 ClientRegistration.clientSettings.requireProofKey 设置为 false 来禁用该功能。spring-doc.cadn.net.cn

DefaultOAuth2AuthorizationRequestResolver还支持URI模板变量用于redirect-uri通过使用UriComponentsBuilder.spring-doc.cadn.net.cn

以下配置使用了所有受支持的URI模板变量:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            # ...
            redirect-uri: "{baseScheme}://{baseHost}{basePort}{basePath}/authorized/{registrationId}"
            # ...

{baseUrl} 解析为 {baseScheme}://{baseHost}{basePort}{basePath}spring-doc.cadn.net.cn

使用 redirect-uri 模板变量配置 URI 在 OAuth 2.0 客户端运行在代理服务器之后时特别有用。 这样做可确保在展开 X-Forwarded-* 时使用 redirect-uri 请求头。spring-doc.cadn.net.cn

自定义授权请求

OAuth2AuthorizationRequestResolver 的一个主要用例是能够使用超出 OAuth 2.0 授权框架中定义的标准参数之外的附加参数来自定义授权请求。spring-doc.cadn.net.cn

例如,OpenID Connect 为授权码流程定义了额外的 OAuth 2.0 请求参数,这些参数是对OAuth 2.0 授权框架中定义的标准参数的扩展。 其中一个扩展参数是 prompt 参数。spring-doc.cadn.net.cn

prompt 参数是可选的。它是一个以空格分隔、区分大小写的 ASCII 字符串值列表,用于指定授权服务器是否应提示最终用户重新进行身份验证和同意。已定义的值包括:noneloginconsentselect_accountspring-doc.cadn.net.cn

以下示例展示了如何使用一个 DefaultOAuth2AuthorizationRequestResolver 来配置 Consumer<OAuth2AuthorizationRequest.Builder>,通过添加请求参数 oauth2Login() 来自定义 prompt=consent 的授权请求。spring-doc.cadn.net.cn

@Configuration
@EnableWebSecurity
public class OAuth2LoginSecurityConfig {

	@Autowired
	private ClientRegistrationRepository clientRegistrationRepository;

	@Bean
	public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
		http
			.authorizeHttpRequests((authorize) -> authorize
				.anyRequest().authenticated()
			)
			.oauth2Login((oauth2) -> oauth2
				.authorizationEndpoint((authorization) -> authorization
					.authorizationRequestResolver(
						authorizationRequestResolver(this.clientRegistrationRepository)
					)
				)
			);
		return http.build();
	}

	private OAuth2AuthorizationRequestResolver authorizationRequestResolver(
			ClientRegistrationRepository clientRegistrationRepository) {

		DefaultOAuth2AuthorizationRequestResolver authorizationRequestResolver =
				new DefaultOAuth2AuthorizationRequestResolver(
						clientRegistrationRepository, "/oauth2/authorization");
		authorizationRequestResolver.setAuthorizationRequestCustomizer(
				authorizationRequestCustomizer());

		return  authorizationRequestResolver;
	}

	private Consumer<OAuth2AuthorizationRequest.Builder> authorizationRequestCustomizer() {
		return customizer -> customizer
					.additionalParameters((params) -> params.put("prompt", "consent"));
	}
}
@Configuration
@EnableWebSecurity
class SecurityConfig {

    @Autowired
    private lateinit var customClientRegistrationRepository: ClientRegistrationRepository

    @Bean
    open fun filterChain(http: HttpSecurity): SecurityFilterChain {
        http {
            authorizeHttpRequests {
                authorize(anyRequest, authenticated)
            }
            oauth2Login {
                authorizationEndpoint {
                    authorizationRequestResolver = authorizationRequestResolver(customClientRegistrationRepository)
                }
            }
        }
        return http.build()
    }

    private fun authorizationRequestResolver(
            clientRegistrationRepository: ClientRegistrationRepository?): OAuth2AuthorizationRequestResolver {
        val authorizationRequestResolver = DefaultOAuth2AuthorizationRequestResolver(
                clientRegistrationRepository, "/oauth2/authorization")
        authorizationRequestResolver.setAuthorizationRequestCustomizer(
                authorizationRequestCustomizer())
        return authorizationRequestResolver
    }

    private fun authorizationRequestCustomizer(): Consumer<OAuth2AuthorizationRequest.Builder> {
        return Consumer { customizer ->
            customizer
                    .additionalParameters { params -> params["prompt"] = "consent" }
        }
    }
}

对于简单使用场景,如果某个特定提供程序的附加请求参数始终相同,您可以直接在 authorization-uri 属性中添加该参数。spring-doc.cadn.net.cn

例如,如果对于提供商 prompt,请求参数 consent 的值始终为 okta,则可以按如下方式配置:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        provider:
          okta:
            authorization-uri: https://dev-1234.oktapreview.com/oauth2/v1/authorize?prompt=consent

前面的示例展示了在标准参数基础上添加自定义参数的常见用例。 或者,如果你的需求更加高级,可以通过重写 OAuth2AuthorizationRequest.authorizationRequestUri 属性,完全控制授权请求 URI 的构建。spring-doc.cadn.net.cn

OAuth2AuthorizationRequest.Builder.build() 方法用于构建 OAuth2AuthorizationRequest.authorizationRequestUri,该 URI 表示授权请求地址,其中包含所有查询参数,并采用 application/x-www-form-urlencoded 格式。spring-doc.cadn.net.cn

以下示例展示了前一个示例中 authorizationRequestCustomizer() 的一种变体,改为覆盖 OAuth2AuthorizationRequest.authorizationRequestUri 属性:spring-doc.cadn.net.cn

private Consumer<OAuth2AuthorizationRequest.Builder> authorizationRequestCustomizer() {
	return customizer -> customizer
				.authorizationRequestUri((uriBuilder) -> uriBuilder
					.queryParam("prompt", "consent").build());
}
private fun authorizationRequestCustomizer(): Consumer<OAuth2AuthorizationRequest.Builder> {
    return Consumer { customizer: OAuth2AuthorizationRequest.Builder ->
        customizer
                .authorizationRequestUri { uriBuilder: UriBuilder ->
                    uriBuilder
                            .queryParam("prompt", "consent").build()
                }
    }
}

存储授权请求

AuthorizationRequestRepository 负责在授权请求发起之时到接收到授权响应(即回调)期间,对 OAuth2AuthorizationRequest 进行持久化。spring-doc.cadn.net.cn

OAuth2AuthorizationRequest 用于关联和验证授权响应。spring-doc.cadn.net.cn

AuthorizationRequestRepository 的默认实现是 HttpSessionOAuth2AuthorizationRequestRepository,它将 OAuth2AuthorizationRequest 存储在 HttpSession 中。spring-doc.cadn.net.cn

如果你有自定义的 AuthorizationRequestRepository 实现,可以按如下方式配置:spring-doc.cadn.net.cn

AuthorizationRequestRepository 配置
@Configuration
@EnableWebSecurity
public class OAuth2ClientSecurityConfig {

	@Bean
	public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
		http
			.oauth2Client((oauth2) -> oauth2
				.authorizationCodeGrant((codeGrant) -> codeGrant
					.authorizationRequestRepository(this.authorizationRequestRepository())
					// ...
				)
			)
            .oauth2Login((oauth2) -> oauth2
                .authorizationEndpoint((endpoint) -> endpoint
                    .authorizationRequestRepository(this.authorizationRequestRepository())
                    // ...
                )
            );
			return http.build();
	}

    @Bean
    public AuthorizationRequestRepository<OAuth2AuthorizationRequest> authorizationRequestRepository() {
        return new CustomOAuth2AuthorizationRequestRepository();
    }
}
@Configuration
@EnableWebSecurity
class OAuth2ClientSecurityConfig {

    @Bean
    open fun filterChain(http: HttpSecurity): SecurityFilterChain {
        http {
            oauth2Client {
                authorizationCodeGrant {
                    authorizationRequestRepository = authorizationRequestRepository()
                }
            }
        }
        return http.build()
    }
}
<http>
	<oauth2-client>
		<authorization-code-grant authorization-request-repository-ref="authorizationRequestRepository"/>
	</oauth2-client>
</http>

请求访问Tokens

参见授权码许可的访问Tokens请求/响应协议流程。spring-doc.cadn.net.cn

授权码许可(Authorization Code grant)的 OAuth2AccessTokenResponseClient 默认实现是 RestClientAuthorizationCodeTokenResponseClient,它使用一个 RestClient 实例在授权服务器的Tokens端点(Token Endpoint)将授权码交换为访问Tokens。spring-doc.cadn.net.cn

RestClientAuthorizationCodeTokenResponseClient 非常灵活,提供了多种选项用于自定义授权码许可(Authorization Code grant)的 OAuth 2.0 访问Tokens请求和响应。 请从以下使用场景中选择以了解更多信息:spring-doc.cadn.net.cn

自定义访问Tokens请求

RestClientAuthorizationCodeTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens请求的 HTTP 请求头和请求参数的钩子。spring-doc.cadn.net.cn

自定义请求头

有两种自定义 HTTP 头部的选项:spring-doc.cadn.net.cn

你可以使用 addHeadersConverter() 方法添加额外的请求头,而不会影响每个请求默认添加的请求头。 以下示例在 User-AgentregistrationId 时,向请求中添加一个 spring 请求头:spring-doc.cadn.net.cn

包含额外的 HTTP 头部
RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.addHeadersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	HttpHeaders headers = new HttpHeaders();
	if (clientRegistration.getRegistrationId().equals("spring")) {
		headers.set(HttpHeaders.USER_AGENT, "my-user-agent");
	}
	return headers;
});
val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.addHeadersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val headers = HttpHeaders()
	if (clientRegistration.getRegistrationId() == "spring") {
        headers[HttpHeaders.USER_AGENT] = "my-user-agent"
	}
	headers
}

你可以通过复用 DefaultOAuth2TokenRequestHeadersConverter 或使用 setHeadersConverter() 提供自定义实现来完全自定义请求头。 以下示例复用了 DefaultOAuth2TokenRequestHeadersConverter,并禁用了 encodeClientCredentials,从而使得 HTTP Basic 凭据不再使用 application/x-www-form-urlencoded 进行编码:spring-doc.cadn.net.cn

自定义 HTTP 头部
DefaultOAuth2TokenRequestHeadersConverter headersConverter =
	new DefaultOAuth2TokenRequestHeadersConverter();
headersConverter.setEncodeClientCredentials(false);

RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.setHeadersConverter(headersConverter);
val headersConverter = DefaultOAuth2TokenRequestHeadersConverter()
headersConverter.setEncodeClientCredentials(false)

val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.setHeadersConverter(headersConverter)

自定义请求参数

有三种选项可用于自定义请求参数:spring-doc.cadn.net.cn

使用 setParametersConverter() 无法完全自定义参数,因为这将要求用户自行提供所有默认参数。 默认参数始终会被提供,但可以通过调用 setParametersCustomizer() 来完全自定义或省略这些参数。spring-doc.cadn.net.cn

你可以使用 addParametersConverter() 添加额外的参数,而不会影响每个请求中默认添加的参数。 以下示例在 audienceregistrationId 时,向请求中添加一个 keycloak 参数:spring-doc.cadn.net.cn

包含额外的请求参数
RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.addParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>();
	if (clientRegistration.getRegistrationId().equals("keycloak")) {
		parameters.set(OAuth2ParameterNames.AUDIENCE, "my-audience");
	}
	return parameters;
});
val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.addParametersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "keycloak") {
        parameters[OAuth2ParameterNames.AUDIENCE] = "my-audience"
	}
	parameters
}

你可以使用 setParametersConverter() 来覆盖默认参数。 以下示例在 client_idregistrationId 时,覆盖了 okta 参数:spring-doc.cadn.net.cn

覆盖请求参数
RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.setParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	LinkedMultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
	if (clientRegistration.getRegistrationId().equals("okta")) {
		parameters.set(OAuth2ParameterNames.CLIENT_ID, "my-client");
	}
	return parameters;
});
val parametersConverter = DefaultOAuth2TokenRequestParametersConverter<OAuth2AuthorizationCodeGrantRequest>()
parametersConverter.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.setParametersConverter { grantRequest ->
    val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "okta") {
        parameters[OAuth2ParameterNames.CLIENT_ID] = "my-client"
	}
	parameters
}

您可以使用 setParametersCustomizer() 完全自定义参数(包括省略默认参数)。 以下示例在请求中包含 client_id 参数时,省略了 client_assertion 参数:spring-doc.cadn.net.cn

省略请求参数
RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.setParametersCustomizer(parameters -> {
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID);
	}
});
val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

自定义访问Tokens响应

RestClientAuthorizationCodeTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens响应的响应参数和错误处理的钩子。spring-doc.cadn.net.cn

自定义RestClient

您可以通过向 RestClient 提供一个预先配置好的 setRestClient() 来自定义Tokens(Token)响应。 默认的 RestClient 配置如下:spring-doc.cadn.net.cn

默认的 RestClient 配置
RestClient restClient = RestClient.builder()
	.messageConverters(messageConverters -> {
		messageConverters.clear();
		messageConverters.add(new FormHttpMessageConverter());
		messageConverters.add(new OAuth2AccessTokenResponseHttpMessageConverter());
	})
	.defaultStatusHandler(new OAuth2ErrorResponseErrorHandler())
	.build();

RestClientAuthorizationCodeTokenResponseClient accessTokenResponseClient =
	new RestClientAuthorizationCodeTokenResponseClient();
accessTokenResponseClient.setRestClient(restClient);
val restClient = RestClient.builder()
	.messageConverters { messageConverters ->
		messageConverters.clear()
		messageConverters.add(FormHttpMessageConverter())
		messageConverters.add(OAuth2AccessTokenResponseHttpMessageConverter())
	}
	.defaultStatusHandler(OAuth2ErrorResponseErrorHandler())
	.build()

val accessTokenResponseClient = RestClientAuthorizationCodeTokenResponseClient()
accessTokenResponseClient.setRestClient(restClient)

OAuth2AccessTokenResponseHttpMessageConverter 是用于 OAuth 2.0 访问Tokens响应的 HttpMessageConverter。 您可以通过调用 OAuth2AccessTokenResponse 方法来自定义Tokens响应参数到 setAccessTokenResponseConverter() 的转换。 默认实现为 DefaultMapOAuth2AccessTokenResponseConverterspring-doc.cadn.net.cn

OAuth2ErrorResponseErrorHandler 是一个 ResponseErrorHandler,可用于处理 OAuth 2.0 错误,例如 400 Bad Request。 它使用 OAuth2ErrorHttpMessageConverter 将 OAuth 2.0 错误参数转换为 OAuth2Error。 您可以通过调用 OAuth2Error 方法来自定义Tokens响应参数到 setErrorConverter() 的转换过程。spring-doc.cadn.net.cn

需要 Spring MVC 的 FormHttpMessageConverter,因为它在发送 OAuth 2.0 访问Tokens请求时会被使用。spring-doc.cadn.net.cn

自定义响应参数

以下示例为自定义Tokens响应参数转换为 OAuth2AccessTokenResponse 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens响应转换器
OAuth2AccessTokenResponseHttpMessageConverter accessTokenResponseMessageConverter =
	new OAuth2AccessTokenResponseHttpMessageConverter();
accessTokenResponseMessageConverter.setAccessTokenResponseConverter(parameters -> {
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build();
});
val accessTokenResponseMessageConverter = OAuth2AccessTokenResponseHttpMessageConverter()
accessTokenResponseMessageConverter.setAccessTokenResponseConverter { parameters ->
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build()
}

自定义错误处理

以下示例为自定义将 Error 参数转换为 OAuth2Error 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens错误处理器
OAuth2ErrorHttpMessageConverter errorConverter =
	new OAuth2ErrorHttpMessageConverter();
errorConverter.setErrorConverter(parameters -> {
	// ...
	return new OAuth2Error("custom-error", "custom description", "custom-uri");
});

OAuth2ErrorResponseErrorHandler errorHandler =
	new OAuth2ErrorResponseErrorHandler();
errorHandler.setErrorConverter(errorConverter);
val errorConverter = OAuth2ErrorHttpMessageConverter()
errorConverter.setErrorConverter { parameters ->
	// ...
	return OAuth2Error("custom-error", "custom description", "custom-uri")
}

val errorHandler = OAuth2ErrorResponseErrorHandler()
errorHandler.setErrorConverter(errorConverter)

使用 DSL 进行自定义

无论您是自定义 RestClientAuthorizationCodeTokenResponseClient,还是提供自己的 OAuth2AccessTokenResponseClient 实现,都可以使用 DSL 进行配置(作为发布一个 Bean的替代方案),如下所示:spring-doc.cadn.net.cn

通过 DSL 配置访问Tokens响应
@Configuration
@EnableWebSecurity
public class OAuth2ClientSecurityConfig {

	@Bean
	public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
		http
			.oauth2Client((oauth2) -> oauth2
				.authorizationCodeGrant((codeGrant) -> codeGrant
					.accessTokenResponseClient(this.accessTokenResponseClient())
					// ...
				)
			);
		return http.build();
	}
}
@Configuration
@EnableWebSecurity
class OAuth2ClientSecurityConfig {

    @Bean
    open fun filterChain(http: HttpSecurity): SecurityFilterChain {
        http {
            oauth2Client {
                authorizationCodeGrant {
                    accessTokenResponseClient = accessTokenResponseClient()
                }
            }
        }
        return http.build()
    }
}
<http>
	<oauth2-client>
		<authorization-code-grant access-token-response-client-ref="accessTokenResponseClient"/>
	</oauth2-client>
</http>

刷新Tokens

有关刷新Tokens的更多详细信息,请参阅 OAuth 2.0 授权框架。spring-doc.cadn.net.cn

刷新访问Tokens

请参阅访问Tokens请求/响应协议流程,了解刷新Tokens授权(Refresh Token grant)的相关内容。spring-doc.cadn.net.cn

用于刷新Tokens授权(Refresh Token grant)的 OAuth2AccessTokenResponseClient 默认实现是 RestClientRefreshTokenTokenResponseClient,它使用一个 RestClient 实例在授权服务器的Tokens端点(Token Endpoint)获取访问Tokens。spring-doc.cadn.net.cn

RestClientRefreshTokenTokenResponseClient 非常灵活,并提供了多种选项来自定义 OAuth 2.0 刷新Tokens grant 的访问Tokens请求和响应。 从以下用例中选择以获取更多信息:spring-doc.cadn.net.cn

自定义访问Tokens请求

RestClientRefreshTokenTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens请求的 HTTP 请求头和请求参数的钩子。spring-doc.cadn.net.cn

自定义请求头

有两种自定义 HTTP 头部的选项:spring-doc.cadn.net.cn

你可以使用 addHeadersConverter() 方法添加额外的请求头,而不会影响每个请求默认添加的请求头。 以下示例在 User-AgentregistrationId 时,向请求中添加一个 spring 请求头:spring-doc.cadn.net.cn

包含额外的 HTTP 头部
RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.addHeadersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	HttpHeaders headers = new HttpHeaders();
	if (clientRegistration.getRegistrationId().equals("spring")) {
		headers.set(HttpHeaders.USER_AGENT, "my-user-agent");
	}
	return headers;
});
val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.addHeadersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val headers = HttpHeaders()
	if (clientRegistration.getRegistrationId() == "spring") {
        headers[HttpHeaders.USER_AGENT] = "my-user-agent"
	}
	headers
}

你可以通过复用 DefaultOAuth2TokenRequestHeadersConverter 或使用 setHeadersConverter() 提供自定义实现来完全自定义请求头。 以下示例复用了 DefaultOAuth2TokenRequestHeadersConverter,并禁用了 encodeClientCredentials,从而使得 HTTP Basic 凭据不再使用 application/x-www-form-urlencoded 进行编码:spring-doc.cadn.net.cn

自定义 HTTP 头部
DefaultOAuth2TokenRequestHeadersConverter headersConverter =
	new DefaultOAuth2TokenRequestHeadersConverter();
headersConverter.setEncodeClientCredentials(false);

RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.setHeadersConverter(headersConverter);
val headersConverter = DefaultOAuth2TokenRequestHeadersConverter()
headersConverter.setEncodeClientCredentials(false)

val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.setHeadersConverter(headersConverter)

自定义请求参数

有三种选项可用于自定义请求参数:spring-doc.cadn.net.cn

使用 setParametersConverter() 无法完全自定义参数,因为这将要求用户自行提供所有默认参数。 默认参数始终会被提供,但可以通过调用 setParametersCustomizer() 来完全自定义或省略这些参数。spring-doc.cadn.net.cn

你可以使用 addParametersConverter() 添加额外的参数,而不会影响每个请求中默认添加的参数。 以下示例在 audienceregistrationId 时,向请求中添加一个 keycloak 参数:spring-doc.cadn.net.cn

包含额外的请求参数
RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.addParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>();
	if (clientRegistration.getRegistrationId().equals("keycloak")) {
		parameters.set(OAuth2ParameterNames.AUDIENCE, "my-audience");
	}
	return parameters;
});
val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.addParametersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "keycloak") {
        parameters[OAuth2ParameterNames.AUDIENCE] = "my-audience"
	}
	parameters
}

你可以使用 setParametersConverter() 来覆盖默认参数。 以下示例在 client_idregistrationId 时,覆盖了 okta 参数:spring-doc.cadn.net.cn

覆盖请求参数
RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.setParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	LinkedMultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
	if (clientRegistration.getRegistrationId().equals("okta")) {
		parameters.set(OAuth2ParameterNames.CLIENT_ID, "my-client");
	}
	return parameters;
});
val parametersConverter = DefaultOAuth2TokenRequestParametersConverter<OAuth2RefreshTokenGrantRequest>()
parametersConverter.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.setParametersConverter { grantRequest ->
    val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "okta") {
        parameters[OAuth2ParameterNames.CLIENT_ID] = "my-client"
	}
	parameters
}

您可以使用 setParametersCustomizer() 完全自定义参数(包括省略默认参数)。 以下示例在请求中包含 client_id 参数时,省略了 client_assertion 参数:spring-doc.cadn.net.cn

省略请求参数
RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.setParametersCustomizer(parameters -> {
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID);
	}
});
val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

自定义访问Tokens响应

RestClientRefreshTokenTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens响应的响应参数和错误处理的钩子。spring-doc.cadn.net.cn

自定义RestClient

您可以通过向 RestClient 提供一个预先配置好的 setRestClient() 来自定义Tokens(Token)响应。 默认的 RestClient 配置如下:spring-doc.cadn.net.cn

默认的 RestClient 配置
RestClient restClient = RestClient.builder()
	.messageConverters(messageConverters -> {
		messageConverters.clear();
		messageConverters.add(new FormHttpMessageConverter());
		messageConverters.add(new OAuth2AccessTokenResponseHttpMessageConverter());
	})
	.defaultStatusHandler(new OAuth2ErrorResponseErrorHandler())
	.build();

RestClientRefreshTokenTokenResponseClient accessTokenResponseClient =
	new RestClientRefreshTokenTokenResponseClient();
accessTokenResponseClient.setRestClient(restClient);
val restClient = RestClient.builder()
	.messageConverters { messageConverters ->
		messageConverters.clear()
		messageConverters.add(FormHttpMessageConverter())
		messageConverters.add(OAuth2AccessTokenResponseHttpMessageConverter())
	}
	.defaultStatusHandler(OAuth2ErrorResponseErrorHandler())
	.build()

val accessTokenResponseClient = RestClientRefreshTokenTokenResponseClient()
accessTokenResponseClient.setRestClient(restClient)

OAuth2AccessTokenResponseHttpMessageConverter 是用于 OAuth 2.0 访问Tokens响应的 HttpMessageConverter。 您可以通过调用 OAuth2AccessTokenResponse 方法来自定义Tokens响应参数到 setAccessTokenResponseConverter() 的转换。 默认实现为 DefaultMapOAuth2AccessTokenResponseConverterspring-doc.cadn.net.cn

OAuth2ErrorResponseErrorHandler 是一个 ResponseErrorHandler,可用于处理 OAuth 2.0 错误,例如 400 Bad Request。 它使用 OAuth2ErrorHttpMessageConverter 将 OAuth 2.0 错误参数转换为 OAuth2Error。 您可以通过调用 OAuth2Error 方法来自定义Tokens响应参数到 setErrorConverter() 的转换过程。spring-doc.cadn.net.cn

需要 Spring MVC 的 FormHttpMessageConverter,因为它在发送 OAuth 2.0 访问Tokens请求时会被使用。spring-doc.cadn.net.cn

自定义响应参数

以下示例为自定义Tokens响应参数转换为 OAuth2AccessTokenResponse 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens响应转换器
OAuth2AccessTokenResponseHttpMessageConverter accessTokenResponseMessageConverter =
	new OAuth2AccessTokenResponseHttpMessageConverter();
accessTokenResponseMessageConverter.setAccessTokenResponseConverter(parameters -> {
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build();
});
val accessTokenResponseMessageConverter = OAuth2AccessTokenResponseHttpMessageConverter()
accessTokenResponseMessageConverter.setAccessTokenResponseConverter { parameters ->
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build()
}

自定义错误处理

以下示例为自定义将 Error 参数转换为 OAuth2Error 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens错误处理器
OAuth2ErrorHttpMessageConverter errorConverter =
	new OAuth2ErrorHttpMessageConverter();
errorConverter.setErrorConverter(parameters -> {
	// ...
	return new OAuth2Error("custom-error", "custom description", "custom-uri");
});

OAuth2ErrorResponseErrorHandler errorHandler =
	new OAuth2ErrorResponseErrorHandler();
errorHandler.setErrorConverter(errorConverter);
val errorConverter = OAuth2ErrorHttpMessageConverter()
errorConverter.setErrorConverter { parameters ->
	// ...
	return OAuth2Error("custom-error", "custom description", "custom-uri")
}

val errorHandler = OAuth2ErrorResponseErrorHandler()
errorHandler.setErrorConverter(errorConverter)

使用构建器进行自定义

是否自定义RestClientRefreshTokenTokenResponseClient或提供您自己的OAuth2AccessTokenResponseClient的实现,您可以使用OAuth2AuthorizedClientProviderBuilder对其进行配置(作为发布bean的一个替代方案),如下所示:spring-doc.cadn.net.cn

通过构建器配置访问Tokens响应
// Customize
OAuth2AccessTokenResponseClient<OAuth2RefreshTokenGrantRequest> refreshTokenTokenResponseClient = ...

OAuth2AuthorizedClientProvider authorizedClientProvider =
		OAuth2AuthorizedClientProviderBuilder.builder()
				.authorizationCode()
				.refreshToken((configurer) -> configurer.accessTokenResponseClient(refreshTokenTokenResponseClient))
				.build();

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);
// Customize
val refreshTokenTokenResponseClient: OAuth2AccessTokenResponseClient<OAuth2RefreshTokenGrantRequest> = ...

val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
        .authorizationCode()
        .refreshToken { it.accessTokenResponseClient(refreshTokenTokenResponseClient) }
        .build()

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)

OAuth2AuthorizedClientProviderBuilder.builder().refreshToken() 配置了一个 RefreshTokenOAuth2AuthorizedClientProvider, 它是用于刷新Tokens(Refresh Token)授权的 OAuth2AuthorizedClientProvider 的一种实现。spring-doc.cadn.net.cn

OAuth2RefreshToken 可以选择性地在 authorization_code 授权类型下的访问Tokens响应中返回。 如果 OAuth2AuthorizedClient.getRefreshToken() 可用,且 OAuth2AuthorizedClient.getAccessToken() 已过期,则会由 RefreshTokenOAuth2AuthorizedClientProvider 自动刷新。spring-doc.cadn.net.cn

客户端凭证

有关客户端凭证授权类型的更多详细信息,请参阅 OAuth 2.0 授权框架。spring-doc.cadn.net.cn

请求访问Tokens

参见访问Tokens请求/响应协议流程,了解客户端凭证授权(Client Credentials grant)。spring-doc.cadn.net.cn

用于客户端凭证(Client Credentials)授权类型的 OAuth2AccessTokenResponseClient 默认实现是 RestClientClientCredentialsTokenResponseClient,它使用一个 RestClient 实例在授权服务器的Tokens端点(Token Endpoint)获取访问Tokens。spring-doc.cadn.net.cn

RestClientClientCredentialsTokenResponseClient 非常灵活,并提供了多种自定义 OAuth 2.0 Access Token 请求和响应选项,适用于 Client Credentials 授予方式。 请选择以下用例以获取更多信息:spring-doc.cadn.net.cn

自定义访问Tokens请求

RestClientClientCredentialsTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens请求的 HTTP 请求头和请求参数的钩子。spring-doc.cadn.net.cn

自定义请求头

有两种自定义 HTTP 头部的选项:spring-doc.cadn.net.cn

你可以使用 addHeadersConverter() 方法添加额外的请求头,而不会影响每个请求默认添加的请求头。 以下示例在 User-AgentregistrationId 时,向请求中添加一个 spring 请求头:spring-doc.cadn.net.cn

包含额外的 HTTP 头部
RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.addHeadersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	HttpHeaders headers = new HttpHeaders();
	if (clientRegistration.getRegistrationId().equals("spring")) {
		headers.set(HttpHeaders.USER_AGENT, "my-user-agent");
	}
	return headers;
});
val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.addHeadersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val headers = HttpHeaders()
	if (clientRegistration.getRegistrationId() == "spring") {
        headers[HttpHeaders.USER_AGENT] = "my-user-agent"
	}
	headers
}

你可以通过复用 DefaultOAuth2TokenRequestHeadersConverter 或使用 setHeadersConverter() 提供自定义实现来完全自定义请求头。 以下示例复用了 DefaultOAuth2TokenRequestHeadersConverter,并禁用了 encodeClientCredentials,从而使得 HTTP Basic 凭据不再使用 application/x-www-form-urlencoded 进行编码:spring-doc.cadn.net.cn

自定义 HTTP 头部
DefaultOAuth2TokenRequestHeadersConverter headersConverter =
	new DefaultOAuth2TokenRequestHeadersConverter();
headersConverter.setEncodeClientCredentials(false);

RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.setHeadersConverter(headersConverter);
val headersConverter = DefaultOAuth2TokenRequestHeadersConverter()
headersConverter.setEncodeClientCredentials(false)

val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.setHeadersConverter(headersConverter)

自定义请求参数

有三种选项可用于自定义请求参数:spring-doc.cadn.net.cn

使用 setParametersConverter() 无法完全自定义参数,因为这将要求用户自行提供所有默认参数。 默认参数始终会被提供,但可以通过调用 setParametersCustomizer() 来完全自定义或省略这些参数。spring-doc.cadn.net.cn

你可以使用 addParametersConverter() 添加额外的参数,而不会影响每个请求中默认添加的参数。 以下示例在 audienceregistrationId 时,向请求中添加一个 keycloak 参数:spring-doc.cadn.net.cn

包含额外的请求参数
RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.addParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>();
	if (clientRegistration.getRegistrationId().equals("keycloak")) {
		parameters.set(OAuth2ParameterNames.AUDIENCE, "my-audience");
	}
	return parameters;
});
val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.addParametersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "keycloak") {
        parameters[OAuth2ParameterNames.AUDIENCE] = "my-audience"
	}
	parameters
}

你可以使用 setParametersConverter() 来覆盖默认参数。 以下示例在 client_idregistrationId 时,覆盖了 okta 参数:spring-doc.cadn.net.cn

覆盖请求参数
RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.setParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	LinkedMultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
	if (clientRegistration.getRegistrationId().equals("okta")) {
		parameters.set(OAuth2ParameterNames.CLIENT_ID, "my-client");
	}
	return parameters;
});
val parametersConverter = DefaultOAuth2TokenRequestParametersConverter<OAuth2ClientCredentialsGrantRequest>()
parametersConverter.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.setParametersConverter { grantRequest ->
    val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "okta") {
        parameters[OAuth2ParameterNames.CLIENT_ID] = "my-client"
	}
	parameters
}

您可以使用 setParametersCustomizer() 完全自定义参数(包括省略默认参数)。 以下示例在请求中包含 client_id 参数时,省略了 client_assertion 参数:spring-doc.cadn.net.cn

省略请求参数
RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.setParametersCustomizer(parameters -> {
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID);
	}
});
val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

自定义访问Tokens响应

RestClientClientCredentialsTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens响应的响应参数和错误处理的钩子。spring-doc.cadn.net.cn

自定义RestClient

您可以通过向 RestClient 提供一个预先配置好的 setRestClient() 来自定义Tokens(Token)响应。 默认的 RestClient 配置如下:spring-doc.cadn.net.cn

默认的 RestClient 配置
RestClient restClient = RestClient.builder()
	.messageConverters(messageConverters -> {
		messageConverters.clear();
		messageConverters.add(new FormHttpMessageConverter());
		messageConverters.add(new OAuth2AccessTokenResponseHttpMessageConverter());
	})
	.defaultStatusHandler(new OAuth2ErrorResponseErrorHandler())
	.build();

RestClientClientCredentialsTokenResponseClient accessTokenResponseClient =
	new RestClientClientCredentialsTokenResponseClient();
accessTokenResponseClient.setRestClient(restClient);
val restClient = RestClient.builder()
	.messageConverters { messageConverters ->
		messageConverters.clear()
		messageConverters.add(FormHttpMessageConverter())
		messageConverters.add(OAuth2AccessTokenResponseHttpMessageConverter())
	}
	.defaultStatusHandler(OAuth2ErrorResponseErrorHandler())
	.build()

val accessTokenResponseClient = RestClientClientCredentialsTokenResponseClient()
accessTokenResponseClient.setRestClient(restClient)

OAuth2AccessTokenResponseHttpMessageConverter 是用于 OAuth 2.0 访问Tokens响应的 HttpMessageConverter。 您可以通过调用 OAuth2AccessTokenResponse 方法来自定义Tokens响应参数到 setAccessTokenResponseConverter() 的转换。 默认实现为 DefaultMapOAuth2AccessTokenResponseConverterspring-doc.cadn.net.cn

OAuth2ErrorResponseErrorHandler 是一个 ResponseErrorHandler,可用于处理 OAuth 2.0 错误,例如 400 Bad Request。 它使用 OAuth2ErrorHttpMessageConverter 将 OAuth 2.0 错误参数转换为 OAuth2Error。 您可以通过调用 OAuth2Error 方法来自定义Tokens响应参数到 setErrorConverter() 的转换过程。spring-doc.cadn.net.cn

需要 Spring MVC 的 FormHttpMessageConverter,因为它在发送 OAuth 2.0 访问Tokens请求时会被使用。spring-doc.cadn.net.cn

自定义响应参数

以下示例为自定义Tokens响应参数转换为 OAuth2AccessTokenResponse 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens响应转换器
OAuth2AccessTokenResponseHttpMessageConverter accessTokenResponseMessageConverter =
	new OAuth2AccessTokenResponseHttpMessageConverter();
accessTokenResponseMessageConverter.setAccessTokenResponseConverter(parameters -> {
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build();
});
val accessTokenResponseMessageConverter = OAuth2AccessTokenResponseHttpMessageConverter()
accessTokenResponseMessageConverter.setAccessTokenResponseConverter { parameters ->
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build()
}

自定义错误处理

以下示例为自定义将 Error 参数转换为 OAuth2Error 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens错误处理器
OAuth2ErrorHttpMessageConverter errorConverter =
	new OAuth2ErrorHttpMessageConverter();
errorConverter.setErrorConverter(parameters -> {
	// ...
	return new OAuth2Error("custom-error", "custom description", "custom-uri");
});

OAuth2ErrorResponseErrorHandler errorHandler =
	new OAuth2ErrorResponseErrorHandler();
errorHandler.setErrorConverter(errorConverter);
val errorConverter = OAuth2ErrorHttpMessageConverter()
errorConverter.setErrorConverter { parameters ->
	// ...
	return OAuth2Error("custom-error", "custom description", "custom-uri")
}

val errorHandler = OAuth2ErrorResponseErrorHandler()
errorHandler.setErrorConverter(errorConverter)

使用构建器进行自定义

是否自定义RestClientClientCredentialsTokenResponseClient或提供您自己的OAuth2AccessTokenResponseClient的实现,您可以使用OAuth2AuthorizedClientProviderBuilder对其进行配置(作为发布bean的一个替代方案),如下所示:spring-doc.cadn.net.cn

通过构建器配置访问Tokens响应
// Customize
OAuth2AccessTokenResponseClient<OAuth2ClientCredentialsGrantRequest> clientCredentialsTokenResponseClient = ...

OAuth2AuthorizedClientProvider authorizedClientProvider =
		OAuth2AuthorizedClientProviderBuilder.builder()
				.clientCredentials((configurer) -> configurer.accessTokenResponseClient(clientCredentialsTokenResponseClient))
				.build();

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);
// Customize
val clientCredentialsTokenResponseClient: OAuth2AccessTokenResponseClient<OAuth2ClientCredentialsGrantRequest> = ...

val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
        .clientCredentials { it.accessTokenResponseClient(clientCredentialsTokenResponseClient) }
        .build()

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)

OAuth2AuthorizedClientProviderBuilder.builder().clientCredentials() 配置了一个 ClientCredentialsOAuth2AuthorizedClientProvider, 它是用于客户端凭证(Client Credentials)授权模式的 OAuth2AuthorizedClientProvider 的一个实现。spring-doc.cadn.net.cn

使用访问Tokens

请考虑以下用于 OAuth 2.0 客户端注册的 Spring Boot 属性:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            client-id: okta-client-id
            client-secret: okta-client-secret
            authorization-grant-type: client_credentials
            scope: read, write
        provider:
          okta:
            token-uri: https://dev-1234.oktapreview.com/oauth2/v1/token

进一步考虑以下 OAuth2AuthorizedClientManager @Beanspring-doc.cadn.net.cn

@Bean
public OAuth2AuthorizedClientManager authorizedClientManager(
		ClientRegistrationRepository clientRegistrationRepository,
		OAuth2AuthorizedClientRepository authorizedClientRepository) {

	OAuth2AuthorizedClientProvider authorizedClientProvider =
			OAuth2AuthorizedClientProviderBuilder.builder()
					.clientCredentials()
					.build();

	DefaultOAuth2AuthorizedClientManager authorizedClientManager =
			new DefaultOAuth2AuthorizedClientManager(
					clientRegistrationRepository, authorizedClientRepository);
	authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);

	return authorizedClientManager;
}
@Bean
fun authorizedClientManager(
        clientRegistrationRepository: ClientRegistrationRepository,
        authorizedClientRepository: OAuth2AuthorizedClientRepository): OAuth2AuthorizedClientManager {
    val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
            .clientCredentials()
            .build()
    val authorizedClientManager = DefaultOAuth2AuthorizedClientManager(
            clientRegistrationRepository, authorizedClientRepository)
    authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)
    return authorizedClientManager
}

根据上述属性和 Bean,你可以按如下方式获取 OAuth2AccessTokenspring-doc.cadn.net.cn

@Controller
public class OAuth2ClientController {

	@Autowired
	private OAuth2AuthorizedClientManager authorizedClientManager;

	@GetMapping("/")
	public String index(Authentication authentication,
						HttpServletRequest servletRequest,
						HttpServletResponse servletResponse) {

		OAuth2AuthorizeRequest authorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
				.principal(authentication)
				.attributes(attrs -> {
					attrs.put(HttpServletRequest.class.getName(), servletRequest);
					attrs.put(HttpServletResponse.class.getName(), servletResponse);
				})
				.build();
		OAuth2AuthorizedClient authorizedClient = this.authorizedClientManager.authorize(authorizeRequest);

		OAuth2AccessToken accessToken = authorizedClient.getAccessToken();

		// ...

		return "index";
	}
}
class OAuth2ClientController {

    @Autowired
    private lateinit var authorizedClientManager: OAuth2AuthorizedClientManager

    @GetMapping("/")
    fun index(authentication: Authentication?,
              servletRequest: HttpServletRequest,
              servletResponse: HttpServletResponse): String {
        val authorizeRequest: OAuth2AuthorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
                .principal(authentication)
                .attributes(Consumer { attrs: MutableMap<String, Any> ->
                    attrs[HttpServletRequest::class.java.name] = servletRequest
                    attrs[HttpServletResponse::class.java.name] = servletResponse
                })
                .build()
        val authorizedClient = authorizedClientManager.authorize(authorizeRequest)
        val accessToken: OAuth2AccessToken = authorizedClient.accessToken

        // ...

        return "index"
    }
}

HttpServletRequestHttpServletResponse 都是可选属性。 如果未提供,它们将默认使用 ServletRequestAttributes 获取的 RequestContextHolder.getRequestAttributes()spring-doc.cadn.net.cn

JWT Bearer

有关 JWT Bearer 授权的更多详细信息,请参阅《OAuth 2.0 客户端认证与授权许可的 JSON Web Token (JWT) 规范》。spring-doc.cadn.net.cn

请求访问Tokens

请参阅访问Tokens请求/响应协议流程,了解 JWT Bearer 授权类型。spring-doc.cadn.net.cn

用于 JWT Bearer 授权类型(grant)的 OAuth2AccessTokenResponseClient 默认实现是 RestClientJwtBearerTokenResponseClient,它使用一个 RestClient 实例在授权服务器的Tokens端点(Token Endpoint)获取访问Tokens。spring-doc.cadn.net.cn

RestClientJwtBearerTokenResponseClient 非常灵活,提供了多种选项用于自定义 JWT Bearer 授权的 OAuth 2.0 访问Tokens请求和响应。 请从以下使用场景中选择以了解更多信息:spring-doc.cadn.net.cn

自定义访问Tokens请求

RestClientJwtBearerTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens请求的 HTTP 请求头和请求参数的钩子。spring-doc.cadn.net.cn

自定义请求头

有两种自定义 HTTP 头部的选项:spring-doc.cadn.net.cn

你可以使用 addHeadersConverter() 方法添加额外的请求头,而不会影响每个请求默认添加的请求头。 以下示例在 User-AgentregistrationId 时,向请求中添加一个 spring 请求头:spring-doc.cadn.net.cn

包含额外的 HTTP 头部
RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.addHeadersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	HttpHeaders headers = new HttpHeaders();
	if (clientRegistration.getRegistrationId().equals("spring")) {
		headers.set(HttpHeaders.USER_AGENT, "my-user-agent");
	}
	return headers;
});
val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.addHeadersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val headers = HttpHeaders()
	if (clientRegistration.getRegistrationId() == "spring") {
        headers[HttpHeaders.USER_AGENT] = "my-user-agent"
	}
	headers
}

你可以通过复用 DefaultOAuth2TokenRequestHeadersConverter 或使用 setHeadersConverter() 提供自定义实现来完全自定义请求头。 以下示例复用了 DefaultOAuth2TokenRequestHeadersConverter,并禁用了 encodeClientCredentials,从而使得 HTTP Basic 凭据不再使用 application/x-www-form-urlencoded 进行编码:spring-doc.cadn.net.cn

自定义 HTTP 头部
DefaultOAuth2TokenRequestHeadersConverter headersConverter =
	new DefaultOAuth2TokenRequestHeadersConverter();
headersConverter.setEncodeClientCredentials(false);

RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.setHeadersConverter(headersConverter);
val headersConverter = DefaultOAuth2TokenRequestHeadersConverter()
headersConverter.setEncodeClientCredentials(false)

val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.setHeadersConverter(headersConverter)

自定义请求参数

有三种选项可用于自定义请求参数:spring-doc.cadn.net.cn

使用 setParametersConverter() 无法完全自定义参数,因为这将要求用户自行提供所有默认参数。 默认参数始终会被提供,但可以通过调用 setParametersCustomizer() 来完全自定义或省略这些参数。spring-doc.cadn.net.cn

你可以使用 addParametersConverter() 添加额外的参数,而不会影响每个请求中默认添加的参数。 以下示例在 audienceregistrationId 时,向请求中添加一个 keycloak 参数:spring-doc.cadn.net.cn

包含额外的请求参数
RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.addParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>();
	if (clientRegistration.getRegistrationId().equals("keycloak")) {
		parameters.set(OAuth2ParameterNames.AUDIENCE, "my-audience");
	}
	return parameters;
});
val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.addParametersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "keycloak") {
        parameters[OAuth2ParameterNames.AUDIENCE] = "my-audience"
	}
	parameters
}

你可以使用 setParametersConverter() 来覆盖默认参数。 以下示例在 client_idregistrationId 时,覆盖了 okta 参数:spring-doc.cadn.net.cn

覆盖请求参数
RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.setParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	LinkedMultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
	if (clientRegistration.getRegistrationId().equals("okta")) {
		parameters.set(OAuth2ParameterNames.CLIENT_ID, "my-client");
	}
	return parameters;
});
val parametersConverter = DefaultOAuth2TokenRequestParametersConverter<JwtBearerGrantRequest>()
parametersConverter.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.setParametersConverter { grantRequest ->
    val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "okta") {
        parameters[OAuth2ParameterNames.CLIENT_ID] = "my-client"
	}
	parameters
}

您可以使用 setParametersCustomizer() 完全自定义参数(包括省略默认参数)。 以下示例在请求中包含 client_id 参数时,省略了 client_assertion 参数:spring-doc.cadn.net.cn

省略请求参数
RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.setParametersCustomizer(parameters -> {
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID);
	}
});
val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

自定义访问Tokens响应

RestClientJwtBearerTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens响应的响应参数和错误处理的钩子。spring-doc.cadn.net.cn

自定义RestClient

您可以通过向 RestClient 提供一个预先配置好的 setRestClient() 来自定义Tokens(Token)响应。 默认的 RestClient 配置如下:spring-doc.cadn.net.cn

默认的 RestClient 配置
RestClient restClient = RestClient.builder()
	.messageConverters(messageConverters -> {
		messageConverters.clear();
		messageConverters.add(new FormHttpMessageConverter());
		messageConverters.add(new OAuth2AccessTokenResponseHttpMessageConverter());
	})
	.defaultStatusHandler(new OAuth2ErrorResponseErrorHandler())
	.build();

RestClientJwtBearerTokenResponseClient accessTokenResponseClient =
	new RestClientJwtBearerTokenResponseClient();
accessTokenResponseClient.setRestClient(restClient);
val restClient = RestClient.builder()
	.messageConverters { messageConverters ->
		messageConverters.clear()
		messageConverters.add(FormHttpMessageConverter())
		messageConverters.add(OAuth2AccessTokenResponseHttpMessageConverter())
	}
	.defaultStatusHandler(OAuth2ErrorResponseErrorHandler())
	.build()

val accessTokenResponseClient = RestClientJwtBearerTokenResponseClient()
accessTokenResponseClient.setRestClient(restClient)

OAuth2AccessTokenResponseHttpMessageConverter 是用于 OAuth 2.0 访问Tokens响应的 HttpMessageConverter。 您可以通过调用 OAuth2AccessTokenResponse 方法来自定义Tokens响应参数到 setAccessTokenResponseConverter() 的转换。 默认实现为 DefaultMapOAuth2AccessTokenResponseConverterspring-doc.cadn.net.cn

OAuth2ErrorResponseErrorHandler 是一个 ResponseErrorHandler,可用于处理 OAuth 2.0 错误,例如 400 Bad Request。 它使用 OAuth2ErrorHttpMessageConverter 将 OAuth 2.0 错误参数转换为 OAuth2Error。 您可以通过调用 OAuth2Error 方法来自定义Tokens响应参数到 setErrorConverter() 的转换过程。spring-doc.cadn.net.cn

需要 Spring MVC 的 FormHttpMessageConverter,因为它在发送 OAuth 2.0 访问Tokens请求时会被使用。spring-doc.cadn.net.cn

自定义响应参数

以下示例为自定义Tokens响应参数转换为 OAuth2AccessTokenResponse 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens响应转换器
OAuth2AccessTokenResponseHttpMessageConverter accessTokenResponseMessageConverter =
	new OAuth2AccessTokenResponseHttpMessageConverter();
accessTokenResponseMessageConverter.setAccessTokenResponseConverter(parameters -> {
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build();
});
val accessTokenResponseMessageConverter = OAuth2AccessTokenResponseHttpMessageConverter()
accessTokenResponseMessageConverter.setAccessTokenResponseConverter { parameters ->
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build()
}

自定义错误处理

以下示例为自定义将 Error 参数转换为 OAuth2Error 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens错误处理器
OAuth2ErrorHttpMessageConverter errorConverter =
	new OAuth2ErrorHttpMessageConverter();
errorConverter.setErrorConverter(parameters -> {
	// ...
	return new OAuth2Error("custom-error", "custom description", "custom-uri");
});

OAuth2ErrorResponseErrorHandler errorHandler =
	new OAuth2ErrorResponseErrorHandler();
errorHandler.setErrorConverter(errorConverter);
val errorConverter = OAuth2ErrorHttpMessageConverter()
errorConverter.setErrorConverter { parameters ->
	// ...
	return OAuth2Error("custom-error", "custom description", "custom-uri")
}

val errorHandler = OAuth2ErrorResponseErrorHandler()
errorHandler.setErrorConverter(errorConverter)

使用构建器进行自定义

是否自定义RestClientJwtBearerTokenResponseClient或提供您自己的OAuth2AccessTokenResponseClient的实现,您可以使用OAuth2AuthorizedClientProviderBuilder对其进行配置(作为发布bean的一个替代方案),如下所示:spring-doc.cadn.net.cn

通过构建器配置访问Tokens响应
// Customize
OAuth2AccessTokenResponseClient<JwtBearerGrantRequest> jwtBearerTokenResponseClient = ...

JwtBearerOAuth2AuthorizedClientProvider jwtBearerAuthorizedClientProvider = new JwtBearerOAuth2AuthorizedClientProvider();
jwtBearerAuthorizedClientProvider.setAccessTokenResponseClient(jwtBearerTokenResponseClient);

OAuth2AuthorizedClientProvider authorizedClientProvider =
		OAuth2AuthorizedClientProviderBuilder.builder()
				.provider(jwtBearerAuthorizedClientProvider)
				.build();

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);
// Customize
val jwtBearerTokenResponseClient: OAuth2AccessTokenResponseClient<JwtBearerGrantRequest> = ...

val jwtBearerAuthorizedClientProvider = JwtBearerOAuth2AuthorizedClientProvider()
jwtBearerAuthorizedClientProvider.setAccessTokenResponseClient(jwtBearerTokenResponseClient)

val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
        .provider(jwtBearerAuthorizedClientProvider)
        .build()

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)

使用访问Tokens

给定以下用于 OAuth 2.0 客户端注册的 Spring Boot 属性:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            client-id: okta-client-id
            client-secret: okta-client-secret
            authorization-grant-type: urn:ietf:params:oauth:grant-type:jwt-bearer
            scope: read
        provider:
          okta:
            token-uri: https://dev-1234.oktapreview.com/oauth2/v1/token

... 和 OAuth2AuthorizedClientManager @Bean:spring-doc.cadn.net.cn

@Bean
public OAuth2AuthorizedClientManager authorizedClientManager(
		ClientRegistrationRepository clientRegistrationRepository,
		OAuth2AuthorizedClientRepository authorizedClientRepository) {

	JwtBearerOAuth2AuthorizedClientProvider jwtBearerAuthorizedClientProvider =
			new JwtBearerOAuth2AuthorizedClientProvider();

	OAuth2AuthorizedClientProvider authorizedClientProvider =
			OAuth2AuthorizedClientProviderBuilder.builder()
					.provider(jwtBearerAuthorizedClientProvider)
					.build();

	DefaultOAuth2AuthorizedClientManager authorizedClientManager =
			new DefaultOAuth2AuthorizedClientManager(
					clientRegistrationRepository, authorizedClientRepository);
	authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);

	return authorizedClientManager;
}
@Bean
fun authorizedClientManager(
        clientRegistrationRepository: ClientRegistrationRepository,
        authorizedClientRepository: OAuth2AuthorizedClientRepository): OAuth2AuthorizedClientManager {
    val jwtBearerAuthorizedClientProvider = JwtBearerOAuth2AuthorizedClientProvider()
    val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
            .provider(jwtBearerAuthorizedClientProvider)
            .build()
    val authorizedClientManager = DefaultOAuth2AuthorizedClientManager(
            clientRegistrationRepository, authorizedClientRepository)
    authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)
    return authorizedClientManager
}

您可以按如下方式获取 OAuth2AccessTokenspring-doc.cadn.net.cn

@RestController
public class OAuth2ResourceServerController {

	@Autowired
	private OAuth2AuthorizedClientManager authorizedClientManager;

	@GetMapping("/resource")
	public String resource(JwtAuthenticationToken jwtAuthentication) {
		OAuth2AuthorizeRequest authorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
				.principal(jwtAuthentication)
				.build();
		OAuth2AuthorizedClient authorizedClient = this.authorizedClientManager.authorize(authorizeRequest);
		OAuth2AccessToken accessToken = authorizedClient.getAccessToken();

		// ...

	}
}
class OAuth2ResourceServerController {

    @Autowired
    private lateinit var authorizedClientManager: OAuth2AuthorizedClientManager

    @GetMapping("/resource")
    fun resource(jwtAuthentication: JwtAuthenticationToken?): String {
        val authorizeRequest: OAuth2AuthorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
                .principal(jwtAuthentication)
                .build()
        val authorizedClient = authorizedClientManager.authorize(authorizeRequest)
        val accessToken: OAuth2AccessToken = authorizedClient.accessToken

        // ...

    }
}

JwtBearerOAuth2AuthorizedClientProvider 默认通过 Jwt 解决 OAuth2AuthorizationContext.getPrincipal().getPrincipal() 断言,因此在前面的示例中使用了 JwtAuthenticationTokenspring-doc.cadn.net.cn

如果你需要从其他来源解析 Jwt 断言,可以向 JwtBearerOAuth2AuthorizedClientProvider.setJwtAssertionResolver() 提供一个自定义的 Function<OAuth2AuthorizationContext, Jwt>spring-doc.cadn.net.cn

Tokens交换

有关Tokens交换授权的更多详细信息,请参阅 OAuth 2.0 Tokens交换。spring-doc.cadn.net.cn

请求访问Tokens

请参阅Tokens交换请求与响应协议流程,了解Tokens交换授权的相关内容。spring-doc.cadn.net.cn

用于 Token Exchange 授权类型的 OAuth2AccessTokenResponseClient 默认实现是 RestClientTokenExchangeTokenResponseClient,它使用一个 RestClient 实例在授权服务器的Tokens端点(Token Endpoint)获取访问Tokens。spring-doc.cadn.net.cn

RestClientTokenExchangeTokenResponseClient 非常灵活,并提供了多种选项来自定义 OAuth 2.0 Access Token 的请求和响应(针对 Token Exchange 授予方式)。 选择以下用例以获取更多信息:spring-doc.cadn.net.cn

自定义访问Tokens请求

RestClientTokenExchangeTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens请求的 HTTP 请求头和请求参数的钩子。spring-doc.cadn.net.cn

自定义请求头

有两种自定义 HTTP 头部的选项:spring-doc.cadn.net.cn

你可以使用 addHeadersConverter() 方法添加额外的请求头,而不会影响每个请求默认添加的请求头。 以下示例在 User-AgentregistrationId 时,向请求中添加一个 spring 请求头:spring-doc.cadn.net.cn

包含额外的 HTTP 头部
RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.addHeadersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	HttpHeaders headers = new HttpHeaders();
	if (clientRegistration.getRegistrationId().equals("spring")) {
		headers.set(HttpHeaders.USER_AGENT, "my-user-agent");
	}
	return headers;
});
val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.addHeadersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val headers = HttpHeaders()
	if (clientRegistration.getRegistrationId() == "spring") {
        headers[HttpHeaders.USER_AGENT] = "my-user-agent"
	}
	headers
}

你可以通过复用 DefaultOAuth2TokenRequestHeadersConverter 或使用 setHeadersConverter() 提供自定义实现来完全自定义请求头。 以下示例复用了 DefaultOAuth2TokenRequestHeadersConverter,并禁用了 encodeClientCredentials,从而使得 HTTP Basic 凭据不再使用 application/x-www-form-urlencoded 进行编码:spring-doc.cadn.net.cn

自定义 HTTP 头部
DefaultOAuth2TokenRequestHeadersConverter headersConverter =
	new DefaultOAuth2TokenRequestHeadersConverter();
headersConverter.setEncodeClientCredentials(false);

RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.setHeadersConverter(headersConverter);
val headersConverter = DefaultOAuth2TokenRequestHeadersConverter()
headersConverter.setEncodeClientCredentials(false)

val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.setHeadersConverter(headersConverter)

自定义请求参数

有三种选项可用于自定义请求参数:spring-doc.cadn.net.cn

使用 setParametersConverter() 无法完全自定义参数,因为这将要求用户自行提供所有默认参数。 默认参数始终会被提供,但可以通过调用 setParametersCustomizer() 来完全自定义或省略这些参数。spring-doc.cadn.net.cn

你可以使用 addParametersConverter() 添加额外的参数,而不会影响每个请求中默认添加的参数。 以下示例在 audienceregistrationId 时,向请求中添加一个 keycloak 参数:spring-doc.cadn.net.cn

包含额外的请求参数
RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.addParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>();
	if (clientRegistration.getRegistrationId().equals("keycloak")) {
		parameters.set(OAuth2ParameterNames.AUDIENCE, "my-audience");
	}
	return parameters;
});
val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.addParametersConverter { grantRequest ->
	val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "keycloak") {
        parameters[OAuth2ParameterNames.AUDIENCE] = "my-audience"
	}
	parameters
}

你可以使用 setParametersConverter() 来覆盖默认参数。 以下示例在 client_idregistrationId 时,覆盖了 okta 参数:spring-doc.cadn.net.cn

覆盖请求参数
RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.setParametersConverter(grantRequest -> {
	ClientRegistration clientRegistration = grantRequest.getClientRegistration();
	LinkedMultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
	if (clientRegistration.getRegistrationId().equals("okta")) {
		parameters.set(OAuth2ParameterNames.CLIENT_ID, "my-client");
	}
	return parameters;
});
val parametersConverter = DefaultOAuth2TokenRequestParametersConverter<TokenExchangeGrantRequest>()
parametersConverter.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.setParametersConverter { grantRequest ->
    val clientRegistration = grantRequest.getClientRegistration()
	val parameters = LinkedMultiValueMap<String, String>()
	if (clientRegistration.getRegistrationId() == "okta") {
        parameters[OAuth2ParameterNames.CLIENT_ID] = "my-client"
	}
	parameters
}

您可以使用 setParametersCustomizer() 完全自定义参数(包括省略默认参数)。 以下示例在请求中包含 client_id 参数时,省略了 client_assertion 参数:spring-doc.cadn.net.cn

省略请求参数
RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.setParametersCustomizer(parameters -> {
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID);
	}
});
val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.setParametersCustomizer { parameters ->
	if (parameters.containsKey(OAuth2ParameterNames.CLIENT_ASSERTION)) {
		parameters.remove(OAuth2ParameterNames.CLIENT_ID)
	}
}

自定义访问Tokens响应

RestClientTokenExchangeTokenResponseClient 提供了用于自定义 OAuth 2.0 访问Tokens响应的响应参数和错误处理的钩子。spring-doc.cadn.net.cn

自定义RestClient

您可以通过向 RestClient 提供一个预先配置好的 setRestClient() 来自定义Tokens(Token)响应。 默认的 RestClient 配置如下:spring-doc.cadn.net.cn

默认的 RestClient 配置
RestClient restClient = RestClient.builder()
	.messageConverters(messageConverters -> {
		messageConverters.clear();
		messageConverters.add(new FormHttpMessageConverter());
		messageConverters.add(new OAuth2AccessTokenResponseHttpMessageConverter());
	})
	.defaultStatusHandler(new OAuth2ErrorResponseErrorHandler())
	.build();

RestClientTokenExchangeTokenResponseClient accessTokenResponseClient =
	new RestClientTokenExchangeTokenResponseClient();
accessTokenResponseClient.setRestClient(restClient);
val restClient = RestClient.builder()
	.messageConverters { messageConverters ->
		messageConverters.clear()
		messageConverters.add(FormHttpMessageConverter())
		messageConverters.add(OAuth2AccessTokenResponseHttpMessageConverter())
	}
	.defaultStatusHandler(OAuth2ErrorResponseErrorHandler())
	.build()

val accessTokenResponseClient = RestClientTokenExchangeTokenResponseClient()
accessTokenResponseClient.setRestClient(restClient)

OAuth2AccessTokenResponseHttpMessageConverter 是用于 OAuth 2.0 访问Tokens响应的 HttpMessageConverter。 您可以通过调用 OAuth2AccessTokenResponse 方法来自定义Tokens响应参数到 setAccessTokenResponseConverter() 的转换。 默认实现为 DefaultMapOAuth2AccessTokenResponseConverterspring-doc.cadn.net.cn

OAuth2ErrorResponseErrorHandler 是一个 ResponseErrorHandler,可用于处理 OAuth 2.0 错误,例如 400 Bad Request。 它使用 OAuth2ErrorHttpMessageConverter 将 OAuth 2.0 错误参数转换为 OAuth2Error。 您可以通过调用 OAuth2Error 方法来自定义Tokens响应参数到 setErrorConverter() 的转换过程。spring-doc.cadn.net.cn

需要 Spring MVC 的 FormHttpMessageConverter,因为它在发送 OAuth 2.0 访问Tokens请求时会被使用。spring-doc.cadn.net.cn

自定义响应参数

以下示例为自定义Tokens响应参数转换为 OAuth2AccessTokenResponse 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens响应转换器
OAuth2AccessTokenResponseHttpMessageConverter accessTokenResponseMessageConverter =
	new OAuth2AccessTokenResponseHttpMessageConverter();
accessTokenResponseMessageConverter.setAccessTokenResponseConverter(parameters -> {
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build();
});
val accessTokenResponseMessageConverter = OAuth2AccessTokenResponseHttpMessageConverter()
accessTokenResponseMessageConverter.setAccessTokenResponseConverter { parameters ->
	// ...
	return OAuth2AccessTokenResponse.withToken("custom-token")
		// ...
		.build()
}

自定义错误处理

以下示例为自定义将 Error 参数转换为 OAuth2Error 提供了一个起点:spring-doc.cadn.net.cn

自定义访问Tokens错误处理器
OAuth2ErrorHttpMessageConverter errorConverter =
	new OAuth2ErrorHttpMessageConverter();
errorConverter.setErrorConverter(parameters -> {
	// ...
	return new OAuth2Error("custom-error", "custom description", "custom-uri");
});

OAuth2ErrorResponseErrorHandler errorHandler =
	new OAuth2ErrorResponseErrorHandler();
errorHandler.setErrorConverter(errorConverter);
val errorConverter = OAuth2ErrorHttpMessageConverter()
errorConverter.setErrorConverter { parameters ->
	// ...
	return OAuth2Error("custom-error", "custom description", "custom-uri")
}

val errorHandler = OAuth2ErrorResponseErrorHandler()
errorHandler.setErrorConverter(errorConverter)

使用构建器进行自定义

是否自定义RestClientTokenExchangeTokenResponseClient或提供您自己的OAuth2AccessTokenResponseClient的实现,您可以使用OAuth2AuthorizedClientProviderBuilder对其进行配置(作为发布bean的一个替代方案),如下所示:spring-doc.cadn.net.cn

通过构建器配置访问Tokens响应
// Customize
OAuth2AccessTokenResponseClient<TokenExchangeGrantRequest> tokenExchangeTokenResponseClient = ...

TokenExchangeOAuth2AuthorizedClientProvider tokenExchangeAuthorizedClientProvider = new TokenExchangeOAuth2AuthorizedClientProvider();
tokenExchangeAuthorizedClientProvider.setAccessTokenResponseClient(tokenExchangeTokenResponseClient);

OAuth2AuthorizedClientProvider authorizedClientProvider =
		OAuth2AuthorizedClientProviderBuilder.builder()
				.provider(tokenExchangeAuthorizedClientProvider)
				.build();

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);
// Customize
val tokenExchangeTokenResponseClient: OAuth2AccessTokenResponseClient<TokenExchangeGrantRequest> = ...

val tokenExchangeAuthorizedClientProvider = TokenExchangeOAuth2AuthorizedClientProvider()
tokenExchangeAuthorizedClientProvider.setAccessTokenResponseClient(tokenExchangeTokenResponseClient)

val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
        .provider(tokenExchangeAuthorizedClientProvider)
        .build()

// ...

authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)

使用访问Tokens

给定以下用于 OAuth 2.0 客户端注册的 Spring Boot 属性:spring-doc.cadn.net.cn

spring:
  security:
    oauth2:
      client:
        registration:
          okta:
            client-id: okta-client-id
            client-secret: okta-client-secret
            authorization-grant-type: urn:ietf:params:oauth:grant-type:token-exchange
            scope: read
        provider:
          okta:
            token-uri: https://dev-1234.oktapreview.com/oauth2/v1/token

... 和 OAuth2AuthorizedClientManager @Bean:spring-doc.cadn.net.cn

@Bean
public OAuth2AuthorizedClientManager authorizedClientManager(
		ClientRegistrationRepository clientRegistrationRepository,
		OAuth2AuthorizedClientRepository authorizedClientRepository) {

	TokenExchangeOAuth2AuthorizedClientProvider tokenExchangeAuthorizedClientProvider =
			new TokenExchangeOAuth2AuthorizedClientProvider();

	OAuth2AuthorizedClientProvider authorizedClientProvider =
			OAuth2AuthorizedClientProviderBuilder.builder()
					.provider(tokenExchangeAuthorizedClientProvider)
					.build();

	DefaultOAuth2AuthorizedClientManager authorizedClientManager =
			new DefaultOAuth2AuthorizedClientManager(
					clientRegistrationRepository, authorizedClientRepository);
	authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider);

	return authorizedClientManager;
}
@Bean
fun authorizedClientManager(
        clientRegistrationRepository: ClientRegistrationRepository,
        authorizedClientRepository: OAuth2AuthorizedClientRepository): OAuth2AuthorizedClientManager {
    val tokenExchangeAuthorizedClientProvider = TokenExchangeOAuth2AuthorizedClientProvider()
    val authorizedClientProvider = OAuth2AuthorizedClientProviderBuilder.builder()
            .provider(tokenExchangeAuthorizedClientProvider)
            .build()
    val authorizedClientManager = DefaultOAuth2AuthorizedClientManager(
            clientRegistrationRepository, authorizedClientRepository)
    authorizedClientManager.setAuthorizedClientProvider(authorizedClientProvider)
    return authorizedClientManager
}

您可以按如下方式获取 OAuth2AccessTokenspring-doc.cadn.net.cn

@RestController
public class OAuth2ResourceServerController {

	@Autowired
	private OAuth2AuthorizedClientManager authorizedClientManager;

	@GetMapping("/resource")
	public String resource(JwtAuthenticationToken jwtAuthentication) {
		OAuth2AuthorizeRequest authorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
				.principal(jwtAuthentication)
				.build();
		OAuth2AuthorizedClient authorizedClient = this.authorizedClientManager.authorize(authorizeRequest);
		OAuth2AccessToken accessToken = authorizedClient.getAccessToken();

		// ...

	}
}
class OAuth2ResourceServerController {

    @Autowired
    private lateinit var authorizedClientManager: OAuth2AuthorizedClientManager

    @GetMapping("/resource")
    fun resource(jwtAuthentication: JwtAuthenticationToken?): String {
        val authorizeRequest: OAuth2AuthorizeRequest = OAuth2AuthorizeRequest.withClientRegistrationId("okta")
                .principal(jwtAuthentication)
                .build()
        val authorizedClient = authorizedClientManager.authorize(authorizeRequest)
        val accessToken: OAuth2AccessToken = authorizedClient.accessToken

        // ...

    }
}

TokenExchangeOAuth2AuthorizedClientProvider 默认通过 OAuth2Token 解决主体Tokens(作为 OAuth2AuthorizationContext.getPrincipal().getPrincipal()),因此前面示例中使用了 JwtAuthenticationToken
默认情况下,不会解析行为者Tokens。spring-doc.cadn.net.cn

如果你需要从不同的来源解析主体Tokens(subject token),可以向 TokenExchangeOAuth2AuthorizedClientProvider.setSubjectTokenResolver() 提供一个自定义的 Function<OAuth2AuthorizationContext, OAuth2Token>spring-doc.cadn.net.cn

如果你需要解析一个参与者(actor)Tokens,可以向 TokenExchangeOAuth2AuthorizedClientProvider.setActorTokenResolver() 提供一个自定义的 Function<OAuth2AuthorizationContext, OAuth2Token>spring-doc.cadn.net.cn