Consistent and lenient HttpMethod resolution across all web modules

Issue: SPR-13776
This commit is contained in:
Juergen Hoeller 2015-12-09 12:26:44 +01:00
parent 34b596c6bf
commit 4261f34b63
29 changed files with 149 additions and 109 deletions

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2013 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -128,7 +128,7 @@ public class MockMultipartHttpServletRequest extends MockHttpServletRequest impl
@Override @Override
public HttpMethod getRequestMethod() { public HttpMethod getRequestMethod() {
return HttpMethod.valueOf(getMethod()); return HttpMethod.resolve(getMethod());
} }
@Override @Override

View File

@ -470,7 +470,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Access-Control-Allow-Methods} response header. * Return the value of the {@code Access-Control-Allow-Methods} response header.
*/ */
public List<HttpMethod> getAccessControlAllowMethods() { public List<HttpMethod> getAccessControlAllowMethods() {
List<HttpMethod> result = new ArrayList<HttpMethod>(); List<HttpMethod> result = new ArrayList<HttpMethod>();
@ -478,7 +478,10 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
if (value != null) { if (value != null) {
String[] tokens = value.split(",\\s*"); String[] tokens = value.split(",\\s*");
for (String token : tokens) { for (String token : tokens) {
result.add(HttpMethod.valueOf(token)); HttpMethod resolved = HttpMethod.resolve(token);
if (resolved != null) {
result.add(resolved);
}
} }
} }
return result; return result;
@ -492,7 +495,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Access-Control-Allow-Origin} response header. * Return the value of the {@code Access-Control-Allow-Origin} response header.
*/ */
public String getAccessControlAllowOrigin() { public String getAccessControlAllowOrigin() {
return getFirst(ACCESS_CONTROL_ALLOW_ORIGIN); return getFirst(ACCESS_CONTROL_ALLOW_ORIGIN);
@ -550,11 +553,10 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Access-Control-Request-Method} request header. * Return the value of the {@code Access-Control-Request-Method} request header.
*/ */
public HttpMethod getAccessControlRequestMethod() { public HttpMethod getAccessControlRequestMethod() {
String value = getFirst(ACCESS_CONTROL_REQUEST_METHOD); return HttpMethod.resolve(getFirst(ACCESS_CONTROL_REQUEST_METHOD));
return (value != null ? HttpMethod.valueOf(value) : null);
} }
/** /**
@ -615,12 +617,15 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
public Set<HttpMethod> getAllow() { public Set<HttpMethod> getAllow() {
String value = getFirst(ALLOW); String value = getFirst(ALLOW);
if (!StringUtils.isEmpty(value)) { if (!StringUtils.isEmpty(value)) {
List<HttpMethod> allowedMethod = new ArrayList<HttpMethod>(5); List<HttpMethod> result = new LinkedList<HttpMethod>();
String[] tokens = value.split(",\\s*"); String[] tokens = value.split(",\\s*");
for (String token : tokens) { for (String token : tokens) {
allowedMethod.add(HttpMethod.valueOf(token)); HttpMethod resolved = HttpMethod.resolve(token);
if (resolved != null) {
result.add(resolved);
} }
return EnumSet.copyOf(allowedMethod); }
return EnumSet.copyOf(result);
} }
else { else {
return EnumSet.noneOf(HttpMethod.class); return EnumSet.noneOf(HttpMethod.class);
@ -635,7 +640,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Cache-Control} header. * Return the value of the {@code Cache-Control} header.
*/ */
public String getCacheControl() { public String getCacheControl() {
return getFirst(CACHE_CONTROL); return getFirst(CACHE_CONTROL);
@ -656,7 +661,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Connection} header. * Return the value of the {@code Connection} header.
*/ */
public List<String> getConnection() { public List<String> getConnection() {
return getFirstValueAsList(CONNECTION); return getFirstValueAsList(CONNECTION);
@ -920,7 +925,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Range} header. * Return the value of the {@code Range} header.
* <p>Returns an empty list when the range is unknown. * <p>Returns an empty list when the range is unknown.
*/ */
public List<HttpRange> getRange() { public List<HttpRange> getRange() {
@ -936,7 +941,7 @@ public class HttpHeaders implements MultiValueMap<String, String>, Serializable
} }
/** /**
* Returns the value of the {@code Upgrade} header. * Return the value of the {@code Upgrade} header.
*/ */
public String getUpgrade() { public String getUpgrade() {
return getFirst(UPGRADE); return getFirst(UPGRADE);

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2012 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -16,16 +16,52 @@
package org.springframework.http; package org.springframework.http;
import java.util.HashMap;
import java.util.Map;
/** /**
* Java 5 enumeration of HTTP request methods. Intended for use * Java 5 enumeration of HTTP request methods. Intended for use
* with {@link org.springframework.http.client.ClientHttpRequest} * with {@link org.springframework.http.client.ClientHttpRequest}
* and {@link org.springframework.web.client.RestTemplate}. * and {@link org.springframework.web.client.RestTemplate}.
* *
* @author Arjen Poutsma * @author Arjen Poutsma
* @author Juergen Hoeller
* @since 3.0 * @since 3.0
*/ */
public enum HttpMethod { public enum HttpMethod {
GET, POST, HEAD, OPTIONS, PUT, PATCH, DELETE, TRACE GET, HEAD, POST, PUT, PATCH, DELETE, OPTIONS, TRACE;
private static final Map<String, HttpMethod> mappings = new HashMap<String, HttpMethod>(8);
static {
for (HttpMethod httpMethod : values()) {
mappings.put(httpMethod.name(), httpMethod);
}
}
/**
* Resolve the given method value to an {@code HttpMethod}.
* @param method the method value as a String
* @return the corresponding {@code HttpMethod}, or {@code null} if not found
* @since 4.2.4
*/
public static HttpMethod resolve(String method) {
return (method != null ? mappings.get(method) : null);
}
/**
* Determine whether this {@code HttpMethod} matches the given
* method value.
* @param method the method value as a String
* @return {@code true} if it matches, {@code false} otherwise
* @since 4.2.4
*/
public boolean matches(String method) {
return name().equals(method);
}
} }

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2011 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -19,8 +19,8 @@ package org.springframework.http;
import java.net.URI; import java.net.URI;
/** /**
* Represents an HTTP request message, consisting of {@linkplain #getMethod() method} * Represents an HTTP request message, consisting of
* and {@linkplain #getURI() uri}. * {@linkplain #getMethod() method} and {@linkplain #getURI() uri}.
* *
* @author Arjen Poutsma * @author Arjen Poutsma
* @since 3.1 * @since 3.1
@ -29,13 +29,14 @@ public interface HttpRequest extends HttpMessage {
/** /**
* Return the HTTP method of the request. * Return the HTTP method of the request.
* @return the HTTP method as an HttpMethod enum value * @return the HTTP method as an HttpMethod enum value, or {@code null}
* if not resolvable (e.g. in case of a non-standard HTTP method)
*/ */
HttpMethod getMethod(); HttpMethod getMethod();
/** /**
* Return the URI of the request. * Return the URI of the request.
* @return the URI of the request * @return the URI of the request (never {@code null})
*/ */
URI getURI(); URI getURI();

View File

@ -20,7 +20,6 @@ import java.net.URI;
import java.nio.charset.Charset; import java.nio.charset.Charset;
import java.util.Arrays; import java.util.Arrays;
import org.springframework.util.Assert;
import org.springframework.util.MultiValueMap; import org.springframework.util.MultiValueMap;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
@ -104,8 +103,6 @@ public class RequestEntity<T> extends HttpEntity<T> {
*/ */
public RequestEntity(T body, MultiValueMap<String, String> headers, HttpMethod method, URI url) { public RequestEntity(T body, MultiValueMap<String, String> headers, HttpMethod method, URI url) {
super(body, headers); super(body, headers);
Assert.notNull(method, "'method' is required");
Assert.notNull(url, "'url' is required");
this.method = method; this.method = method;
this.url = url; this.url = url;
} }

View File

@ -68,7 +68,7 @@ final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncC
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.httpRequest.getMethod()); return HttpMethod.resolve(this.httpRequest.getMethod());
} }
@Override @Override

View File

@ -66,7 +66,7 @@ final class HttpComponentsClientHttpRequest extends AbstractBufferingClientHttpR
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.httpRequest.getMethod()); return HttpMethod.resolve(this.httpRequest.getMethod());
} }
@Override @Override

View File

@ -65,7 +65,7 @@ final class HttpComponentsStreamingClientHttpRequest extends AbstractClientHttpR
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.httpRequest.getMethod()); return HttpMethod.resolve(this.httpRequest.getMethod());
} }
@Override @Override

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -57,7 +57,7 @@ final class SimpleBufferingAsyncClientHttpRequest extends AbstractBufferingAsync
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.connection.getRequestMethod()); return HttpMethod.resolve(this.connection.getRequestMethod());
} }
@Override @Override
@ -78,8 +78,8 @@ final class SimpleBufferingAsyncClientHttpRequest extends AbstractBufferingAsync
@Override @Override
public ClientHttpResponse call() throws Exception { public ClientHttpResponse call() throws Exception {
SimpleBufferingClientHttpRequest.addHeaders(connection, headers); SimpleBufferingClientHttpRequest.addHeaders(connection, headers);
// JDK < 1.8 doesn't support getOutputStream with HTTP DELETE // JDK <1.8 doesn't support getOutputStream with HTTP DELETE
if (HttpMethod.DELETE.equals(getMethod()) && bufferedOutput.length == 0) { if (HttpMethod.DELETE == getMethod() && bufferedOutput.length == 0) {
connection.setDoOutput(false); connection.setDoOutput(false);
} }
if (connection.getDoOutput() && outputStreaming) { if (connection.getDoOutput() && outputStreaming) {

View File

@ -52,7 +52,7 @@ final class SimpleBufferingClientHttpRequest extends AbstractBufferingClientHttp
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.connection.getRequestMethod()); return HttpMethod.resolve(this.connection.getRequestMethod());
} }
@Override @Override
@ -69,8 +69,8 @@ final class SimpleBufferingClientHttpRequest extends AbstractBufferingClientHttp
protected ClientHttpResponse executeInternal(HttpHeaders headers, byte[] bufferedOutput) throws IOException { protected ClientHttpResponse executeInternal(HttpHeaders headers, byte[] bufferedOutput) throws IOException {
addHeaders(this.connection, headers); addHeaders(this.connection, headers);
// JDK < 1.8 doesn't support getOutputStream with HTTP DELETE // JDK <1.8 doesn't support getOutputStream with HTTP DELETE
if (HttpMethod.DELETE.equals(getMethod()) && bufferedOutput.length == 0) { if (HttpMethod.DELETE == getMethod() && bufferedOutput.length == 0) {
this.connection.setDoOutput(false); this.connection.setDoOutput(false);
} }

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -63,7 +63,7 @@ final class SimpleStreamingAsyncClientHttpRequest extends AbstractAsyncClientHtt
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.connection.getRequestMethod()); return HttpMethod.resolve(this.connection.getRequestMethod());
} }
@Override @Override

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -53,7 +53,7 @@ final class SimpleStreamingClientHttpRequest extends AbstractClientHttpRequest {
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.connection.getRequestMethod()); return HttpMethod.resolve(this.connection.getRequestMethod());
} }
@Override @Override

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -55,8 +55,6 @@ public class ServletServerHttpRequest implements ServerHttpRequest {
protected static final String FORM_CHARSET = "UTF-8"; protected static final String FORM_CHARSET = "UTF-8";
private static final String METHOD_POST = "POST";
private final HttpServletRequest servletRequest; private final HttpServletRequest servletRequest;
@ -84,7 +82,7 @@ public class ServletServerHttpRequest implements ServerHttpRequest {
@Override @Override
public HttpMethod getMethod() { public HttpMethod getMethod() {
return HttpMethod.valueOf(this.servletRequest.getMethod()); return HttpMethod.resolve(this.servletRequest.getMethod());
} }
@Override @Override
@ -166,9 +164,22 @@ public class ServletServerHttpRequest implements ServerHttpRequest {
} }
} }
private boolean isFormPost(HttpServletRequest request) { @Override
return (request.getContentType() != null && request.getContentType().contains(FORM_CONTENT_TYPE) && public ServerHttpAsyncRequestControl getAsyncRequestControl(ServerHttpResponse response) {
METHOD_POST.equalsIgnoreCase(request.getMethod())); if (this.asyncRequestControl == null) {
Assert.isInstanceOf(ServletServerHttpResponse.class, response);
ServletServerHttpResponse servletServerResponse = (ServletServerHttpResponse) response;
this.asyncRequestControl = new ServletServerHttpAsyncRequestControl(this, servletServerResponse);
}
return this.asyncRequestControl;
}
private static boolean isFormPost(HttpServletRequest request) {
String contentType = request.getContentType();
return (contentType != null && contentType.contains(FORM_CONTENT_TYPE) &&
HttpMethod.POST.matches(request.getMethod()));
} }
/** /**
@ -177,7 +188,7 @@ public class ServletServerHttpRequest implements ServerHttpRequest {
* from the body, which can fail if any other code has used ServletRequest * from the body, which can fail if any other code has used ServletRequest
* to access a parameter thus causing the input stream to be "consumed". * to access a parameter thus causing the input stream to be "consumed".
*/ */
private InputStream getBodyFromServletRequestParameters(HttpServletRequest request) throws IOException { private static InputStream getBodyFromServletRequestParameters(HttpServletRequest request) throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream(1024); ByteArrayOutputStream bos = new ByteArrayOutputStream(1024);
Writer writer = new OutputStreamWriter(bos, FORM_CHARSET); Writer writer = new OutputStreamWriter(bos, FORM_CHARSET);
@ -205,14 +216,4 @@ public class ServletServerHttpRequest implements ServerHttpRequest {
return new ByteArrayInputStream(bos.toByteArray()); return new ByteArrayInputStream(bos.toByteArray());
} }
@Override
public ServerHttpAsyncRequestControl getAsyncRequestControl(ServerHttpResponse response) {
if (this.asyncRequestControl == null) {
Assert.isInstanceOf(ServletServerHttpResponse.class, response);
ServletServerHttpResponse servletServerResponse = (ServletServerHttpResponse) response;
this.asyncRequestControl = new ServletServerHttpAsyncRequestControl(this, servletServerResponse);
}
return this.asyncRequestControl;
}
} }

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2013 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -17,8 +17,9 @@
package org.springframework.web; package org.springframework.web;
import java.util.Collection; import java.util.Collection;
import java.util.Collections; import java.util.EnumSet;
import java.util.LinkedHashSet; import java.util.LinkedList;
import java.util.List;
import java.util.Set; import java.util.Set;
import javax.servlet.ServletException; import javax.servlet.ServletException;
@ -105,11 +106,14 @@ public class HttpRequestMethodNotSupportedException extends ServletException {
* Return the actually supported HTTP methods, if known, as {@link HttpMethod} instances. * Return the actually supported HTTP methods, if known, as {@link HttpMethod} instances.
*/ */
public Set<HttpMethod> getSupportedHttpMethods() { public Set<HttpMethod> getSupportedHttpMethods() {
Set<HttpMethod> supportedMethods = new LinkedHashSet<HttpMethod>(); List<HttpMethod> supportedMethods = new LinkedList<HttpMethod>();
for (String value : this.supportedMethods) { for (String value : this.supportedMethods) {
supportedMethods.add(HttpMethod.valueOf(value)); HttpMethod resolved = HttpMethod.resolve(value);
if (resolved != null) {
supportedMethods.add(resolved);
} }
return Collections.unmodifiableSet(supportedMethods); }
return EnumSet.copyOf(supportedMethods);
} }
} }

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2012 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -17,16 +17,14 @@
package org.springframework.web.bind.annotation; package org.springframework.web.bind.annotation;
/** /**
* Java 5 enumeration of HTTP request methods. Intended for use * Java 5 enumeration of HTTP request methods. Intended for use with the
* with the {@link RequestMapping#method()} attribute of the * {@link RequestMapping#method()} attribute of the {@link RequestMapping} annotation.
* {@link RequestMapping} annotation.
* *
* <p>Note that, by default, {@link org.springframework.web.servlet.DispatcherServlet} * <p>Note that, by default, {@link org.springframework.web.servlet.DispatcherServlet}
* supports GET, HEAD, POST, PUT, PATCH and DELETE only. DispatcherServlet will * supports GET, HEAD, POST, PUT, PATCH and DELETE only. DispatcherServlet will
* process TRACE and OPTIONS with the default HttpServlet behavior unless * process TRACE and OPTIONS with the default HttpServlet behavior unless explicitly
* explicitly told to dispatch those request types as well: Check out * told to dispatch those request types as well: Check out the "dispatchOptionsRequest"
* the "dispatchOptionsRequest" and "dispatchTraceRequest" properties, * and "dispatchTraceRequest" properties, switching them to "true" if necessary.
* switching them to "true" if necessary.
* *
* @author Juergen Hoeller * @author Juergen Hoeller
* @since 2.5 * @since 2.5

View File

@ -106,7 +106,7 @@ public class ServletWebRequest extends ServletRequestAttributes implements Nativ
* @since 4.0.2 * @since 4.0.2
*/ */
public HttpMethod getHttpMethod() { public HttpMethod getHttpMethod() {
return HttpMethod.valueOf(getRequest().getMethod()); return HttpMethod.resolve(getRequest().getMethod());
} }
@Override @Override

View File

@ -344,10 +344,13 @@ public class CorsConfiguration {
List<HttpMethod> result = new ArrayList<HttpMethod>(allowedMethods.size()); List<HttpMethod> result = new ArrayList<HttpMethod>(allowedMethods.size());
boolean allowed = false; boolean allowed = false;
for (String method : allowedMethods) { for (String method : allowedMethods) {
if (requestMethod.name().equals(method)) { if (requestMethod.matches(method)) {
allowed = true; allowed = true;
} }
result.add(HttpMethod.valueOf(method)); HttpMethod resolved = HttpMethod.resolve(method);
if (resolved != null) {
result.add(resolved);
}
} }
return (allowed ? result : null); return (allowed ? result : null);
} }

View File

@ -28,7 +28,7 @@ import org.springframework.http.HttpMethod;
* @author Sebastien Deleuze * @author Sebastien Deleuze
* @since 4.2 * @since 4.2
*/ */
public class CorsUtils { public abstract class CorsUtils {
/** /**
* Returns {@code true} if the request is a valid CORS one. * Returns {@code true} if the request is a valid CORS one.
@ -41,7 +41,7 @@ public class CorsUtils {
* Returns {@code true} if the request is a valid CORS pre-flight one. * Returns {@code true} if the request is a valid CORS pre-flight one.
*/ */
public static boolean isPreFlightRequest(HttpServletRequest request) { public static boolean isPreFlightRequest(HttpServletRequest request) {
return (isCorsRequest(request) && request.getMethod().equals(HttpMethod.OPTIONS.name()) && return (isCorsRequest(request) && HttpMethod.OPTIONS.matches(request.getMethod()) &&
request.getHeader(HttpHeaders.ACCESS_CONTROL_REQUEST_METHOD) != null); request.getHeader(HttpHeaders.ACCESS_CONTROL_REQUEST_METHOD) != null);
} }

View File

@ -144,7 +144,7 @@ public class ShallowEtagHeaderFilter extends OncePerRequestFilter {
protected boolean isEligibleForEtag(HttpServletRequest request, HttpServletResponse response, protected boolean isEligibleForEtag(HttpServletRequest request, HttpServletResponse response,
int responseStatusCode, InputStream inputStream) { int responseStatusCode, InputStream inputStream) {
if (responseStatusCode >= 200 && responseStatusCode < 300 && HttpMethod.GET.name().equals(request.getMethod())) { if (responseStatusCode >= 200 && responseStatusCode < 300 && HttpMethod.GET.matches(request.getMethod())) {
String cacheControl = null; String cacheControl = null;
if (servlet3Present) { if (servlet3Present) {
cacheControl = response.getHeader(HEADER_CACHE_CONTROL); cacheControl = response.getHeader(HEADER_CACHE_CONTROL);

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2012 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -61,7 +61,7 @@ public abstract class AbstractMultipartHttpServletRequest extends HttpServletReq
@Override @Override
public HttpMethod getRequestMethod() { public HttpMethod getRequestMethod() {
return HttpMethod.valueOf(getRequest().getMethod()); return HttpMethod.resolve(getRequest().getMethod());
} }
@Override @Override

View File

@ -30,6 +30,8 @@ import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper; import javax.servlet.http.HttpServletRequestWrapper;
import org.springframework.http.HttpMethod;
/** /**
* {@link javax.servlet.http.HttpServletRequest} wrapper that caches all content read from * {@link javax.servlet.http.HttpServletRequest} wrapper that caches all content read from
* the {@linkplain #getInputStream() input stream} and {@linkplain #getReader() reader}, * the {@linkplain #getInputStream() input stream} and {@linkplain #getReader() reader},
@ -46,8 +48,6 @@ public class ContentCachingRequestWrapper extends HttpServletRequestWrapper {
private static final String FORM_CONTENT_TYPE = "application/x-www-form-urlencoded"; private static final String FORM_CONTENT_TYPE = "application/x-www-form-urlencoded";
private static final String METHOD_POST = "POST";
private final ByteArrayOutputStream cachedContent; private final ByteArrayOutputStream cachedContent;
@ -125,7 +125,7 @@ public class ContentCachingRequestWrapper extends HttpServletRequestWrapper {
private boolean isFormPost() { private boolean isFormPost() {
String contentType = getContentType(); String contentType = getContentType();
return (contentType != null && contentType.contains(FORM_CONTENT_TYPE) && return (contentType != null && contentType.contains(FORM_CONTENT_TYPE) &&
METHOD_POST.equalsIgnoreCase(getMethod())); HttpMethod.POST.matches(getMethod()));
} }
private void writeRequestParametersToCachedContent() { private void writeRequestParametersToCachedContent() {

View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2013 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -128,7 +128,7 @@ public class MockMultipartHttpServletRequest extends MockHttpServletRequest impl
@Override @Override
public HttpMethod getRequestMethod() { public HttpMethod getRequestMethod() {
return HttpMethod.valueOf(getMethod()); return HttpMethod.resolve(getMethod());
} }
@Override @Override

View File

@ -1137,9 +1137,8 @@ public class DispatcherServlet extends FrameworkServlet {
"] in DispatcherServlet with name '" + getServletName() + "'"); "] in DispatcherServlet with name '" + getServletName() + "'");
} }
if (this.throwExceptionIfNoHandlerFound) { if (this.throwExceptionIfNoHandlerFound) {
ServletServerHttpRequest sshr = new ServletServerHttpRequest(request); throw new NoHandlerFoundException(request.getMethod(), getRequestUri(request),
throw new NoHandlerFoundException( new ServletServerHttpRequest(request).getHeaders());
sshr.getMethod().name(), sshr.getServletRequest().getRequestURI(), sshr.getHeaders());
} }
else { else {
response.sendError(HttpServletResponse.SC_NOT_FOUND); response.sendError(HttpServletResponse.SC_NOT_FOUND);

View File

@ -42,6 +42,7 @@ import org.springframework.context.i18n.SimpleLocaleContext;
import org.springframework.core.GenericTypeResolver; import org.springframework.core.GenericTypeResolver;
import org.springframework.core.annotation.AnnotationAwareOrderComparator; import org.springframework.core.annotation.AnnotationAwareOrderComparator;
import org.springframework.core.env.ConfigurableEnvironment; import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.http.HttpMethod;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import org.springframework.util.ClassUtils; import org.springframework.util.ClassUtils;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
@ -831,15 +832,13 @@ public abstract class FrameworkServlet extends HttpServletBean implements Applic
/** /**
* Override the parent class implementation in order to intercept PATCH * Override the parent class implementation in order to intercept PATCH requests.
* requests.
*/ */
@Override @Override
protected void service(HttpServletRequest request, HttpServletResponse response) protected void service(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException { throws ServletException, IOException {
String method = request.getMethod(); if (HttpMethod.PATCH.matches(request.getMethod())) {
if (method.equalsIgnoreCase(RequestMethod.PATCH.name())) {
processRequest(request, response); processRequest(request, response);
} }
else { else {

View File

@ -22,8 +22,8 @@ import java.io.PushbackInputStream;
import java.lang.annotation.Annotation; import java.lang.annotation.Annotation;
import java.lang.reflect.Type; import java.lang.reflect.Type;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.EnumSet;
import java.util.LinkedHashSet; import java.util.LinkedHashSet;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
@ -63,8 +63,8 @@ import org.springframework.web.method.support.HandlerMethodArgumentResolver;
*/ */
public abstract class AbstractMessageConverterMethodArgumentResolver implements HandlerMethodArgumentResolver { public abstract class AbstractMessageConverterMethodArgumentResolver implements HandlerMethodArgumentResolver {
private static final List<HttpMethod> SUPPORTED_METHODS = private static final Set<HttpMethod> SUPPORTED_METHODS =
Arrays.asList(HttpMethod.POST, HttpMethod.PUT, HttpMethod.PATCH); EnumSet.of(HttpMethod.POST, HttpMethod.PUT, HttpMethod.PATCH);
private static final Object NO_VALUE = new Object(); private static final Object NO_VALUE = new Object();
@ -228,8 +228,8 @@ public abstract class AbstractMessageConverterMethodArgumentResolver implements
} }
if (body == NO_VALUE) { if (body == NO_VALUE) {
if (!SUPPORTED_METHODS.contains(httpMethod) if (httpMethod == null || !SUPPORTED_METHODS.contains(httpMethod) ||
|| (noContentType && inputMessage.getBody() == null)) { (noContentType && inputMessage.getBody() == null)) {
return null; return null;
} }
throw new HttpMediaTypeNotSupportedException(contentType, this.allSupportedMediaTypes); throw new HttpMediaTypeNotSupportedException(contentType, this.allSupportedMediaTypes);

View File

@ -19,7 +19,6 @@ package org.springframework.web.servlet.mvc.method.annotation;
import java.io.IOException; import java.io.IOException;
import java.lang.reflect.ParameterizedType; import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type; import java.lang.reflect.Type;
import java.net.URI;
import java.util.List; import java.util.List;
import org.springframework.core.MethodParameter; import org.springframework.core.MethodParameter;
@ -122,9 +121,8 @@ public class HttpEntityMethodProcessor extends AbstractMessageConverterMethodPro
Object body = readWithMessageConverters(webRequest, parameter, paramType); Object body = readWithMessageConverters(webRequest, parameter, paramType);
if (RequestEntity.class == parameter.getParameterType()) { if (RequestEntity.class == parameter.getParameterType()) {
URI url = inputMessage.getURI(); return new RequestEntity<Object>(body, inputMessage.getHeaders(),
HttpMethod httpMethod = inputMessage.getMethod(); inputMessage.getMethod(), inputMessage.getURI());
return new RequestEntity<Object>(body, inputMessage.getHeaders(), httpMethod, url);
} }
else { else {
return new HttpEntity<Object>(body, inputMessage.getHeaders()); return new HttpEntity<Object>(body, inputMessage.getHeaders());
@ -172,8 +170,7 @@ public class HttpEntityMethodProcessor extends AbstractMessageConverterMethodPro
Object body = responseEntity.getBody(); Object body = responseEntity.getBody();
if (responseEntity instanceof ResponseEntity) { if (responseEntity instanceof ResponseEntity) {
outputMessage.setStatusCode(((ResponseEntity<?>) responseEntity).getStatusCode()); outputMessage.setStatusCode(((ResponseEntity<?>) responseEntity).getStatusCode());
if (inputMessage.getMethod().equals(HttpMethod.GET) && if (HttpMethod.GET == inputMessage.getMethod() && isResourceNotModified(inputMessage, outputMessage)) {
isResourceNotModified(inputMessage, outputMessage)) {
outputMessage.setStatusCode(HttpStatus.NOT_MODIFIED); outputMessage.setStatusCode(HttpStatus.NOT_MODIFIED);
// Ensure headers are flushed, no body should be written. // Ensure headers are flushed, no body should be written.
outputMessage.flush(); outputMessage.flush();

View File

@ -231,7 +231,7 @@ public abstract class AbstractHandshakeHandler implements HandshakeHandler, Life
logger.trace("Processing request " + request.getURI() + " with headers=" + headers); logger.trace("Processing request " + request.getURI() + " with headers=" + headers);
} }
try { try {
if (!HttpMethod.GET.equals(request.getMethod())) { if (HttpMethod.GET != request.getMethod()) {
response.setStatusCode(HttpStatus.METHOD_NOT_ALLOWED); response.setStatusCode(HttpStatus.METHOD_NOT_ALLOWED);
response.getHeaders().setAllow(Collections.singleton(HttpMethod.GET)); response.getHeaders().setAllow(Collections.singleton(HttpMethod.GET));
if (logger.isErrorEnabled()) { if (logger.isErrorEnabled()) {
@ -320,8 +320,8 @@ public abstract class AbstractHandshakeHandler implements HandshakeHandler, Life
". Supported versions: " + Arrays.toString(getSupportedVersions())); ". Supported versions: " + Arrays.toString(getSupportedVersions()));
} }
response.setStatusCode(HttpStatus.UPGRADE_REQUIRED); response.setStatusCode(HttpStatus.UPGRADE_REQUIRED);
response.getHeaders().put(WebSocketHttpHeaders.SEC_WEBSOCKET_VERSION, response.getHeaders().set(WebSocketHttpHeaders.SEC_WEBSOCKET_VERSION,
Arrays.asList(StringUtils.arrayToCommaDelimitedString(getSupportedVersions()))); StringUtils.arrayToCommaDelimitedString(getSupportedVersions()));
} }
/** /**

View File

@ -544,7 +544,7 @@ public abstract class AbstractSockJsService implements SockJsService, CorsConfig
@Override @Override
public void handle(ServerHttpRequest request, ServerHttpResponse response) throws IOException { public void handle(ServerHttpRequest request, ServerHttpResponse response) throws IOException {
if (HttpMethod.GET.equals(request.getMethod())) { if (HttpMethod.GET == request.getMethod()) {
addNoCacheHeaders(response); addNoCacheHeaders(response);
if (checkOrigin(request, response)) { if (checkOrigin(request, response)) {
response.getHeaders().setContentType(new MediaType("application", "json", UTF8_CHARSET)); response.getHeaders().setContentType(new MediaType("application", "json", UTF8_CHARSET));
@ -554,7 +554,7 @@ public abstract class AbstractSockJsService implements SockJsService, CorsConfig
} }
} }
else if (HttpMethod.OPTIONS.equals(request.getMethod())) { else if (HttpMethod.OPTIONS == request.getMethod()) {
if (checkOrigin(request, response)) { if (checkOrigin(request, response)) {
addCacheHeaders(response); addCacheHeaders(response);
response.setStatusCode(HttpStatus.NO_CONTENT); response.setStatusCode(HttpStatus.NO_CONTENT);

View File

@ -247,8 +247,8 @@ public class TransportHandlingSockJsService extends AbstractSockJsService implem
try { try {
HttpMethod supportedMethod = transportType.getHttpMethod(); HttpMethod supportedMethod = transportType.getHttpMethod();
if (!supportedMethod.equals(request.getMethod())) { if (supportedMethod != request.getMethod()) {
if (HttpMethod.OPTIONS.equals(request.getMethod()) && transportType.supportsCors()) { if (HttpMethod.OPTIONS == request.getMethod() && transportType.supportsCors()) {
if (checkOrigin(request, response, HttpMethod.OPTIONS, supportedMethod)) { if (checkOrigin(request, response, HttpMethod.OPTIONS, supportedMethod)) {
response.setStatusCode(HttpStatus.NO_CONTENT); response.setStatusCode(HttpStatus.NO_CONTENT);
addCacheHeaders(response); addCacheHeaders(response);