import io.undertow.util.StringReadChannelListener; //导入依赖的package包/类
@Override
public void handleRequest(final HttpServerExchange exchange) throws Exception {
    if(!exchange.isRequestComplete()) {
        exchange.dispatch(SameThreadExecutor.INSTANCE, new Runnable() {
            @Override
            public void run() {
                new StringReadChannelListener(exchange.getConnection().getBufferPool()) {
                    @Override
                    protected void stringDone(String string) {
                        exchange.putAttachment(DATA, string);
                        Connectors.executeRootHandler(next, exchange);
                    }

                    @Override
                    protected void error(IOException e) {
                        UndertowLogger.REQUEST_IO_LOGGER.ioException(e);
                        exchange.setResponseCode(500);
                        exchange.endExchange();
                    }
                }.setup(exchange.getRequestChannel());
            }
        });

    } else {
        next.handleRequest(exchange);
    }


}
 

import io.undertow.util.StringReadChannelListener; //导入依赖的package包/类
private void upgradeConnection(ClientExchange result) throws IOException {
    if (result.getResponse().getResponseCode() == 101) {
        // flush response
        new StringReadChannelListener(bufferPool) {
            @Override
            protected void stringDone(String string) {
            }

            @Override
            protected void error(IOException e) {
            }
        }.setup(result.getResponseChannel());

        // Create the upgraded SPDY connection
        ByteBufferPool heapBufferPool =
            new XnioByteBufferPool(new ByteBufferSlicePool(BufferAllocator.BYTE_BUFFER_ALLOCATOR, 8196, 8196));
        SpdyChannel spdyChannel =
            new SpdyChannelWithoutFlowControl(connection.performUpgrade(), bufferPool, null, heapBufferPool, true,
                OptionMap.EMPTY);
        Integer idleTimeout = DEFAULT_OPTIONS.get(UndertowOptions.IDLE_TIMEOUT);
        if (idleTimeout != null && idleTimeout > 0) {
            spdyChannel.setIdleTimeout(idleTimeout);
        }
        connection = new SpdyClientConnection(spdyChannel, null);
    } else {
        throw new IOException("Failed to upgrade connection");
    }
}
 

import io.undertow.util.StringReadChannelListener; //导入依赖的package包/类
@Override
public void completed(ClientExchange clientExchange) {
    StringReadChannelListener readChannelListener;
    readChannelListener = new ResponseBodyListener(serverExchange, connection, clientExchange);
    readChannelListener.setup(clientExchange.getResponseChannel());
}