此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Security 6.4.1! |
授权客户端功能
本节介绍 Spring Security 为 OAuth2 客户端提供的其他功能。
解析授权客户端
这@RegisteredOAuth2AuthorizedClient
annotation 提供了将 method 参数解析为 type 为 argument 值的功能OAuth2AuthorizedClient
.
与访问OAuth2AuthorizedClient
通过使用OAuth2AuthorizedClientManager
或OAuth2AuthorizedClientService
.
以下示例演示如何使用@RegisteredOAuth2AuthorizedClient
:
-
Java
-
Kotlin
@Controller
public class OAuth2ClientController {
@GetMapping("/")
public String index(@RegisteredOAuth2AuthorizedClient("okta") OAuth2AuthorizedClient authorizedClient) {
OAuth2AccessToken accessToken = authorizedClient.getAccessToken();
...
return "index";
}
}
@Controller
class OAuth2ClientController {
@GetMapping("/")
fun index(@RegisteredOAuth2AuthorizedClient("okta") authorizedClient: OAuth2AuthorizedClient): String {
val accessToken = authorizedClient.accessToken
...
return "index"
}
}
这@RegisteredOAuth2AuthorizedClient
annotation 由OAuth2AuthorizedClientArgumentResolver
,它直接使用OAuth2AuthorizedClientManager
因此,继承了它的能力。
用于 Servlet 环境的 WebClient 集成
OAuth 2.0 客户端支持与WebClient
通过使用ExchangeFilterFunction
.
这ServletOAuth2AuthorizedClientExchangeFilterFunction
提供了一种使用OAuth2AuthorizedClient
并包括关联的OAuth2AccessToken
作为 Bearer Token 进行验证。
它直接使用OAuth2AuthorizedClientManager
因此,继承了以下功能:
-
一
OAuth2AccessToken
如果客户端尚未获得授权,则请求。-
authorization_code
:触发 Authorization Request 重定向以启动流。 -
client_credentials
:访问令牌直接从 Token Endpoint 获取。 -
password
:访问令牌直接从 Token Endpoint 获取。
-
-
如果
OAuth2AccessToken
已过期,则如果OAuth2AuthorizedClientProvider
可用于执行授权
以下代码显示了如何配置WebClient
使用 OAuth 2.0 客户端支持:
-
Java
-
Kotlin
@Bean
WebClient webClient(OAuth2AuthorizedClientManager authorizedClientManager) {
ServletOAuth2AuthorizedClientExchangeFilterFunction oauth2Client =
new ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager);
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build();
}
@Bean
fun webClient(authorizedClientManager: OAuth2AuthorizedClientManager?): WebClient {
val oauth2Client = ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager)
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build()
}
提供授权客户
这ServletOAuth2AuthorizedClientExchangeFilterFunction
通过解析OAuth2AuthorizedClient
从ClientRequest.attributes()
(请求属性)。
以下代码演示如何设置OAuth2AuthorizedClient
作为请求属性:
-
Java
-
Kotlin
@GetMapping("/")
public String index(@RegisteredOAuth2AuthorizedClient("okta") OAuth2AuthorizedClient authorizedClient) {
String resourceUri = ...
String body = webClient
.get()
.uri(resourceUri)
.attributes(oauth2AuthorizedClient(authorizedClient)) (1)
.retrieve()
.bodyToMono(String.class)
.block();
...
return "index";
}
@GetMapping("/")
fun index(@RegisteredOAuth2AuthorizedClient("okta") authorizedClient: OAuth2AuthorizedClient): String {
val resourceUri: String = ...
val body: String = webClient
.get()
.uri(resourceUri)
.attributes(oauth2AuthorizedClient(authorizedClient)) (1)
.retrieve()
.bodyToMono()
.block()
...
return "index"
}
1 | oauth2AuthorizedClient() 是一个static method 中ServletOAuth2AuthorizedClientExchangeFilterFunction . |
以下代码演示如何设置ClientRegistration.getRegistrationId()
作为请求属性:
-
Java
-
Kotlin
@GetMapping("/")
public String index() {
String resourceUri = ...
String body = webClient
.get()
.uri(resourceUri)
.attributes(clientRegistrationId("okta")) (1)
.retrieve()
.bodyToMono(String.class)
.block();
...
return "index";
}
@GetMapping("/")
fun index(): String {
val resourceUri: String = ...
val body: String = webClient
.get()
.uri(resourceUri)
.attributes(clientRegistrationId("okta")) (1)
.retrieve()
.bodyToMono()
.block()
...
return "index"
}
1 | clientRegistrationId() 是一个static method 中ServletOAuth2AuthorizedClientExchangeFilterFunction . |
以下代码演示如何设置Authentication
作为请求属性:
-
Java
-
Kotlin
@GetMapping("/")
public String index() {
String resourceUri = ...
Authentication anonymousAuthentication = new AnonymousAuthenticationToken(
"anonymous", "anonymousUser", AuthorityUtils.createAuthorityList("ROLE_ANONYMOUS"));
String body = webClient
.get()
.uri(resourceUri)
.attributes(authentication(anonymousAuthentication)) (1)
.retrieve()
.bodyToMono(String.class)
.block();
...
return "index";
}
@GetMapping("/")
fun index(): String {
val resourceUri: String = ...
val anonymousAuthentication: Authentication = AnonymousAuthenticationToken(
"anonymous", "anonymousUser", AuthorityUtils.createAuthorityList("ROLE_ANONYMOUS"))
val body: String = webClient
.get()
.uri(resourceUri)
.attributes(authentication(anonymousAuthentication)) (1)
.retrieve()
.bodyToMono()
.block()
...
return "index"
}
1 | authentication() 是一个static method 中ServletOAuth2AuthorizedClientExchangeFilterFunction . |
建议谨慎使用此功能,因为所有 HTTP 请求都将收到绑定到提供的委托人的访问令牌。 |
默认授权客户端
如果两者都不是OAuth2AuthorizedClient
或ClientRegistration.getRegistrationId()
作为请求属性提供,ServletOAuth2AuthorizedClientExchangeFilterFunction
可以确定要使用的默认客户端,具体取决于其配置。
如果setDefaultOAuth2AuthorizedClient(true)
,并且用户已使用HttpSecurity.oauth2Login()
这OAuth2AccessToken
与当前OAuth2AuthenticationToken
被使用。
以下代码显示了具体配置:
-
Java
-
Kotlin
@Bean
WebClient webClient(OAuth2AuthorizedClientManager authorizedClientManager) {
ServletOAuth2AuthorizedClientExchangeFilterFunction oauth2Client =
new ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager);
oauth2Client.setDefaultOAuth2AuthorizedClient(true);
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build();
}
@Bean
fun webClient(authorizedClientManager: OAuth2AuthorizedClientManager?): WebClient {
val oauth2Client = ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager)
oauth2Client.setDefaultOAuth2AuthorizedClient(true)
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build()
}
请谨慎使用此功能,因为所有 HTTP 请求都会收到访问令牌。 |
或者,如果setDefaultClientRegistrationId("okta")
配置了有效的ClientRegistration
这OAuth2AccessToken
与OAuth2AuthorizedClient
被使用。
以下代码显示了具体配置:
-
Java
-
Kotlin
@Bean
WebClient webClient(OAuth2AuthorizedClientManager authorizedClientManager) {
ServletOAuth2AuthorizedClientExchangeFilterFunction oauth2Client =
new ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager);
oauth2Client.setDefaultClientRegistrationId("okta");
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build();
}
@Bean
fun webClient(authorizedClientManager: OAuth2AuthorizedClientManager?): WebClient {
val oauth2Client = ServletOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager)
oauth2Client.setDefaultClientRegistrationId("okta")
return WebClient.builder()
.apply(oauth2Client.oauth2Configuration())
.build()
}
请谨慎使用此功能,因为所有 HTTP 请求都会收到访问令牌。 |