org.springframework.security.config.annotation.rsocket

Class RSocketSecurity

java.lang.Object

org.springframework.security.config.annotation.rsocket.RSocketSecurity

public class RSocketSecurity
extends java.lang.Object

Allows configuring RSocket based security. A minimal example can be found below:

 @EnableRSocketSecurity
 public class SecurityConfig {
     // @formatter:off
     @Bean
     PayloadSocketAcceptorInterceptor rsocketInterceptor(RSocketSecurity rsocket) {
         rsocket
             .authorizePayload(authorize ->
                 authorize
                     .anyRequest().authenticated()
             );
         return rsocket.build();
     }
     // @formatter:on

     // @formatter:off
     @Bean
     public MapReactiveUserDetailsService userDetailsService() {
          UserDetails user = User.withDefaultPasswordEncoder()
               .username("user")
               .password("password")
               .roles("USER")
               .build();
          return new MapReactiveUserDetailsService(user);
     }
     // @formatter:on
 }
 

A more advanced configuration can be seen below:

 @EnableRSocketSecurity
 public class SecurityConfig {
     // @formatter:off
     @Bean
     PayloadSocketAcceptorInterceptor rsocketInterceptor(RSocketSecurity rsocket) {
         rsocket
             .authorizePayload(authorize ->
                 authorize
                     // must have ROLE_SETUP to make connection
                     .setup().hasRole("SETUP")
                      // must have ROLE_ADMIN for routes starting with "admin."
                     .route("admin.*").hasRole("ADMIN")
                     // any other request must be authenticated for
                     .anyRequest().authenticated()
             );
         return rsocket.build();
     }
     // @formatter:on
 }
 

Since:

5.2

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RSocketSecurity.AuthorizePayloadsSpec
class	RSocketSecurity.BasicAuthenticationSpec
class	RSocketSecurity.JwtSpec

Constructor Summary

Constructors

Constructor and Description
RSocketSecurity()

Method Summary

Modifier and Type	Method and Description
RSocketSecurity	addPayloadInterceptor(PayloadInterceptor interceptor) Adds a PayloadInterceptor to be used.
RSocketSecurity	authenticationManager(ReactiveAuthenticationManager authenticationManager)
RSocketSecurity	authorizePayload(Customizer<RSocketSecurity.AuthorizePayloadsSpec> authorize)
RSocketSecurity	basicAuthentication(Customizer<RSocketSecurity.BasicAuthenticationSpec> basic)
PayloadSocketAcceptorInterceptor	build()
RSocketSecurity	jwt(Customizer<RSocketSecurity.JwtSpec> jwt)
protected void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RSocketSecurity

public RSocketSecurity()

Method Detail

addPayloadInterceptor

public RSocketSecurity addPayloadInterceptor(PayloadInterceptor interceptor)

Adds a PayloadInterceptor to be used. This is typically only used when using the DSL does not meet a users needs. In order to ensure the PayloadInterceptor is done in the proper order the PayloadInterceptor should either implement Ordered or be annotated with Order.

Parameters:

interceptor -

Returns:

the builder for additional customizations

See Also:

PayloadInterceptorOrder

authenticationManager

public RSocketSecurity authenticationManager(ReactiveAuthenticationManager authenticationManager)

basicAuthentication

public RSocketSecurity basicAuthentication(Customizer<RSocketSecurity.BasicAuthenticationSpec> basic)

jwt

public RSocketSecurity jwt(Customizer<RSocketSecurity.JwtSpec> jwt)

authorizePayload

public RSocketSecurity authorizePayload(Customizer<RSocketSecurity.AuthorizePayloadsSpec> authorize)

build

public PayloadSocketAcceptorInterceptor build()

setApplicationContext

protected void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                              throws org.springframework.beans.BeansException

Throws:

org.springframework.beans.BeansException