运行 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;
}
}