spring-boot-protocol icon indicating copy to clipboard operation
spring-boot-protocol copied to clipboard

The request could not be processed normally due to ignoring httpcontent

Open markbanyang opened this issue 4 years ago • 13 comments
trafficstars

在NettyMessageToServletRunnable里面先处理HttpRequest,在处理HttpContent。当msg是DefaultFullHttpRequest时会被忽略掉HttpConetnt导致不能正常处理请求

markbanyang avatar Nov 25 '20 03:11 markbanyang

我复现下, 还没有到过有DefaultFullHttpRequest的情况, 因为我把HttpObjectAggregator去掉了, 应该是没有Full请求的情况了.

wangzihaogithub avatar Nov 25 '20 03:11 wangzihaogithub

提交解决了. 不过我没有复现出来啊, 你是如何发现的.

https://github.com/wangzihaogithub/spring-boot-protocol/commit/544ede627b7552db7ac06cfa7722490a6055c433

wangzihaogithub avatar Nov 25 '20 08:11 wangzihaogithub

我看了下你修复合包的那个问题的提交,感觉这里有点问题。然后在HttpServletProtocol的ChannelPipeline最前面加了一个ChannelInboundHandlerAdapter,在里面构造DefaultFullHttpRequest向下传递,可以复现这个问题。

markbanyang avatar Nov 25 '20 09:11 markbanyang

FullHttpRequest只有 HttpObjectAggregator这个类, 和http请求行解析失败时, 会收到. 但HttpObjectAggregator这个类的聚合不支持long类型, 所以去掉了.

不过为了代码健壮, 刚才也都加上了. 现在2.0.17这个版本还是没问题的.

wangzihaogithub avatar Nov 25 '20 09:11 wangzihaogithub

2.0.17不支持apache common-fileupload了么。

  public ResponseEntity<String> upload(HttpServletRequest request, HttpServletResponse response)
        throws IOException, FileUploadException {
    boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    if (isMultipart) {
        ServletFileUpload upload = new ServletFileUpload();

        Map<String, String> params = new HashMap<>();
        InputStream is = null;
        FileItemIterator iter = upload.getItemIterator(request);
        while (iter.hasNext()) {
            FileItemStream item = iter.next();
            if (!item.isFormField()) {
                is = item.openStream();
                try {
                      .....
                } catch (Exception e) {
                   e.printStackTrace();
                } finally {
                    if (null != is) {
                        is.close();
                    }
                }
            } else {
                String fieldName = item.getFieldName();
                String value = Streams.asString(item.openStream());
                params.put(fieldName, value);
            }
        }
    }
    return new ResponseEntity<String>("success", HttpStatus.OK);
}

markbanyang avatar Nov 26 '20 10:11 markbanyang

应该是不影响的啊, 我试试咋回事

wangzihaogithub avatar Nov 26 '20 10:11 wangzihaogithub

tomcat也不支持, 这里实现的逻辑和tomcat是一样的. 你可以这样保存文件

try { Part part = request.getPart("myFile"); InputStream inputStream = part.getInputStream(); IOUtil.writeFile(inputStream,"D://test//upload","myfile.txt",false); } catch (Exception e) { e.printStackTrace(); }

wangzihaogithub avatar Nov 26 '20 10:11 wangzihaogithub

解析的逻辑不需要你主动用common-fileupload写, servlet已经实现了.

wangzihaogithub avatar Nov 26 '20 10:11 wangzihaogithub

tomcat 是可以的,另外2.0.15这个用法也是可以的,2.0.17不行。

markbanyang avatar Nov 26 '20 11:11 markbanyang

好吧 那我加下. 然后发个版. 估计这两天就能好. 好了就告诉你

wangzihaogithub avatar Nov 26 '20 12:11 wangzihaogithub

好的

markbanyang avatar Nov 26 '20 12:11 markbanyang

这次提交解决了这个问题, 已经发版在2.0.18, 过两天就能在maven中央仓库拉包了.

https://github.com/wangzihaogithub/spring-boot-protocol/commit/acf2eefb2942876319579e19b7b9f4f39f206501

wangzihaogithub avatar Nov 27 '20 02:11 wangzihaogithub

多多提意见啊, 感谢感谢

wangzihaogithub avatar Nov 27 '20 02:11 wangzihaogithub