| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295 | 
							- [[webflux-observability]]
 
- = Observability
 
- Spring Security integrates with Spring Observability out-of-the-box for tracing; though it's also quite simple to configure for gathering metrics.
 
- [[webflux-observability-tracing]]
 
- == Tracing
 
- When an `ObservationRegistry` bean is present, Spring Security creates traces for:
 
- * the filter chain
 
- * the `ReactiveAuthenticationManager`, and
 
- * the `ReactiveAuthorizationManager`
 
- [[webflux-observability-tracing-boot]]
 
- === Boot Integration
 
- For example, consider a simple Boot application:
 
- [tabs]
 
- ======
 
- Java::
 
- +
 
- [source,java,role="primary"]
 
- ----
 
- @SpringBootApplication
 
- public class MyApplication {
 
- 	@Bean
 
- 	public ReactiveUserDetailsService userDetailsService() {
 
- 		return new MapReactiveUserDetailsManager(
 
- 				User.withDefaultPasswordEncoder()
 
- 						.username("user")
 
- 						.password("password")
 
- 						.authorities("app")
 
- 						.build()
 
- 		);
 
- 	}
 
- 	@Bean
 
- 	ObservationRegistryCustomizer<ObservationRegistry> addTextHandler() {
 
- 		return (registry) -> registry.observationConfig().observationHandler(new ObservationTextPublisher());
 
- 	}
 
- 	public static void main(String[] args) {
 
- 		SpringApplication.run(ListenerSamplesApplication.class, args);
 
- 	}
 
- }
 
- ----
 
- Kotlin::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- @SpringBootApplication
 
- class MyApplication {
 
- 	@Bean
 
- 	fun userDetailsService(): ReactiveUserDetailsService {
 
- 		MapReactiveUserDetailsManager(
 
- 				User.withDefaultPasswordEncoder()
 
- 						.username("user")
 
- 						.password("password")
 
- 						.authorities("app")
 
- 						.build()
 
- 		);
 
- 	}
 
- 	@Bean
 
- 	fun addTextHandler(): ObservationRegistryCustomizer<ObservationRegistry> {
 
- 		return registry: ObservationRegistry -> registry.observationConfig()
 
- 				.observationHandler(ObservationTextPublisher());
 
- 	}
 
- 	fun main(args: Array<String>) {
 
- 		runApplication<MyApplication>(*args)
 
- 	}
 
- }
 
- ----
 
- ======
 
- And a corresponding request:
 
- [source,bash]
 
- ----
 
- ?> http -a user:password :8080
 
- ----
 
- Will produce the following output (indentation added for clarity):
 
- [source,bash]
 
- ----
 
- START - name='http.server.requests', contextualName='null', error='null', lowCardinalityKeyValues=[], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@5dfdb78', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.00191856, duration(nanos)=1918560.0, startTimeNanos=101177265022745}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@121549e0']
 
- 	START - name='spring.security.http.chains', contextualName='spring.security.http.chains.before', error='null', lowCardinalityKeyValues=[chain.size='14', filter.section='before'], highCardinalityKeyValues=[request.line='/'], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@3932a48c', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=4.65777E-4, duration(nanos)=465777.0, startTimeNanos=101177276300777}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@562db70f']
 
- 	STOP - name='spring.security.http.chains', contextualName='spring.security.http.chains.before', error='null', lowCardinalityKeyValues=[chain.size='14', filter.section='before'], highCardinalityKeyValues=[request.line='/'], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@3932a48c', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.003733105, duration(nanos)=3733105.0, startTimeNanos=101177276300777}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@562db70f']
 
- 		START - name='spring.security.authentications', contextualName='null', error='null', lowCardinalityKeyValues=[authentication.failure.type='Optional', authentication.method='UserDetailsRepositoryReactiveAuthenticationManager', authentication.request.type='UsernamePasswordAuthenticationToken'], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@574ba6cd', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=3.21015E-4, duration(nanos)=321015.0, startTimeNanos=101177336038417}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@49202cc7']
 
- 		STOP - name='spring.security.authentications', contextualName='null', error='null', lowCardinalityKeyValues=[authentication.failure.type='Optional', authentication.method='UserDetailsRepositoryReactiveAuthenticationManager', authentication.request.type='UsernamePasswordAuthenticationToken', authentication.result.type='UsernamePasswordAuthenticationToken'], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@574ba6cd', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.37574992, duration(nanos)=3.7574992E8, startTimeNanos=101177336038417}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@49202cc7']
 
- 		START - name='spring.security.authorizations', contextualName='null', error='null', lowCardinalityKeyValues=[object.type='SecurityContextServerWebExchange'], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@6f837332', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=2.65687E-4, duration(nanos)=265687.0, startTimeNanos=101177777941381}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@7f5bc7cb']
 
- 		STOP - name='spring.security.authorizations', contextualName='null', error='null', lowCardinalityKeyValues=[authorization.decision='true', object.type='SecurityContextServerWebExchange'], highCardinalityKeyValues=[authentication.authorities='[app]', authorization.decision.details='AuthorizationDecision [granted=true]'], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@6f837332', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.039239047, duration(nanos)=3.9239047E7, startTimeNanos=101177777941381}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@7f5bc7cb']
 
- 		START - name='spring.security.http.secured.requests', contextualName='null', error='null', lowCardinalityKeyValues=[], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@2f33dfae', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=3.1775E-4, duration(nanos)=317750.0, startTimeNanos=101177821377592}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@63b0d28f']
 
- 		STOP - name='spring.security.http.secured.requests', contextualName='null', error='null', lowCardinalityKeyValues=[], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@2f33dfae', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.219901971, duration(nanos)=2.19901971E8, startTimeNanos=101177821377592}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@63b0d28f']
 
- 	START - name='spring.security.http.chains', contextualName='spring.security.http.chains.after', error='null', lowCardinalityKeyValues=[chain.size='14', filter.section='after'], highCardinalityKeyValues=[request.line='/'], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@40b25623', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=3.25118E-4, duration(nanos)=325118.0, startTimeNanos=101178044824275}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@3b6cec2']
 
- 	STOP - name='spring.security.http.chains', contextualName='spring.security.http.chains.after', error='null', lowCardinalityKeyValues=[chain.size='14', filter.section='after'], highCardinalityKeyValues=[request.line='/'], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@40b25623', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.001693146, duration(nanos)=1693146.0, startTimeNanos=101178044824275}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@3b6cec2']
 
- STOP - name='http.server.requests', contextualName='null', error='null', lowCardinalityKeyValues=[], highCardinalityKeyValues=[], map=[class io.micrometer.tracing.handler.TracingObservationHandler$TracingContext='io.micrometer.tracing.handler.TracingObservationHandler$TracingContext@5dfdb78', class io.micrometer.core.instrument.LongTaskTimer$Sample='SampleImpl{duration(seconds)=0.784320641, duration(nanos)=7.84320641E8, startTimeNanos=101177265022745}', class io.micrometer.core.instrument.Timer$Sample='io.micrometer.core.instrument.Timer$Sample@121549e0']
 
- ----
 
- [[webflux-observability-tracing-manual-configuration]]
 
- === Manual Configuration
 
- For a non-Spring Boot application, or to override the existing Boot configuration, you can publish your own `ObservationRegistry` and Spring Security will still pick it up.
 
- [tabs]
 
- ======
 
- Java::
 
- +
 
- [source,java,role="primary"]
 
- ----
 
- @SpringBootApplication
 
- public class MyApplication {
 
- 	@Bean
 
- 	public ReactiveUserDetailsService userDetailsService() {
 
- 		return new MapReactiveUserDetailsManager(
 
- 				User.withDefaultPasswordEncoder()
 
- 						.username("user")
 
- 						.password("password")
 
- 						.authorities("app")
 
- 						.build()
 
- 		);
 
- 	}
 
- 	@Bean
 
- 	ObservationRegistry observationRegistry() {
 
- 		ObservationRegistry registry = ObservationRegistry.create();
 
- 		registry.observationConfig().observationHandler(new ObservationTextPublisher());
 
- 		return registry;
 
- 	}
 
- 	public static void main(String[] args) {
 
- 		SpringApplication.run(ListenerSamplesApplication.class, args);
 
- 	}
 
- }
 
- ----
 
- Kotlin::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- @SpringBootApplication
 
- class MyApplication {
 
- 	@Bean
 
- 	fun userDetailsService(): ReactiveUserDetailsService {
 
- 		MapReactiveUserDetailsManager(
 
- 				User.withDefaultPasswordEncoder()
 
- 						.username("user")
 
- 						.password("password")
 
- 						.authorities("app")
 
- 						.build()
 
- 		);
 
- 	}
 
- 	@Bean
 
- 	fun observationRegistry(): ObservationRegistry {
 
- 		ObservationRegistry registry = ObservationRegistry.create()
 
- 		registry.observationConfig().observationHandler(ObservationTextPublisher())
 
- 		return registry
 
- 	}
 
- 	fun main(args: Array<String>) {
 
- 		runApplication<MyApplication>(*args)
 
- 	}
 
- }
 
- ----
 
- Xml::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- <sec:http auto-config="true" observation-registry-ref="ref">
 
- 	<sec:intercept-url pattern="/**" access="authenticated"/>
 
- </sec:http>
 
- <!-- define and configure ObservationRegistry bean -->
 
- ----
 
- ======
 
- [[webflux-observability-tracing-disable]]
 
- === Disabling Observability
 
- If you don't want any Spring Security observations, in a Spring Boot application you can publish a `ObservationRegistry.NOOP` `@Bean`.
 
- However, this may turn off observations for more than just Spring Security.
 
- Instead, you can publish a `SecurityObservationSettings` like the following:
 
- [tabs]
 
- ======
 
- Java::
 
- +
 
- [source,java,role="primary"]
 
- ----
 
- @Bean
 
- SecurityObservationSettings noSpringSecurityObservations() {
 
- 	return SecurityObservationSettings.noObservations();
 
- }
 
- ----
 
- Kotlin::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- @Bean
 
- fun noSpringSecurityObservations(): SecurityObservationSettings {
 
- 	return SecurityObservationSettings.noObservations()
 
- }
 
- ----
 
- ======
 
- and then Spring Security will not wrap any filter chains, authentications, or authorizations in their `ObservationXXX` counterparts.
 
- [TIP]
 
- There is no facility for disabling observations with XML support.
 
- Instead, simply do not set the `observation-registry-ref` attribute.
 
- You can also disable security for only a subset of Security's observations.
 
- For example, the `SecurityObservationSettings` bean excludes the filter chain observations by default.
 
- So, you can also do:
 
- [tabs]
 
- ======
 
- Java::
 
- +
 
- [source,java,role="primary"]
 
- ----
 
- @Bean
 
- SecurityObservationSettings defaultSpringSecurityObservations() {
 
- 	return SecurityObservationSettings.withDefaults().build();
 
- }
 
- ----
 
- Kotlin::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- @Bean
 
- fun defaultSpringSecurityObservations(): SecurityObservationSettings {
 
- 	return SecurityObservationSettings.withDefaults().build()
 
- }
 
- ----
 
- ======
 
- Or you can turn on and off observations individually, based on the defaults:
 
- [tabs]
 
- ======
 
- Java::
 
- +
 
- [source,java,role="primary"]
 
- ----
 
- @Bean
 
- SecurityObservationSettings allSpringSecurityObservations() {
 
- 	return SecurityObservationSettings.withDefaults()
 
-             .shouldObserveFilterChains(true).build();
 
- }
 
- ----
 
- Kotlin::
 
- +
 
- [source,kotlin,role="secondary"]
 
- ----
 
- @Bean
 
- fun allSpringSecurityObservations(): SecurityObservationSettings {
 
-     return SecurityObservabilityDefaults.builder()
 
-             .shouldObserveFilterChains(true).build()
 
- }
 
- ----
 
- ======
 
- [NOTE]
 
- =====
 
- For backward compatibility, all Spring Security observations are made unless a `SecurityObservationSettings` is published.
 
- =====
 
- [[webflux-observability-tracing-listing]]
 
- === Trace Listing
 
- Spring Security tracks the following spans on each request:
 
- 1. `spring.security.http.requests` - a span that wraps the entire filter chain, including the request
 
- 2. `spring.security.http.chains.before` - a span that wraps the receiving part of the security filters
 
- 3. `spring.security.http.chains.after` - a span that wraps the returning part of the security filters
 
- 4. `spring.security.http.secured.requests` - a span that wraps the now-secured application request
 
- 5. `spring.security.http.unsecured.requests` - a span that wraps requests that Spring Security does not secure
 
- 6. `spring.security.authentications` - a span that wraps authentication attempts
 
- 7. `spring.security.authorizations` - a span that wraps authorization attempts
 
- [TIP]
 
- `spring.security.http.chains.before` + `spring.security.http.secured.requests` + `spring.security.http.chains.after` = `spring.security.http.requests` +
 
- `spring.security.http.chains.before` + `spring.security.http.chains.after` = Spring Security's part of the request
 
 
  |