Go语言视频零基础入门到精通

admin

  tomcat进行http request解析的时候报错，并将错误返回给客户端了，具体的错误如下：

1. org.apache.coyote.http11.AbstractHttp11Processor.process Error parsing HTTP request header
2. Note: further occurrences of HTTP header parsing errors will be logged at DEBUG level.

复制代码

  查看对应的类代码，其中涉及的方法如下：

1. public SocketState process(SocketWrapper<S> socketWrapper)
2.     throws IOException {
3.     RequestInfo rp = request.getRequestProcessor();
4.     rp.setStage(org.apache.coyote.Constants.STAGE_PARSE);
6.     // Setting up the I/O
7.     setSocketWrapper(socketWrapper);
8.     getInputBuffer().init(socketWrapper, endpoint);
9.     getOutputBuffer().init(socketWrapper, endpoint);
11.     // Flags
12.     keepAlive = true;
13.     comet = false;
14.     openSocket = false;
15.     sendfileInProgress = false;
16.     readComplete = true;
17.     if (endpoint.getUsePolling()) {
18.       keptAlive = false;
19.     } else {
20.       keptAlive = socketWrapper.isKeptAlive();
21.     }
23.     if (disableKeepAlive()) {
24.       socketWrapper.setKeepAliveLeft(0);
25.     }
27.     while (!getErrorState().isError() && keepAlive && !comet && !isAsync() &&
28.         httpUpgradeHandler == null && !endpoint.isPaused()) {
30.       // Parsing the request header
31.       try {
32.         setRequestLineReadTimeout();
34.         if (!getInputBuffer().parseRequestLine(keptAlive)) {
35.           if (handleIncompleteRequestLineRead()) {
36.             break;
37.           }
38.         }
40.         if (endpoint.isPaused()) {
41.           // 503 - Service unavailable
42.           response.setStatus(503);
43.           setErrorState(ErrorState.CLOSE_CLEAN, null);
44.         } else {
45.           keptAlive = true;
46.           // Set this every time in case limit has been changed via JMX
47.           request.getMimeHeaders().setLimit(endpoint.getMaxHeaderCount());
48.           // Currently only NIO will ever return false here
49.           if (!getInputBuffer().parseHeaders()) {
50.             // We"ve read part of the request, don"t recycle it
51.             // instead associate it with the socket
52.             openSocket = true;
53.             readComplete = false;
54.             break;
55.           }
56.           if (!disableUploadTimeout) {
57.             setSocketTimeout(connectionUploadTimeout);
58.           }
59.         }
60.       } catch (IOException e) {
61.         if (getLog().isDebugEnabled()) {
62.           getLog().debug(
63.               sm.getString("http11processor.header.parse"), e);
64.         }
65.         setErrorState(ErrorState.CLOSE_NOW, e);
66.         break;
67.       } catch (Throwable t) {
68.         ExceptionUtils.handleThrowable(t);
69.         UserDataHelper.Mode logMode = userDataHelper.getNextMode();
70.         if (logMode != null) {
71.           String message = sm.getString(
72.               "http11processor.header.parse");
73.           switch (logMode) {
74.             case INFO_THEN_DEBUG:
75.               message += sm.getString(
76.                   "http11processor.fallToDebug");
77.               //$FALL-THROUGH$
78.             case INFO:
79.               getLog().info(message);
80.               break;
81.             case DEBUG:
82.               getLog().debug(message);
83.           }
84.         }
85.         // 400 - Bad Request
86.         response.setStatus(400);
87.         setErrorState(ErrorState.CLOSE_CLEAN, t);
88.         getAdapter().log(request, response, 0);
89.       }
91.       if (!getErrorState().isError()) {
92.         // Setting up filters, and parse some request headers
93.         rp.setStage(org.apache.coyote.Constants.STAGE_PREPARE);
94.         try {
95.           prepareRequest();
96.         } catch (Throwable t) {
97.           ExceptionUtils.handleThrowable(t);
98.           if (getLog().isDebugEnabled()) {
99.             getLog().debug(sm.getString(
100.                 "http11processor.request.prepare"), t);
101.           }
102.           // 500 - Internal Server Error
103.           response.setStatus(500);
104.           setErrorState(ErrorState.CLOSE_CLEAN, t);
105.           getAdapter().log(request, response, 0);
106.         }
107.       }
109.       if (maxKeepAliveRequests == 1) {
110.         keepAlive = false;
111.       } else if (maxKeepAliveRequests > 0 &&
112.           socketWrapper.decrementKeepAlive() <= 0) {
113.         keepAlive = false;
114.       }
116.       // Process the request in the adapter
117.       if (!getErrorState().isError()) {
118.         try {
119.           rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
120.           getAdapter().service(request, response);
121.           // Handle when the response was committed before a serious
122.           // error occurred.  Throwing a ServletException should both
123.           // set the status to 500 and set the errorException.
124.           // If we fail here, then the response is likely already
125.           // committed, so we can"t try and set headers.
126.           if(keepAlive && !getErrorState().isError() && (
127.               response.getErrorException() != null ||
128.                   (!isAsync() &&
129.                   statusDropsConnection(response.getStatus())))) {
130.             setErrorState(ErrorState.CLOSE_CLEAN, null);
131.           }
132.           setCometTimeouts(socketWrapper);
133.         } catch (InterruptedIOException e) {
134.           setErrorState(ErrorState.CLOSE_NOW, e);
135.         } catch (HeadersTooLargeException e) {
136.           // The response should not have been committed but check it
137.           // anyway to be safe
138.           if (response.isCommitted()) {
139.             setErrorState(ErrorState.CLOSE_NOW, e);
140.           } else {
141.             response.reset();
142.             response.setStatus(500);
143.             setErrorState(ErrorState.CLOSE_CLEAN, e);
144.             response.setHeader("Connection", "close"); // TODO: Remove
145.           }
146.         } catch (Throwable t) {
147.           ExceptionUtils.handleThrowable(t);
148.           getLog().error(sm.getString(
149.               "http11processor.request.process"), t);
150.           // 500 - Internal Server Error
151.           response.setStatus(500);
152.           setErrorState(ErrorState.CLOSE_CLEAN, t);
153.           getAdapter().log(request, response, 0);
154.         }
155.       }
157.       // Finish the handling of the request
158.       rp.setStage(org.apache.coyote.Constants.STAGE_ENDINPUT);
160.       if (!isAsync() && !comet) {
161.         if (getErrorState().isError()) {
162.           // If we know we are closing the connection, don"t drain
163.           // input. This way uploading a 100GB file doesn"t tie up the
164.           // thread if the servlet has rejected it.
165.           getInputBuffer().setSwallowInput(false);
166.         } else if (expectation &&
167.             (response.getStatus() < 200 || response.getStatus() > 299)) {
168.           // Client sent Expect: 100-continue but received a
169.           // non-2xx final response. Disable keep-alive (if enabled)
170.           // to ensure that the connection is closed. Some clients may
171.           // still send the body, some may send the next request.
172.           // No way to differentiate, so close the connection to
173.           // force the client to send the next request.
174.           getInputBuffer().setSwallowInput(false);
175.           keepAlive = false;
176.         }
177.         endRequest();
178.       }
180.       rp.setStage(org.apache.coyote.Constants.STAGE_ENDOUTPUT);
182.       // If there was an error, make sure the request is counted as
183.       // and error, and update the statistics counter
184.       if (getErrorState().isError()) {
185.         response.setStatus(500);
186.       }
187.       request.updateCounters();
189.       if (!isAsync() && !comet || getErrorState().isError()) {
190.         if (getErrorState().isIoAllowed()) {
191.           getInputBuffer().nextRequest();
192.           getOutputBuffer().nextRequest();
193.         }
194.       }
196.       if (!disableUploadTimeout) {
197.         if(endpoint.getSoTimeout() > 0) {
198.           setSocketTimeout(endpoint.getSoTimeout());
199.         } else {
200.           setSocketTimeout(0);
201.         }
202.       }
204.       rp.setStage(org.apache.coyote.Constants.STAGE_KEEPALIVE);
206.       if (breakKeepAliveLoop(socketWrapper)) {
207.         break;
208.       }
209.     }
211.     rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);
213.     if (getErrorState().isError() || endpoint.isPaused()) {
214.       return SocketState.CLOSED;
215.     } else if (isAsync() || comet) {
216.       return SocketState.LONG;
217.     } else if (isUpgrade()) {
218.       return SocketState.UPGRADING;
219.     } else {
220.       if (sendfileInProgress) {
221.         return SocketState.SENDFILE;
222.       } else {
223.         if (openSocket) {
224.           if (readComplete) {
225.             return SocketState.OPEN;
226.           } else {
227.             return SocketState.LONG;
228.           }
229.         } else {
230.           return SocketState.CLOSED;
231.         }
232.       }
233.     }
234.   }

复制代码

  而报错的地方则是在：

1. // Currently only NIO will ever return false here
2.           if (!getInputBuffer().parseHeaders()) {
3.             // We"ve read part of the request, don"t recycle it
4.             // instead associate it with the socket
5.             openSocket = true;
6.             readComplete = false;
7.             break;
8.           }
9.           if (!disableUploadTimeout) {
10.             setSocketTimeout(connectionUploadTimeout);
11.           }
12. 的时候抛出了异常，对应的catch块代码如下：
13. catch (Throwable t) {
14.         ExceptionUtils.handleThrowable(t);
15.         UserDataHelper.Mode logMode = userDataHelper.getNextMode();
16.         if (logMode != null) {
17.           String message = sm.getString(
18.               "http11processor.header.parse");
19.           switch (logMode) {
20.             case INFO_THEN_DEBUG:
21.               message += sm.getString(
22.                   "http11processor.fallToDebug");
23.               //$FALL-THROUGH$
24.             case INFO:
25.               getLog().info(message);
26.               break;
27.             case DEBUG:
28.               getLog().debug(message);
29.           }
30.         }
31.         // 400 - Bad Request
32.         response.setStatus(400);
33.         setErrorState(ErrorState.CLOSE_CLEAN, t);
34.         getAdapter().log(request, response, 0);
35.       }

复制代码

  错误日志的输出，是配置在LocalStrings.properties中的，相关的两个属性：

1. http11processor.fallToDebug=\n Note\: further occurrences of HTTP header parsing errors will be logged at DEBUG level.
2. http11processor.header.parse=Error parsing HTTP request header

复制代码

  找到对应的 getInputBuffer().parseHeaders()

1. public boolean parseHeaders()
2.     throws IOException {
3.     if (!parsingHeader) {
4.       throw new IllegalStateException(
5.           sm.getString("iib.parseheaders.ise.error"));
6.     }
8.     HeaderParseStatus status = HeaderParseStatus.HAVE_MORE_HEADERS;
10.     do {
11.       status = parseHeader();
12.       // Checking that
13.       // (1) Headers plus request line size does not exceed its limit
14.       // (2) There are enough bytes to avoid expanding the buffer when
15.       // reading body
16.       // Technically, (2) is technical limitation, (1) is logical
17.       // limitation to enforce the meaning of headerBufferSize
18.       // From the way how buf is allocated and how blank lines are being
19.       // read, it should be enough to check (1) only.
20.       if (pos > headerBufferSize
21.           || buf.length - pos < socketReadBufferSize) {
22.         throw new IllegalArgumentException(
23.             sm.getString("iib.requestheadertoolarge.error"));
24.       }
25.     } while ( status == HeaderParseStatus.HAVE_MORE_HEADERS );
26.     if (status == HeaderParseStatus.DONE) {
27.       parsingHeader = false;
28.       end = pos;
29.       return true;
30.     } else {
31.       return false;
32.     }
33.   }

复制代码

1. 可知此处涉及了两个缓冲区大小，headerBufferSize和socketReadBufferSize，如果读取时数据的长度大于这两个值，就会报iib.requestheadertoolarge.error即Request header is too large，在网上搜索时，有的是因为这个设置导致的400，解决方法就是修改Tomcat的server.xml，
2. 在<Connector port="8080" protocol="HTTP/1.1"
3. connectionTimeout="20000"    redirectPort="8443" />的配置中增加maxHttpHeaderSize的配置

复制代码

  在org.apache.coyote.http11.AbstractHttp11Protocol类中定义了其默认值：

1. /**
2. Maximum size of the HTTP message header.  */
3. private int maxHttpHeaderSize = 8 * 1024;
4. /**
5. Maximum size of the post which will be saved when processing certain  requests, such as a POST. */
6. private int maxSavePostSize = 4 * 1024;
7. /**
8. * Specifies a different (usually  longer) connection timeout during data  upload. */
9. private int connectionUploadTimeout = 300000;
10. /**
11. Maximum size of trailing headers in bytes */
12. private int maxTrailerSize = 8192;
13. /**
14. Maximum size of extension information in chunked encoding */
15. private int maxExtensionSize = 8192;
16. /**Maximum amount of request body to swallow.*/
17. private int maxSwallowSize = 2 * 1024 * 1024;

复制代码

  其他参数设置介绍： http://tomcat.apache.org/tomcat-8.0-doc/config/ajp.html