HttpPostDecoderBenchmark Class — netty Architecture

Source Code

microbench/src/main/java/io/netty/handler/codec/http/HttpPostDecoderBenchmark.java lines 39–85

@Threads(1)
@Warmup(iterations = 3)
@Measurement(iterations = 3)
@OutputTimeUnit(TimeUnit.MILLISECONDS)
@State(Scope.Benchmark)
public class HttpPostDecoderBenchmark extends AbstractMicrobenchmark {
    @Param({ "false", "true" })
    public boolean direct;

    private ByteBuf buf;
    private HttpRequest request;

    @Setup()
    public void setUp() {
        request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, "/post");
        request.headers().add(HttpHeaderNames.CONTENT_TYPE, "application/x-www-form-urlencoded");
        buf = direct ? Unpooled.directBuffer() : Unpooled.buffer();
        for (int i = 0; i < 100; i++) {
            if (i != 0) {
                buf.writeByte('&');
            }
            ByteBufUtil.writeAscii(buf, "form-field-" + i);
            buf.writeByte('=');

            ByteBufUtil.writeAscii(buf, randomString());
        }
    }

    private static CharSequence randomString() {
        Random rng = ThreadLocalRandom.current();
        int len = 4 + rng.nextInt(110);
        StringBuilder sb = new StringBuilder(len);
        for (int i = 0; i < len; i++) {
            String chars = "_-0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJLKMNOPQRSTUVWXYZ";
            sb.append(chars.charAt(rng.nextInt(chars.length())));
        }
        return sb;
    }

    @Benchmark
    public List<InterfaceHttpData> decode() {
        HttpPostRequestDecoder decoder = new HttpPostRequestDecoder(request);
        DefaultLastHttpContent content = new DefaultLastHttpContent(buf.duplicate());
        decoder.offer(content);
        return decoder.getBodyHttpDatas();
    }
}