public static void main(String[] args) throws RemotingException, InterruptedException {
        System.setProperty("bolt.netty.buffer.high.watermark", String.valueOf(64 * 1024 * 1024));
        System.setProperty("bolt.netty.buffer.low.watermark", String.valueOf(32 * 1024 * 1024));
        RpcClient rpcClient = new RpcClient();
        rpcClient.option(BoltClientOption.NETTY_FLUSH_CONSOLIDATION, true);
        rpcClient.startup();

        int processors = Runtime.getRuntime().availableProcessors();
        callWithFuture(rpcClient, "127.0.0.1:18090", processors << 4);
    }
body=4096, CODEC_FLUSH_CONSOLIDATION=turnOff
Request count: 10240000, time: 347 second, qps: 29510

body=4096, CODEC_FLUSH_CONSOLIDATION=turnOn
Request count: 10240000, time: 311 second, qps: 32926

-------------------------------------------------------

body=1024, CODEC_FLUSH_CONSOLIDATION=turnOff
Request count: 10240000, time: 206 second, qps: 49708

body=1024, CODEC_FLUSH_CONSOLIDATION=turnOn
Request count: 10240000, time: 148 second, qps: 69189

-------------------------------------------------------

body=128, CODEC_FLUSH_CONSOLIDATION=turnOff
Request count: 10240000, time: 148 second, qps: 69189

body=128, CODEC_FLUSH_CONSOLIDATION=turnOn
Request count: 10240000, time: 69 second, qps: 148405
src/test/java/com/alipay/remoting/benchmark/BenchmarkClient.java