Skip to content

Commit a8ef049

Browse files
jonatan-ivanovjonatan-ivanov
committed
Disable HTTP Observations for Actuator
There's something weird with test using WebTestClient, see the two failing tests in WebFluxObservationAutoConfigurationTests: - whenActuatorObservationsDisabledObservationsShouldNotBeRecordedUsingCustomWebfluxBasePath - whenActuatorObservationsDisabledObservationsShouldNotBeRecordedUsingCustomWebfluxBasePathAndCustomEndpointBasePath Closes gh-34801
1 parent c22cbb0 commit a8ef049

File tree

5 files changed

+403
-3
lines changed

5 files changed

+403
-3
lines changed

‎spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/reactive/WebFluxObservationAutoConfiguration.java

+22
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import io.micrometer.core.instrument.MeterRegistry;
2020
import io.micrometer.core.instrument.config.MeterFilter;
2121
import io.micrometer.observation.Observation;
22+
import io.micrometer.observation.ObservationPredicate;
2223
import io.micrometer.observation.ObservationRegistry;
2324

2425
import org.springframework.beans.factory.ObjectProvider;
@@ -29,17 +30,20 @@
2930
import org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration;
3031
import org.springframework.boot.actuate.autoconfigure.observation.ObservationAutoConfiguration;
3132
import org.springframework.boot.actuate.autoconfigure.observation.ObservationProperties;
33+
import org.springframework.boot.actuate.endpoint.web.PathMappedEndpoints;
3234
import org.springframework.boot.autoconfigure.AutoConfiguration;
3335
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
3436
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
3537
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
3638
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
39+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
3740
import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
3841
import org.springframework.boot.context.properties.EnableConfigurationProperties;
3942
import org.springframework.context.annotation.Bean;
4043
import org.springframework.context.annotation.Configuration;
4144
import org.springframework.core.annotation.Order;
4245
import org.springframework.http.server.reactive.observation.DefaultServerRequestObservationConvention;
46+
import org.springframework.http.server.reactive.observation.ServerRequestObservationContext;
4347
import org.springframework.http.server.reactive.observation.ServerRequestObservationConvention;
4448
import org.springframework.web.filter.reactive.ServerHttpObservationFilter;
4549

@@ -51,6 +55,7 @@
5155
* @author Jon Schneider
5256
* @author Dmytro Nosan
5357
* @author Moritz Halbritter
58+
* @author Jonatan Ivanov
5459
* @since 3.0.0
5560
*/
5661
@AutoConfiguration(after = { MetricsAutoConfiguration.class, CompositeMeterRegistryAutoConfiguration.class,
@@ -97,4 +102,21 @@ MeterFilter metricsHttpServerUriTagFilter(MetricsProperties metricsProperties,
97102

98103
}
99104

105+
@Configuration(proxyBeanMethods = false)
106+
@ConditionalOnProperty(value = "management.observations.http.server.actuator.enabled", havingValue = "false")
107+
static class ActuatorWebEndpointObservationConfiguration {
108+
109+
@Bean
110+
ObservationPredicate actuatorWebEndpointObservationPredicate(PathMappedEndpoints pathMappedEndpoints) {
111+
return (name, context) -> {
112+
if (context instanceof ServerRequestObservationContext serverContext) {
113+
return !serverContext.getCarrier().getURI().getPath().startsWith(pathMappedEndpoints.getBasePath());
114+
}
115+
return true;
116+
};
117+
118+
}
119+
120+
}
121+
100122
}

‎spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/servlet/WebMvcObservationAutoConfiguration.java

+47-1
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,12 @@
1616

1717
package org.springframework.boot.actuate.autoconfigure.observation.web.servlet;
1818

19+
import java.nio.file.Path;
20+
1921
import io.micrometer.core.instrument.MeterRegistry;
2022
import io.micrometer.core.instrument.config.MeterFilter;
2123
import io.micrometer.observation.Observation;
24+
import io.micrometer.observation.ObservationPredicate;
2225
import io.micrometer.observation.ObservationRegistry;
2326
import jakarta.servlet.DispatcherType;
2427

@@ -30,18 +33,24 @@
3033
import org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration;
3134
import org.springframework.boot.actuate.autoconfigure.observation.ObservationAutoConfiguration;
3235
import org.springframework.boot.actuate.autoconfigure.observation.ObservationProperties;
36+
import org.springframework.boot.actuate.endpoint.web.PathMappedEndpoints;
3337
import org.springframework.boot.autoconfigure.AutoConfiguration;
3438
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
3539
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
3640
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
41+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
3742
import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
43+
import org.springframework.boot.autoconfigure.web.ServerProperties;
44+
import org.springframework.boot.autoconfigure.web.ServerProperties.Servlet;
3845
import org.springframework.boot.autoconfigure.web.servlet.ConditionalOnMissingFilterBean;
46+
import org.springframework.boot.autoconfigure.web.servlet.WebMvcProperties;
3947
import org.springframework.boot.context.properties.EnableConfigurationProperties;
4048
import org.springframework.boot.web.servlet.FilterRegistrationBean;
4149
import org.springframework.context.annotation.Bean;
4250
import org.springframework.context.annotation.Configuration;
4351
import org.springframework.core.annotation.Order;
4452
import org.springframework.http.server.observation.DefaultServerRequestObservationConvention;
53+
import org.springframework.http.server.observation.ServerRequestObservationContext;
4554
import org.springframework.http.server.observation.ServerRequestObservationConvention;
4655
import org.springframework.web.filter.ServerHttpObservationFilter;
4756
import org.springframework.web.servlet.DispatcherServlet;
@@ -54,14 +63,16 @@
5463
* @author Jon Schneider
5564
* @author Dmytro Nosan
5665
* @author Moritz Halbritter
66+
* @author Jonatan Ivanov
5767
* @since 3.0.0
5868
*/
5969
@AutoConfiguration(after = { MetricsAutoConfiguration.class, CompositeMeterRegistryAutoConfiguration.class,
6070
SimpleMetricsExportAutoConfiguration.class, ObservationAutoConfiguration.class })
6171
@ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.SERVLET)
6272
@ConditionalOnClass({ DispatcherServlet.class, Observation.class })
6373
@ConditionalOnBean(ObservationRegistry.class)
64-
@EnableConfigurationProperties({ MetricsProperties.class, ObservationProperties.class })
74+
@EnableConfigurationProperties({ MetricsProperties.class, ObservationProperties.class, ServerProperties.class,
75+
WebMvcProperties.class })
6576
public class WebMvcObservationAutoConfiguration {
6677

6778
@Bean
@@ -97,4 +108,39 @@ MeterFilter metricsHttpServerUriTagFilter(ObservationProperties observationPrope
97108

98109
}
99110

111+
@Configuration(proxyBeanMethods = false)
112+
@ConditionalOnProperty(value = "management.observations.http.server.actuator.enabled", havingValue = "false")
113+
static class ActuatorWebEndpointObservationConfiguration {
114+
115+
@Bean
116+
ObservationPredicate actuatorWebEndpointObservationPredicate(ServerProperties serverProperties,
117+
WebMvcProperties webMvcProperties, PathMappedEndpoints pathMappedEndpoints) {
118+
return (name, context) -> {
119+
if (context instanceof ServerRequestObservationContext serverContext) {
120+
String endpointPath = getEndpointPath(serverProperties, webMvcProperties, pathMappedEndpoints);
121+
return !serverContext.getCarrier().getRequestURI().startsWith(endpointPath);
122+
}
123+
return true;
124+
};
125+
}
126+
127+
private static String getEndpointPath(ServerProperties serverProperties, WebMvcProperties webMvcProperties,
128+
PathMappedEndpoints pathMappedEndpoints) {
129+
String contextPath = getContextPath(serverProperties);
130+
String servletPath = getServletPath(webMvcProperties);
131+
return Path.of(contextPath, servletPath, pathMappedEndpoints.getBasePath()).toString();
132+
}
133+
134+
private static String getContextPath(ServerProperties serverProperties) {
135+
Servlet servlet = serverProperties.getServlet();
136+
return (servlet.getContextPath() != null) ? servlet.getContextPath() : "";
137+
}
138+
139+
private static String getServletPath(WebMvcProperties webMvcProperties) {
140+
WebMvcProperties.Servlet servletProperties = webMvcProperties.getServlet();
141+
return (servletProperties.getPath() != null) ? servletProperties.getPath() : "";
142+
}
143+
144+
}
145+
100146
}

‎spring-boot-project/spring-boot-actuator-autoconfigure/src/main/resources/META-INF/additional-spring-configuration-metadata.json

+6
Original file line numberDiff line numberDiff line change
@@ -2054,6 +2054,12 @@
20542054
"level": "error"
20552055
}
20562056
},
2057+
{
2058+
"name": "management.observations.http.server.actuator.enabled",
2059+
"type": "java.lang.Boolean",
2060+
"description": "Whether to enable HTTP observations for actuator endpoints.",
2061+
"defaultValue": false
2062+
},
20572063
{
20582064
"name": "management.otlp.tracing.compression",
20592065
"defaultValue": "none"

‎spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/observation/web/reactive/WebFluxObservationAutoConfigurationTests.java

+153-2
Original file line numberDiff line numberDiff line change
@@ -19,15 +19,23 @@
1919
import java.util.List;
2020

2121
import io.micrometer.core.instrument.MeterRegistry;
22+
import io.micrometer.observation.ObservationRegistry;
23+
import io.micrometer.observation.tck.TestObservationRegistry;
24+
import io.micrometer.observation.tck.TestObservationRegistryAssert;
2225
import org.junit.jupiter.api.Test;
2326
import org.junit.jupiter.api.extension.ExtendWith;
2427
import reactor.core.publisher.Mono;
2528

29+
import org.springframework.boot.actuate.autoconfigure.endpoint.EndpointAutoConfiguration;
30+
import org.springframework.boot.actuate.autoconfigure.endpoint.web.WebEndpointAutoConfiguration;
31+
import org.springframework.boot.actuate.autoconfigure.endpoint.web.reactive.WebFluxEndpointManagementContextConfiguration;
32+
import org.springframework.boot.actuate.autoconfigure.info.InfoEndpointAutoConfiguration;
2633
import org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration;
2734
import org.springframework.boot.actuate.autoconfigure.metrics.test.MetricsRun;
2835
import org.springframework.boot.actuate.autoconfigure.metrics.web.TestController;
2936
import org.springframework.boot.actuate.autoconfigure.observation.ObservationAutoConfiguration;
3037
import org.springframework.boot.autoconfigure.AutoConfigurations;
38+
import org.springframework.boot.autoconfigure.web.reactive.HttpHandlerAutoConfiguration;
3139
import org.springframework.boot.autoconfigure.web.reactive.WebFluxAutoConfiguration;
3240
import org.springframework.boot.test.context.assertj.AssertableReactiveWebApplicationContext;
3341
import org.springframework.boot.test.context.runner.ReactiveWebApplicationContextRunner;
@@ -53,6 +61,7 @@
5361
* @author Dmytro Nosan
5462
* @author Madhura Bhave
5563
* @author Moritz Halbritter
64+
* @author Jonatan Ivanov
5665
*/
5766
@ExtendWith(OutputCaptureExtension.class)
5867
@SuppressWarnings("removal")
@@ -115,6 +124,121 @@ void afterMaxUrisReachedFurtherUrisAreDeniedWhenUsingCustomObservationName(Captu
115124
});
116125
}
117126

127+
@Test
128+
void whenAnActuatorEndpointIsCalledObservationsShouldBeRecorded() {
129+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
130+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
131+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
132+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
133+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
134+
.withPropertyValues("management.endpoints.web.exposure.include=info")
135+
.run((context) -> {
136+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry(context, "/test0",
137+
"/actuator/info");
138+
TestObservationRegistryAssert.assertThat(observationRegistry)
139+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 2)
140+
.hasAnObservationWithAKeyValue("http.url", "/test0")
141+
.hasAnObservationWithAKeyValue("http.url", "/actuator/info");
142+
});
143+
}
144+
145+
@Test
146+
void whenActuatorObservationsEnabledObservationsShouldBeRecorded() {
147+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
148+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
149+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
150+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
151+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
152+
.withPropertyValues("management.endpoints.web.exposure.include=info",
153+
"management.observations.http.server.actuator.enabled=true")
154+
.run((context) -> {
155+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry(context, "/test0",
156+
"/actuator/info");
157+
TestObservationRegistryAssert.assertThat(observationRegistry)
158+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 2)
159+
.hasAnObservationWithAKeyValue("http.url", "/test0")
160+
.hasAnObservationWithAKeyValue("http.url", "/actuator/info");
161+
});
162+
}
163+
164+
@Test
165+
void whenActuatorObservationsDisabledObservationsShouldNotBeRecorded() {
166+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
167+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
168+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
169+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
170+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
171+
.withPropertyValues("management.endpoints.web.exposure.include=info",
172+
"management.observations.http.server.actuator.enabled=false")
173+
.run((context) -> {
174+
assertThat(context).hasBean("actuatorWebEndpointObservationPredicate");
175+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry(context, "/test0",
176+
"/actuator/info");
177+
TestObservationRegistryAssert.assertThat(observationRegistry)
178+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 1)
179+
.hasAnObservationWithAKeyValue("http.url", "/test0");
180+
});
181+
}
182+
183+
@Test
184+
void whenActuatorObservationsDisabledObservationsShouldNotBeRecordedUsingCustomEndpointBasePath() {
185+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
186+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
187+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
188+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
189+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
190+
.withPropertyValues("management.endpoints.web.exposure.include=info",
191+
"management.observations.http.server.actuator.enabled=false",
192+
"management.endpoints.web.base-path=/management")
193+
.run((context) -> {
194+
assertThat(context).hasBean("actuatorWebEndpointObservationPredicate");
195+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry(context, "/test0",
196+
"/management/info");
197+
TestObservationRegistryAssert.assertThat(observationRegistry)
198+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 1)
199+
.hasAnObservationWithAKeyValue("http.url", "/test0");
200+
});
201+
}
202+
203+
@Test
204+
void whenActuatorObservationsDisabledObservationsShouldNotBeRecordedUsingCustomWebfluxBasePath() {
205+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
206+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
207+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
208+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
209+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
210+
.withPropertyValues("management.endpoints.web.exposure.include=info",
211+
"management.observations.http.server.actuator.enabled=false", "spring.webflux.base-path=/test-path")
212+
.run((context) -> {
213+
assertThat(context).hasBean("actuatorWebEndpointObservationPredicate");
214+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry("/test-path",
215+
context, "/test0", "/actuator/info");
216+
TestObservationRegistryAssert.assertThat(observationRegistry)
217+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 1)
218+
.hasAnObservationWithAKeyValue("http.url", "/test0");
219+
});
220+
}
221+
222+
@Test
223+
void whenActuatorObservationsDisabledObservationsShouldNotBeRecordedUsingCustomWebfluxBasePathAndCustomEndpointBasePath() {
224+
this.contextRunner.withUserConfiguration(TestController.class, TestObservationRegistryConfiguration.class)
225+
.withConfiguration(AutoConfigurations.of(InfoEndpointAutoConfiguration.class,
226+
WebFluxAutoConfiguration.class, HttpHandlerAutoConfiguration.class, EndpointAutoConfiguration.class,
227+
WebEndpointAutoConfiguration.class, WebFluxEndpointManagementContextConfiguration.class,
228+
MetricsAutoConfiguration.class, ObservationAutoConfiguration.class))
229+
.withPropertyValues("management.endpoints.web.exposure.include=info",
230+
"management.observations.http.server.actuator.enabled=false", "spring.webflux.base-path=/test-path",
231+
"management.endpoints.web.base-path=/management")
232+
.run((context) -> {
233+
assertThat(context).hasBean("actuatorWebEndpointObservationPredicate");
234+
TestObservationRegistry observationRegistry = getInitializedTestObservationRegistry("/test-path",
235+
context, "/test0", "/management/info");
236+
TestObservationRegistryAssert.assertThat(observationRegistry)
237+
.hasNumberOfObservationsWithNameEqualTo("http.server.requests", 1)
238+
.hasAnObservationWithAKeyValue("http.url", "/test0");
239+
});
240+
}
241+
118242
@Test
119243
void shouldNotDenyNorLogIfMaxUrisIsNotReached(CapturedOutput output) {
120244
this.contextRunner.withUserConfiguration(TestController.class)
@@ -142,8 +266,7 @@ private MeterRegistry getInitializedMeterRegistry(AssertableReactiveWebApplicati
142266
return getInitializedMeterRegistry(context, "/test0", "/test1", "/test2");
143267
}
144268

145-
private MeterRegistry getInitializedMeterRegistry(AssertableReactiveWebApplicationContext context, String... urls)
146-
throws Exception {
269+
private MeterRegistry getInitializedMeterRegistry(AssertableReactiveWebApplicationContext context, String... urls) {
147270
assertThat(context).hasSingleBean(ServerHttpObservationFilter.class);
148271
WebTestClient client = WebTestClient.bindToApplicationContext(context).build();
149272
for (String url : urls) {
@@ -152,6 +275,34 @@ private MeterRegistry getInitializedMeterRegistry(AssertableReactiveWebApplicati
152275
return context.getBean(MeterRegistry.class);
153276
}
154277

278+
private TestObservationRegistry getInitializedTestObservationRegistry(
279+
AssertableReactiveWebApplicationContext context, String... urls) {
280+
return getInitializedTestObservationRegistry("", context, urls);
281+
}
282+
283+
private TestObservationRegistry getInitializedTestObservationRegistry(String baseUrl,
284+
AssertableReactiveWebApplicationContext context, String... urls) {
285+
assertThat(context).hasSingleBean(ServerHttpObservationFilter.class);
286+
WebTestClient client = WebTestClient.bindToApplicationContext(context)
287+
.configureClient()
288+
.baseUrl(baseUrl)
289+
.build();
290+
for (String url : urls) {
291+
client.get().uri(url).exchange().expectStatus().isOk();
292+
}
293+
return context.getBean(TestObservationRegistry.class);
294+
}
295+
296+
@Configuration(proxyBeanMethods = false)
297+
static class TestObservationRegistryConfiguration {
298+
299+
@Bean
300+
ObservationRegistry observationRegistry() {
301+
return TestObservationRegistry.create();
302+
}
303+
304+
}
305+
155306
@Configuration(proxyBeanMethods = false)
156307
static class CustomConventionConfiguration {
157308

0 commit comments

Comments
 (0)