0

运行 xml-rcp 服务器和客户端。试图将请求记录到服务器。但得到文件过早结束错误。谁能看到我做错了什么？

 public void doPost(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException

 ServletInputStream sis = req.getInputStream();
 int len = req.getContentLength();
 byte[] bytes = new byte[len]; 

 int offset = 0;  
 int numRead = 0;  
 while ((offset < bytes.length) && (numRead=sis.read(bytes, offset, bytes.length-offset)) >= 0) {  
       offset += numRead;  
   }  

   if (offset < bytes.length) {  
       throw new IOException("Could not complete reading request body");  
   }  

   sis.close();  

   FileOutputStream f = new FileOutputStream(new File("C:\\Users\\test\\file.log"), true);
   f.write(bytes);  
   f.flush();
   f.close();

   super.doPost(req, res);
 }

[致命错误]：1:1：文件过早结束。

org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:609) 处的句柄(AsyncHttpConnection.java:77) org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:45 ) 在 org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:599) 在 org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:534) 在 java.lang.Thread .run(Thread.java:722) 引起：org.xml.sax.SAXParseException；行号：1；列号：1；com.sun.org.apache.xerces.internal.parsers.AbstractSAXParser.parse(AbstractSAXParser.java:1236) 处的文件过早结束 ... 26 更多 45）在 org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:599) 在 org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:534) 在 java.lang。 Thread.run(Thread.java:722) 引起：org.xml.sax.SAXParseException; 行号：1；列号：1；com.sun.org.apache.xerces.internal.parsers.AbstractSAXParser.parse(AbstractSAXParser.java:1236) 处的文件过早结束 ... 26 更多 45）在 org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:599) 在 org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:534) 在 java.lang。 Thread.run(Thread.java:722) 引起：org.xml.sax.SAXParseException；行号：1；列号：1；com.sun.org.apache.xerces.internal.parsers.AbstractSAXParser.parse(AbstractSAXParser.java:1236) 处的文件过早结束 ... 26 更多

解决方案：

 import javax.servlet.ServletException;
 import javax.servlet.ServletInputStream;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletRequestWrapper;
 import javax.servlet.http.HttpServletResponse;

 public void doPost(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException
 {
 CustomHttpServletRequestWrapper wrapper = new CustomHttpServletRequestWrapper((HttpServletRequest) req);

 ServletInputStream sis = wrapper.getInputStream();
 String StringFromInputStream = IOUtils.toString(sis, "UTF-8");
 LOG.info( "request:");
 LOG.info( StringFromInputStream );
 super.doPost(wrapper, res);
 }


 public class CustomHttpServletRequestWrapper extends HttpServletRequestWrapper
 {

  private final String body;
  private final Logger LOG = LoggerFactory.getLogger( CustomHttpServletRequestWrapper.class );

  public CustomHttpServletRequestWrapper( final HttpServletRequest request )
  {
     super( request );

     final StringBuilder stringBuilder = new StringBuilder();
     BufferedReader bufferedReader = null;

     try
     {
        final InputStream inputStream = request.getInputStream();

        if (inputStream != null)
        {
           bufferedReader = new BufferedReader( new InputStreamReader( inputStream ) );

           final char[] charBuffer = new char[128];
           int bytesRead = -1;

           while (( bytesRead = bufferedReader.read( charBuffer ) ) > 0)
           {
              stringBuilder.append( charBuffer, 0, bytesRead );
           }
        }
        else
        {
           stringBuilder.append( "" );
        }
     }
     catch (final IOException ex)
     {
        LOG.error( "Error reading the request body..." );
     }
     finally
     {
        if (bufferedReader != null)
        {
           try
           {
              bufferedReader.close();
           }
           catch (final IOException ex)
           {
              LOG.error( "Error closing bufferedReader..." );
           }
        }
     }

     body = stringBuilder.toString();
     LOG.info( "body:" );
     LOG.info( body );
  }

  @Override
  public ServletInputStream getInputStream() throws IOException
  {
     final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream( body.getBytes() );

     final ServletInputStream inputStream = new ServletInputStream()
     {
        @Override
        public int read() throws IOException
        {
           return byteArrayInputStream.read();
        }
     };

     return inputStream;
  }

}

4

1 回答 1

2

您已经使用了请求发送的所有数据，因此该super.doPost(...)方法没有任何剩余！

您可以改为将 a 传递HttpServletRequestWrapper给super.doPost(...). 它应该包装原始请求，但返回InputStream由您已经在此方法中读取的字节数组支持的不同请求。另请注意，还需要包装可从请求 ( HttpServletRequest#getReader()) 中获取的阅读器。

另请参阅How to log response content from a java web server，在那里您可以找到有关日志记录对面的完整代码示例。我认为它可以很容易地适应你的需要。

于 2013-11-12T12:03:04.920 回答