| description |
|---|
spring actuator上报指标uri=known修复 |
import org.springframework.boot.actuate.metrics.web.reactive.server.WebFluxTags;
import org.springframework.boot.actuate.metrics.web.reactive.server.WebFluxTagsProvider;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import io.micrometer.core.instrument.Tag;
import org.springframework.http.HttpStatus;
import org.springframework.web.reactive.HandlerMapping;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.util.pattern.PathPattern;
import java.util.Arrays;
@Configuration
public class WebFluxMetricsConfig {
@Bean
public WebFluxTagsProvider customTagsProvider() {
return new WebFluxTagsProvider() {
private final Tag URI_NOT_FOUND = Tag.of("uri", "NOT_FOUND");
private final Tag URI_REDIRECTION = Tag.of("uri", "REDIRECTION");
private final Tag URI_ROOT = Tag.of("uri", "root");
@Override
public Iterable<Tag> httpRequestTags(ServerWebExchange exchange, Throwable exception) {
return Arrays.asList(WebFluxTags.method(exchange),
uriTag(exchange),
WebFluxTags.exception(exception),
WebFluxTags.status(exchange),
WebFluxTags.outcome(exchange));
}
Tag uriTag(ServerWebExchange exchange) {
String matchingPattern = exchange
.getAttribute(RouterFunctions.MATCHING_PATTERN_ATTRIBUTE);
if (matchingPattern != null) {
return Tag.of("uri", matchingPattern);
}
PathPattern pathPattern = exchange
.getAttribute(HandlerMapping.BEST_MATCHING_PATTERN_ATTRIBUTE);
if (pathPattern != null) {
return Tag.of("uri", pathPattern.getPatternString());
}
HttpStatus status = exchange.getResponse().getStatusCode();
if (status != null) {
if (status.is3xxRedirection()) {
return URI_REDIRECTION;
}
if (status == HttpStatus.NOT_FOUND) {
return URI_NOT_FOUND;
}
}
String path = exchange.getRequest().getPath().value();
if (path.isEmpty()) {
return URI_ROOT;
}
return Tag.of("uri", path);
}
};
}
}