diff --git a/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/reactive/error/DefaultErrorAttributes.java b/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/reactive/error/DefaultErrorAttributes.java
index 354b46988a..a618c45132 100644
--- a/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/reactive/error/DefaultErrorAttributes.java
+++ b/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/reactive/error/DefaultErrorAttributes.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2012-2023 the original author or authors.
+ * Copyright 2012-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -20,6 +20,7 @@ import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.Date;
import java.util.LinkedHashMap;
+import java.util.List;
import java.util.Map;
import java.util.Optional;
@@ -32,6 +33,7 @@ import org.springframework.http.HttpStatus;
import org.springframework.util.StringUtils;
import org.springframework.validation.BindingResult;
import org.springframework.validation.ObjectError;
+import org.springframework.validation.method.MethodValidationResult;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.server.ResponseStatusException;
@@ -46,8 +48,8 @@ import org.springframework.web.server.ServerWebExchange;
*
error - The error reason
* exception - The class name of the root exception (if configured)
* message - The exception message (if configured)
- * errors - Any {@link ObjectError}s from a {@link BindingResult} exception (if
- * configured)
+ * errors - Any {@link ObjectError}s from a {@link BindingResult} or
+ * {@link MethodValidationResult} exception (if configured)
* trace - The exception stack trace (if configured)
* path - The URL path when the exception was raised
* requestId - Unique ID associated with the current request
@@ -57,6 +59,7 @@ import org.springframework.web.server.ServerWebExchange;
* @author Stephane Nicoll
* @author Michele Mancioppi
* @author Scott Frederick
+ * @author Yanming Zhou
* @since 2.0.0
* @see ErrorAttributes
*/
@@ -93,9 +96,8 @@ public class DefaultErrorAttributes implements ErrorAttributes {
HttpStatus errorStatus = determineHttpStatus(error, responseStatusAnnotation);
errorAttributes.put("status", errorStatus.value());
errorAttributes.put("error", errorStatus.getReasonPhrase());
- errorAttributes.put("message", determineMessage(error, responseStatusAnnotation));
errorAttributes.put("requestId", request.exchange().getRequest().getId());
- handleException(errorAttributes, determineException(error), includeStackTrace);
+ handleException(errorAttributes, error, responseStatusAnnotation, includeStackTrace);
return errorAttributes;
}
@@ -109,27 +111,6 @@ public class DefaultErrorAttributes implements ErrorAttributes {
return responseStatusAnnotation.getValue("code", HttpStatus.class).orElse(HttpStatus.INTERNAL_SERVER_ERROR);
}
- private String determineMessage(Throwable error, MergedAnnotation responseStatusAnnotation) {
- if (error instanceof BindingResult) {
- return error.getMessage();
- }
- if (error instanceof ResponseStatusException responseStatusException) {
- return responseStatusException.getReason();
- }
- String reason = responseStatusAnnotation.getValue("reason", String.class).orElse("");
- if (StringUtils.hasText(reason)) {
- return reason;
- }
- return (error.getMessage() != null) ? error.getMessage() : "";
- }
-
- private Throwable determineException(Throwable error) {
- if (error instanceof ResponseStatusException) {
- return (error.getCause() != null) ? error.getCause() : error;
- }
- return error;
- }
-
private void addStackTrace(Map errorAttributes, Throwable error) {
StringWriter stackTrace = new StringWriter();
error.printStackTrace(new PrintWriter(stackTrace));
@@ -137,18 +118,46 @@ public class DefaultErrorAttributes implements ErrorAttributes {
errorAttributes.put("trace", stackTrace.toString());
}
- private void handleException(Map errorAttributes, Throwable error, boolean includeStackTrace) {
- errorAttributes.put("exception", error.getClass().getName());
+ private void handleException(Map errorAttributes, Throwable error,
+ MergedAnnotation responseStatusAnnotation, boolean includeStackTrace) {
+ Throwable exception;
+ if (error instanceof BindingResult bindingResult) {
+ errorAttributes.put("message", error.getMessage());
+ errorAttributes.put("errors", bindingResult.getAllErrors());
+ exception = error;
+ }
+ else if (error instanceof MethodValidationResult methodValidationResult) {
+ addMessageAndErrorsFromMethodValidationResult(errorAttributes, methodValidationResult);
+ exception = error;
+ }
+ else if (error instanceof ResponseStatusException responseStatusException) {
+ errorAttributes.put("message", responseStatusException.getReason());
+ exception = (responseStatusException.getCause() != null) ? responseStatusException.getCause() : error;
+ }
+ else {
+ exception = error;
+ String reason = responseStatusAnnotation.getValue("reason", String.class).orElse("");
+ String message = StringUtils.hasText(reason) ? reason : error.getMessage();
+ errorAttributes.put("message", (message != null) ? message : "");
+ }
+ errorAttributes.put("exception", exception.getClass().getName());
if (includeStackTrace) {
- addStackTrace(errorAttributes, error);
- }
- if (error instanceof BindingResult result) {
- if (result.hasErrors()) {
- errorAttributes.put("errors", result.getAllErrors());
- }
+ addStackTrace(errorAttributes, exception);
}
}
+ private void addMessageAndErrorsFromMethodValidationResult(Map errorAttributes,
+ MethodValidationResult result) {
+ List errors = result.getAllErrors()
+ .stream()
+ .filter(ObjectError.class::isInstance)
+ .map(ObjectError.class::cast)
+ .toList();
+ errorAttributes.put("message",
+ "Validation failed for method='" + result.getMethod() + "'. Error count: " + errors.size());
+ errorAttributes.put("errors", errors);
+ }
+
@Override
public Throwable getError(ServerRequest request) {
Optional