|
对于最新的稳定版本,请使用 Spring Security 6.5.3! |
测试 OAuth 2.0
当谈到 OAuth 2.0 时,前面介绍的相同原则仍然适用:最终,这取决于你被测的方法期望在SecurityContextHolder.
例如,对于如下所示的控制器:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(Principal user) {
return Mono.just(user.getName());
}
@GetMapping("/endpoint")
fun foo(user: Principal): Mono<String> {
return Mono.just(user.name)
}
它没有特定于 OAuth2 的内容,因此您可能能够简单地用@WithMockUser并且没事。
但是,如果您的控制器绑定到 Spring Security 的 OAuth 2.0 支持的某些方面,如下所示:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@AuthenticationPrincipal OidcUser user) {
return Mono.just(user.getIdToken().getSubject());
}
@GetMapping("/endpoint")
fun foo(@AuthenticationPrincipal user: OidcUser): Mono<String> {
return Mono.just(user.idToken.subject)
}
那么 Spring Security 的测试支持就可以派上用场了。
测试 OIDC 登录
使用WebTestClient需要使用授权服务器模拟某种授权流。
当然,这将是一项艰巨的任务,这就是为什么 Spring Security 附带了删除此样板的支持。
例如,我们可以告诉 Spring Security 包含默认值OidcUser使用SecurityMockServerConfigurers#mockOidcLogin方法,如下所示:
-
Java
-
Kotlin
client
.mutateWith(mockOidcLogin()).get().uri("/endpoint").exchange();
client
.mutateWith(mockOidcLogin())
.get().uri("/endpoint")
.exchange()
这将要做的是配置关联的MockServerRequest使用OidcUser其中包括一个简单的OidcIdToken,OidcUserInfo和Collection授予的权力。
具体来说,它将包括一个OidcIdToken使用sub声明设置为user:
-
Java
-
Kotlin
assertThat(user.getIdToken().getClaim("sub")).isEqualTo("user");
assertThat(user.idToken.getClaim<String>("sub")).isEqualTo("user")
一OidcUserInfo未设置索赔:
-
Java
-
Kotlin
assertThat(user.getUserInfo().getClaims()).isEmpty();
assertThat(user.userInfo.claims).isEmpty()
和Collection只有一个权限的权威,SCOPE_read:
-
Java
-
Kotlin
assertThat(user.getAuthorities()).hasSize(1);
assertThat(user.getAuthorities()).containsExactly(new SimpleGrantedAuthority("SCOPE_read"));
assertThat(user.authorities).hasSize(1)
assertThat(user.authorities).containsExactly(SimpleGrantedAuthority("SCOPE_read"))
Spring Security 执行必要的工作以确保OidcUser实例可用于这@AuthenticationPrincipal注解.
此外,它还链接了OidcUser转换为OAuth2AuthorizedClient它存入模拟ServerOAuth2AuthorizedClientRepository.
如果您的测试使用@RegisteredOAuth2AuthorizedClient注解..
配置权限
在许多情况下,您的方法受过滤器或方法安全性的保护,并且需要您的Authentication让某些授权机构允许该请求。
在这种情况下,您可以使用authorities()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOidcLogin()
.authorities(new SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOidcLogin()
.authorities(SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange()
配置声明
虽然授予的权限在所有 Spring Security 中都很常见,但我们在 OAuth 2.0 的情况下也有声明。
例如,假设您有一个user_id声明,指示系统中的用户 ID。
您可以在控制器中像这样访问它:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@AuthenticationPrincipal OidcUser oidcUser) {
String userId = oidcUser.getIdToken().getClaim("user_id");
// ...
}
@GetMapping("/endpoint")
fun foo(@AuthenticationPrincipal oidcUser: OidcUser): Mono<String> {
val userId = oidcUser.idToken.getClaim<String>("user_id")
// ...
}
在这种情况下,您需要使用idToken()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOidcLogin()
.idToken(token -> token.claim("user_id", "1234"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOidcLogin()
.idToken { token -> token.claim("user_id", "1234") }
)
.get().uri("/endpoint").exchange()
因为OidcUser从OidcIdToken.
其他配置
还有其他方法用于进一步配置身份验证;这仅取决于您的控制者期望哪些数据:
-
userInfo(OidcUserInfo.Builder)- 用于配置OidcUserInfo实例 -
clientRegistration(ClientRegistration)- 用于配置关联的OAuth2AuthorizedClient使用给定的ClientRegistration -
oidcUser(OidcUser)- 用于配置完整的OidcUser实例
如果您满足以下条件,最后一个会很方便:
1. 拥有自己的实现OidcUser或
2.需要更改名称属性
例如,假设您的授权服务器在user_name声明而不是sub索赔。
在这种情况下,您可以配置OidcUser手工:
-
Java
-
Kotlin
OidcUser oidcUser = new DefaultOidcUser(
AuthorityUtils.createAuthorityList("SCOPE_message:read"),
OidcIdToken.withTokenValue("id-token").claim("user_name", "foo_user").build(),
"user_name");
client
.mutateWith(mockOidcLogin().oidcUser(oidcUser))
.get().uri("/endpoint").exchange();
val oidcUser: OidcUser = DefaultOidcUser(
AuthorityUtils.createAuthorityList("SCOPE_message:read"),
OidcIdToken.withTokenValue("id-token").claim("user_name", "foo_user").build(),
"user_name"
)
client
.mutateWith(mockOidcLogin().oidcUser(oidcUser))
.get().uri("/endpoint").exchange()
测试 OAuth 2.0 登录
与测试 OIDC 登录一样,测试 OAuth 2.0 登录也面临着模拟授权流的类似挑战。 正因为如此,Spring Security 还为非 OIDC 用例提供了测试支持。
假设我们有一个控制器,可以将登录用户作为OAuth2User:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@AuthenticationPrincipal OAuth2User oauth2User) {
return Mono.just(oauth2User.getAttribute("sub"));
}
@GetMapping("/endpoint")
fun foo(@AuthenticationPrincipal oauth2User: OAuth2User): Mono<String> {
return Mono.just(oauth2User.getAttribute("sub"))
}
在这种情况下,我们可以告诉 Spring Security 包含默认值OAuth2User使用SecurityMockServerConfigurers#mockOAuth2Login方法,如下所示:
-
Java
-
Kotlin
client
.mutateWith(mockOAuth2Login())
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOAuth2Login())
.get().uri("/endpoint").exchange()
这将要做的是配置关联的MockServerRequest使用OAuth2User其中包括一个简单的Map属性和Collection授予的权力。
具体来说,它将包括一个Map键/值对为sub/user:
-
Java
-
Kotlin
assertThat((String) user.getAttribute("sub")).isEqualTo("user");
assertThat(user.getAttribute<String>("sub")).isEqualTo("user")
和Collection只有一个权限的权威,SCOPE_read:
-
Java
-
Kotlin
assertThat(user.getAuthorities()).hasSize(1);
assertThat(user.getAuthorities()).containsExactly(new SimpleGrantedAuthority("SCOPE_read"));
assertThat(user.authorities).hasSize(1)
assertThat(user.authorities).containsExactly(SimpleGrantedAuthority("SCOPE_read"))
Spring Security 执行必要的工作以确保OAuth2User实例可用于这@AuthenticationPrincipal注解.
此外,它还链接了OAuth2User转换为OAuth2AuthorizedClient它存放在模拟中ServerOAuth2AuthorizedClientRepository.
如果您的测试使用@RegisteredOAuth2AuthorizedClient注解.
配置权限
在许多情况下,您的方法受过滤器或方法安全性的保护,并且需要您的Authentication让某些授权机构允许该请求。
在这种情况下,您可以使用authorities()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOAuth2Login()
.authorities(new SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOAuth2Login()
.authorities(SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange()
配置声明
虽然授予的权限在所有 Spring Security 中都很常见,但我们在 OAuth 2.0 的情况下也有声明。
例如,假设您有一个user_id属性,指示系统中用户的 ID。
您可以在控制器中像这样访问它:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@AuthenticationPrincipal OAuth2User oauth2User) {
String userId = oauth2User.getAttribute("user_id");
// ...
}
@GetMapping("/endpoint")
fun foo(@AuthenticationPrincipal oauth2User: OAuth2User): Mono<String> {
val userId = oauth2User.getAttribute<String>("user_id")
// ...
}
在这种情况下,您需要使用attributes()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOAuth2Login()
.attributes(attrs -> attrs.put("user_id", "1234"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOAuth2Login()
.attributes { attrs -> attrs["user_id"] = "1234" }
)
.get().uri("/endpoint").exchange()
其他配置
还有其他方法用于进一步配置身份验证;这仅取决于您的控制者期望哪些数据:
-
clientRegistration(ClientRegistration)- 用于配置关联的OAuth2AuthorizedClient使用给定的ClientRegistration -
oauth2User(OAuth2User)- 用于配置完整的OAuth2User实例
如果您满足以下条件,最后一个会很方便:
1. 拥有自己的实现OAuth2User或
2.需要更改名称属性
例如,假设您的授权服务器在user_name声明而不是sub索赔。
在这种情况下,您可以配置OAuth2User手工:
-
Java
-
Kotlin
OAuth2User oauth2User = new DefaultOAuth2User(
AuthorityUtils.createAuthorityList("SCOPE_message:read"),
Collections.singletonMap("user_name", "foo_user"),
"user_name");
client
.mutateWith(mockOAuth2Login().oauth2User(oauth2User))
.get().uri("/endpoint").exchange();
val oauth2User: OAuth2User = DefaultOAuth2User(
AuthorityUtils.createAuthorityList("SCOPE_message:read"),
mapOf(Pair("user_name", "foo_user")),
"user_name"
)
client
.mutateWith(mockOAuth2Login().oauth2User(oauth2User))
.get().uri("/endpoint").exchange()
测试 OAuth 2.0 客户端
无论用户如何进行身份验证,您可能有其他Tokens和客户端注册用于您正在测试的请求。 例如,控制器可能依赖于客户端凭据授予来获取根本不与用户关联的Tokens:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@RegisteredOAuth2AuthorizedClient("my-app") OAuth2AuthorizedClient authorizedClient) {
return this.webClient.get()
.attributes(oauth2AuthorizedClient(authorizedClient))
.retrieve()
.bodyToMono(String.class);
}
import org.springframework.web.reactive.function.client.bodyToMono
// ...
@GetMapping("/endpoint")
fun foo(@RegisteredOAuth2AuthorizedClient("my-app") authorizedClient: OAuth2AuthorizedClient?): Mono<String> {
return this.webClient.get()
.attributes(oauth2AuthorizedClient(authorizedClient))
.retrieve()
.bodyToMono()
}
与授权服务器模拟这种握手可能会很麻烦。相反,您可以使用SecurityMockServerConfigurers#mockOAuth2Client添加一个OAuth2AuthorizedClient变成模拟ServerOAuth2AuthorizedClientRepository:
-
Java
-
Kotlin
client
.mutateWith(mockOAuth2Client("my-app"))
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOAuth2Client("my-app"))
.get().uri("/endpoint").exchange()
这将创建一个OAuth2AuthorizedClient这有一个简单的ClientRegistration,OAuth2AccessToken和资源所有者名称。
具体来说,它将包括一个ClientRegistration客户端 ID 为“test-client”,客户端密码为“test-secret”:
-
Java
-
Kotlin
assertThat(authorizedClient.getClientRegistration().getClientId()).isEqualTo("test-client");
assertThat(authorizedClient.getClientRegistration().getClientSecret()).isEqualTo("test-secret");
assertThat(authorizedClient.clientRegistration.clientId).isEqualTo("test-client")
assertThat(authorizedClient.clientRegistration.clientSecret).isEqualTo("test-secret")
资源所有者名称为“user”:
-
Java
-
Kotlin
assertThat(authorizedClient.getPrincipalName()).isEqualTo("user");
assertThat(authorizedClient.principalName).isEqualTo("user")
和OAuth2AccessToken只需一个示波器,read:
-
Java
-
Kotlin
assertThat(authorizedClient.getAccessToken().getScopes()).hasSize(1);
assertThat(authorizedClient.getAccessToken().getScopes()).containsExactly("read");
assertThat(authorizedClient.accessToken.scopes).hasSize(1)
assertThat(authorizedClient.accessToken.scopes).containsExactly("read")
然后可以使用@RegisteredOAuth2AuthorizedClient在控制器方法中。
配置范围
在许多情况下,OAuth 2.0 访问Tokens附带一组范围。如果您的控制器检查这些,请如下所示:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(@RegisteredOAuth2AuthorizedClient("my-app") OAuth2AuthorizedClient authorizedClient) {
Set<String> scopes = authorizedClient.getAccessToken().getScopes();
if (scopes.contains("message:read")) {
return this.webClient.get()
.attributes(oauth2AuthorizedClient(authorizedClient))
.retrieve()
.bodyToMono(String.class);
}
// ...
}
import org.springframework.web.reactive.function.client.bodyToMono
// ...
@GetMapping("/endpoint")
fun foo(@RegisteredOAuth2AuthorizedClient("my-app") authorizedClient: OAuth2AuthorizedClient): Mono<String> {
val scopes = authorizedClient.accessToken.scopes
if (scopes.contains("message:read")) {
return webClient.get()
.attributes(oauth2AuthorizedClient(authorizedClient))
.retrieve()
.bodyToMono()
}
// ...
}
然后,您可以使用accessToken()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOAuth2Client("my-app")
.accessToken(new OAuth2AccessToken(BEARER, "token", null, null, Collections.singleton("message:read")))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOAuth2Client("my-app")
.accessToken(OAuth2AccessToken(BEARER, "token", null, null, setOf("message:read")))
)
.get().uri("/endpoint").exchange()
其他配置
还有其他方法用于进一步配置身份验证;这仅取决于您的控制者期望哪些数据:
-
principalName(String)- 用于配置资源所有者名称 -
clientRegistration(Consumer<ClientRegistration.Builder>)- 用于配置关联的ClientRegistration -
clientRegistration(ClientRegistration)- 用于配置完整的ClientRegistration
如果您想使用真正的ClientRegistration
例如,假设您想要使用应用的ClientRegistration定义,如您的application.yml.
在这种情况下,您的测试可以自动连接ReactiveClientRegistrationRepository并查找您的测试需要的那个:
-
Java
-
Kotlin
@Autowired
ReactiveClientRegistrationRepository clientRegistrationRepository;
// ...
client
.mutateWith(mockOAuth2Client()
.clientRegistration(this.clientRegistrationRepository.findByRegistrationId("facebook").block())
)
.get().uri("/exchange").exchange();
@Autowired
lateinit var clientRegistrationRepository: ReactiveClientRegistrationRepository
// ...
client
.mutateWith(mockOAuth2Client()
.clientRegistration(this.clientRegistrationRepository.findByRegistrationId("facebook").block())
)
.get().uri("/exchange").exchange()
测试 JWT 身份验证
为了在资源服务器上发出授权请求,您需要一个持有者Tokens。 如果您的资源服务器配置为 JWT,则这意味着需要对持有者Tokens进行签名,然后根据 JWT 规范进行编码。 所有这些都可能非常令人生畏,尤其是当这不是测试的重点时。
幸运的是,有许多简单的方法可以克服这个困难,并允许测试专注于授权而不是表示不记名Tokens。 我们现在来看其中两个:
mockJwt() WebTestClientConfigurer
第一种方式是通过WebTestClientConfigurer.
其中最简单的方法是使用SecurityMockServerConfigurers#mockJwt方法如下所示:
-
Java
-
Kotlin
client
.mutateWith(mockJwt()).get().uri("/endpoint").exchange();
client
.mutateWith(mockJwt()).get().uri("/endpoint").exchange()
这将创建一个模拟Jwt,通过任何身份验证 API 正确传递它,以便您的授权机制可以验证它。
默认情况下,JWT它创建的具有以下特征:
{
"headers" : { "alg" : "none" },
"claims" : {
"sub" : "user",
"scope" : "read"
}
}
由此产生的Jwt,如果经过测试,将以以下方式通过:
-
Java
-
Kotlin
assertThat(jwt.getTokenValue()).isEqualTo("token");
assertThat(jwt.getHeaders().get("alg")).isEqualTo("none");
assertThat(jwt.getSubject()).isEqualTo("sub");
assertThat(jwt.tokenValue).isEqualTo("token")
assertThat(jwt.headers["alg"]).isEqualTo("none")
assertThat(jwt.subject).isEqualTo("sub")
当然,这些值是可以配置的。
可以使用其相应的方法配置任何标头或声明:
-
Java
-
Kotlin
client
.mutateWith(mockJwt().jwt(jwt -> jwt.header("kid", "one")
.claim("iss", "https://idp.example.org")))
.get().uri("/endpoint").exchange();
client
.mutateWith(mockJwt().jwt { jwt -> jwt.header("kid", "one")
.claim("iss", "https://idp.example.org")
})
.get().uri("/endpoint").exchange()
-
Java
-
Kotlin
client
.mutateWith(mockJwt().jwt(jwt -> jwt.claims(claims -> claims.remove("scope"))))
.get().uri("/endpoint").exchange();
client
.mutateWith(mockJwt().jwt { jwt ->
jwt.claims { claims -> claims.remove("scope") }
})
.get().uri("/endpoint").exchange()
这scope和scp此处的声明处理方式与普通持有者Tokens请求中的处理方式相同。
但是,只需提供GrantedAuthority测试所需的实例:
-
Java
-
Kotlin
client
.mutateWith(mockJwt().authorities(new SimpleGrantedAuthority("SCOPE_messages")))
.get().uri("/endpoint").exchange();
client
.mutateWith(mockJwt().authorities(SimpleGrantedAuthority("SCOPE_messages")))
.get().uri("/endpoint").exchange()
或者,如果您有自定义Jwt自Collection<GrantedAuthority>转换器,你也可以使用它来派生权限:
-
Java
-
Kotlin
client
.mutateWith(mockJwt().authorities(new MyConverter()))
.get().uri("/endpoint").exchange();
client
.mutateWith(mockJwt().authorities(MyConverter()))
.get().uri("/endpoint").exchange()
您还可以指定完整的Jwt,为此Jwt.Builder非常方便:
-
Java
-
Kotlin
Jwt jwt = Jwt.withTokenValue("token")
.header("alg", "none")
.claim("sub", "user")
.claim("scope", "read")
.build();
client
.mutateWith(mockJwt().jwt(jwt))
.get().uri("/endpoint").exchange();
val jwt: Jwt = Jwt.withTokenValue("token")
.header("alg", "none")
.claim("sub", "user")
.claim("scope", "read")
.build()
client
.mutateWith(mockJwt().jwt(jwt))
.get().uri("/endpoint").exchange()
authentication() WebTestClientConfigurer
第二种方法是使用authentication() Mutator.
本质上,您可以实例化自己的JwtAuthenticationToken并在测试中提供它,如下所示:
-
Java
-
Kotlin
Jwt jwt = Jwt.withTokenValue("token")
.header("alg", "none")
.claim("sub", "user")
.build();
Collection<GrantedAuthority> authorities = AuthorityUtils.createAuthorityList("SCOPE_read");
JwtAuthenticationToken token = new JwtAuthenticationToken(jwt, authorities);
client
.mutateWith(mockAuthentication(token))
.get().uri("/endpoint").exchange();
val jwt = Jwt.withTokenValue("token")
.header("alg", "none")
.claim("sub", "user")
.build()
val authorities: Collection<GrantedAuthority> = AuthorityUtils.createAuthorityList("SCOPE_read")
val token = JwtAuthenticationToken(jwt, authorities)
client
.mutateWith(mockAuthentication<JwtMutator>(token))
.get().uri("/endpoint").exchange()
请注意,作为这些的替代方法,您还可以模拟ReactiveJwtDecoderbean 本身带有@MockBean注解。
测试不透明Tokens身份验证
与 JWT 类似,不透明Tokens需要授权服务器来验证其有效性,这会使测试更加困难。 为了帮助解决这个问题,Spring Security 提供了对不透明Tokens的测试支持。
假设我们有一个控制器,它将身份验证检索为BearerTokenAuthentication:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(BearerTokenAuthentication authentication) {
return Mono.just((String) authentication.getTokenAttributes().get("sub"));
}
@GetMapping("/endpoint")
fun foo(authentication: BearerTokenAuthentication): Mono<String?> {
return Mono.just(authentication.tokenAttributes["sub"] as String?)
}
在这种情况下,我们可以告诉 Spring Security 包含默认值BearerTokenAuthentication使用SecurityMockServerConfigurers#mockOpaqueToken方法,如下所示:
-
Java
-
Kotlin
client
.mutateWith(mockOpaqueToken())
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOpaqueToken())
.get().uri("/endpoint").exchange()
这将要做的是配置关联的MockHttpServletRequest使用BearerTokenAuthentication其中包括一个简单的OAuth2AuthenticatedPrincipal,Map属性,以及Collection授予的权力。
具体来说,它将包括一个Map键/值对为sub/user:
-
Java
-
Kotlin
assertThat((String) token.getTokenAttributes().get("sub")).isEqualTo("user");
assertThat(token.tokenAttributes["sub"] as String?).isEqualTo("user")
和Collection只有一个权限的权威,SCOPE_read:
-
Java
-
Kotlin
assertThat(token.getAuthorities()).hasSize(1);
assertThat(token.getAuthorities()).containsExactly(new SimpleGrantedAuthority("SCOPE_read"));
assertThat(token.authorities).hasSize(1)
assertThat(token.authorities).containsExactly(SimpleGrantedAuthority("SCOPE_read"))
Spring Security 执行必要的工作以确保BearerTokenAuthentication实例可用于您的控制器方法。
配置权限
在许多情况下,您的方法受过滤器或方法安全性的保护,并且需要您的Authentication让某些授权机构允许该请求。
在这种情况下,您可以使用authorities()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOpaqueToken()
.authorities(new SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOpaqueToken()
.authorities(SimpleGrantedAuthority("SCOPE_message:read"))
)
.get().uri("/endpoint").exchange()
配置声明
虽然授予的权限在所有 Spring Security 中都很常见,但我们在 OAuth 2.0 的情况下也有属性。
例如,假设您有一个user_id属性,指示系统中用户的 ID。
您可以在控制器中像这样访问它:
-
Java
-
Kotlin
@GetMapping("/endpoint")
public Mono<String> foo(BearerTokenAuthentication authentication) {
String userId = (String) authentication.getTokenAttributes().get("user_id");
// ...
}
@GetMapping("/endpoint")
fun foo(authentication: BearerTokenAuthentication): Mono<String?> {
val userId = authentication.tokenAttributes["user_id"] as String?
// ...
}
在这种情况下,您需要使用attributes()方法:
-
Java
-
Kotlin
client
.mutateWith(mockOpaqueToken()
.attributes(attrs -> attrs.put("user_id", "1234"))
)
.get().uri("/endpoint").exchange();
client
.mutateWith(mockOpaqueToken()
.attributes { attrs -> attrs["user_id"] = "1234" }
)
.get().uri("/endpoint").exchange()
其他配置
还有其他方法用于进一步配置身份验证;这仅取决于您的控制者期望哪些数据。
其中之一是principal(OAuth2AuthenticatedPrincipal),您可以使用它来配置完整的OAuth2AuthenticatedPrincipal作为BearerTokenAuthentication
如果您满足以下条件,它会很方便:
1. 拥有自己的实现OAuth2AuthenticatedPrincipal或
2. 想要指定不同的主体名称
例如,假设您的授权服务器在user_name属性而不是sub属性。 在这种情况下,您可以配置OAuth2AuthenticatedPrincipal手工:
-
Java
-
Kotlin
Map<String, Object> attributes = Collections.singletonMap("user_name", "foo_user");
OAuth2AuthenticatedPrincipal principal = new DefaultOAuth2AuthenticatedPrincipal(
(String) attributes.get("user_name"),
attributes,
AuthorityUtils.createAuthorityList("SCOPE_message:read"));
client
.mutateWith(mockOpaqueToken().principal(principal))
.get().uri("/endpoint").exchange();
val attributes: Map<String, Any> = mapOf(Pair("user_name", "foo_user"))
val principal: OAuth2AuthenticatedPrincipal = DefaultOAuth2AuthenticatedPrincipal(
attributes["user_name"] as String?,
attributes,
AuthorityUtils.createAuthorityList("SCOPE_message:read")
)
client
.mutateWith(mockOpaqueToken().principal(principal))
.get().uri("/endpoint").exchange()
请注意,作为使用mockOpaqueToken()test support,你也可以模拟OpaqueTokenIntrospectorbean 本身带有@MockBean注解。