HttpNativeServerHandler Class — netty Architecture

Source Code

testsuite-native-image/src/main/java/io/netty/testsuite/svm/HttpNativeServerHandler.java lines 35–76

public class HttpNativeServerHandler extends SimpleChannelInboundHandler<HttpObject> {
    private static final byte[] CONTENT = { 'H', 'e', 'l', 'l', 'o', ' ', 'N', 'a', 't', 'i', 'v', 'e' };

    private static final AsciiString KEEP_ALIVE = AsciiString.cached("keep-alive");

    private final CompletableFuture<Void> httpRequestFuture;

    public HttpNativeServerHandler(CompletableFuture<Void> httpRequestFuture) {
        this.httpRequestFuture = httpRequestFuture;
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush();
    }

    @Override
    public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) {
        if (msg instanceof HttpRequest) {
            HttpRequest req = (HttpRequest) msg;

            boolean keepAlive = HttpUtil.isKeepAlive(req);
            FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(CONTENT));
            response.headers().set(CONTENT_TYPE, "text/plain");
            response.headers().setInt(CONTENT_LENGTH, response.content().readableBytes());
            httpRequestFuture.complete(null);
            if (!keepAlive) {
                ctx.write(response).addListener(ChannelFutureListener.CLOSE);
            } else {
                response.headers().set(CONNECTION, KEEP_ALIVE);
                ctx.write(response);
            }
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        httpRequestFuture.completeExceptionally(cause);
        cause.printStackTrace();
        ctx.close();
    }
}