Apply management server base path to webflux application registrations with management port, resolves #2169 (#2170)

Author: rainerfrey-inxmail

spring-boot-admin-client/src/main/java/de/codecentric/boot/admin/client/registration/ReactiveApplicationFactory.java

@@ -21,13 +21,19 @@
 import org.springframework.boot.actuate.endpoint.web.PathMappedEndpoints;
 import org.springframework.boot.autoconfigure.web.ServerProperties;
 import org.springframework.boot.autoconfigure.web.reactive.WebFluxProperties;
+import org.springframework.boot.web.server.Ssl;
+import org.springframework.util.StringUtils;
 import org.springframework.web.util.UriComponentsBuilder;
 
 import de.codecentric.boot.admin.client.config.InstanceProperties;
 import de.codecentric.boot.admin.client.registration.metadata.MetadataContributor;
 
 public class ReactiveApplicationFactory extends DefaultApplicationFactory {
 
+	private ManagementServerProperties management;
+
+	private final ServerProperties server;
+
 	private WebFluxProperties webflux;
 
 	private InstanceProperties instance;
@@ -36,6 +42,8 @@ public ReactiveApplicationFactory(InstanceProperties instance, ManagementServerP
 			ServerProperties server, PathMappedEndpoints pathMappedEndpoints, WebEndpointProperties webEndpoint,
 			MetadataContributor metadataContributor, WebFluxProperties webFluxProperties) {
 		super(instance, management, server, pathMappedEndpoints, webEndpoint, metadataContributor);
+		this.management = management;
+		this.server = server;
 		this.webflux = webFluxProperties;
 		this.instance = instance;
 	}
@@ -50,6 +58,27 @@ protected String getServiceUrl() {
 				.toUriString();
 	}
 
+	@Override
+	protected String getManagementBaseUrl() {
+		String baseUrl = this.instance.getManagementBaseUrl();
+
+		if (StringUtils.hasText(baseUrl)) {
+			return baseUrl;
+		}
+
+		if (isManagementPortEqual()) {
+			return this.getServiceUrl();
+		}
+
+		Ssl ssl = (this.management.getSsl() != null) ? this.management.getSsl() : this.server.getSsl();
+		return UriComponentsBuilder.newInstance().scheme(getScheme(ssl)).host(getManagementHost())
+				.port(getLocalManagementPort()).path(getManagementContextPath()).toUriString();
+	}
+
+	protected String getManagementContextPath() {
+		return management.getBasePath();
+	}
+
 	protected String getWebfluxBasePath() {
 		return webflux.getBasePath();
 	}

spring-boot-admin-client/src/test/java/de/codecentric/boot/admin/client/registration/ReactiveApplicationFactoryTest.java

@@ -109,6 +109,19 @@ public void test_noBasePath() {
 		assertThat(app.getServiceUrl()).isEqualTo("http://" + getHostname() + ":80/");
 	}
 
+	@Test
+	public void test_mgmtBasePath_mgmtPortPath() {
+		webflux.setBasePath("/app");
+		management.setBasePath("/mgnt");
+		when(pathMappedEndpoints.getPath(EndpointId.of("health"))).thenReturn("/actuator/health");
+		publishApplicationReadyEvent(factory, 8080, 8081);
+
+		Application app = factory.createApplication();
+		assertThat(app.getManagementUrl()).isEqualTo("http://" + getHostname() + ":8081/mgnt/actuator");
+		assertThat(app.getHealthUrl()).isEqualTo("http://" + getHostname() + ":8081/mgnt/actuator/health");
+		assertThat(app.getServiceUrl()).isEqualTo("http://" + getHostname() + ":8080/app");
+	}
+
 	private String getHostname() {
 		try {
 			return InetAddress.getLocalHost().getCanonicalHostName();