如何在Handler中正确读取POST请求体？

我现在使用的代码是：

    Pooled<ByteBuffer> pooledByteBuffer = exchange.getConnection().getBufferPool().allocate();
    ByteBuffer byteBuffer = pooledByteBuffer.getResource();

    int limit = byteBuffer.limit();

    byteBuffer.clear();

    exchange.getRequestChannel().read(byteBuffer);
    int pos = byteBuffer.position();
    byteBuffer.rewind();
    byte[] bytes = new byte[pos];
    byteBuffer.get(bytes);

    String requestBody = new String(bytes, Charset.forName("UTF-8") );

    byteBuffer.clear();
    pooledByteBuffer.free();

它似乎工作正常，但我不确定在将其返回到池之前clear() ByteBuffer的必要性。 我甚至不确定使用exchange.getConnection().getBufferPool().allocate(); 。 文档中没有太多关于它的内容。

---

读取请求主体的更简单的方法是分派给工作线程，这使得HttpExchange#getInputStream()可用。

有两种方法：使用BlockingHandler或文档中显示的分派模式。 这里有一个使用BlockingHandler的例子：

new BlockingHandler(myHandler)

BlockingHandler基本上为你做派遣。

---

@atok，我用你的方法一段时间，但有时我得到一个空的身体，当流在读取调用之前关闭。 这就像魅力一样：

BufferedReader reader = null;
StringBuilder builder = new StringBuilder( );

try {
    exchange.startBlocking( );
    reader = new BufferedReader( new InputStreamReader( exchange.getInputStream( ) ) );

    String line;
    while( ( line = reader.readLine( ) ) != null ) {
        builder.append( line );
    }
} catch( IOException e ) {
    e.printStackTrace( );
} finally {
    if( reader != null ) {
        try {
            reader.close( );
        } catch( IOException e ) {
            e.printStackTrace( );
        }
    }
}

String body = builder.toString( );

链接地址: http://www.djcxy.com/p/23073.html

上一篇: How to properly read POST request body in a Handler?

下一篇: Preventing observable sharing for certain subtrees in Haskell