@Override
                public void run() {
                    for (int i = 0; i < t; i++) {
                        try {
                            RpcResponseFuture f = rpcClient.invokeWithFuture(address,
                                new Request<byte[]>(BYTES), 5000);
                            futures.add(f);
                            if (futures.size() == futureSize) {
                                int fSize = futures.size();
                                for (int j = 0; j < fSize; j++) {
                                    try {
                                        futures.get(j).get();
                                    } catch (Throwable t) {
                                        t.printStackTrace();
                                    }
                                }
                                futures.clear();
                            }
                            if (count.getAndIncrement() % 10000 == 0) {
                                System.out.println("count=" + count.get());
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                    if (!futures.isEmpty()) {
                        int fSize = futures.size();
                        for (int j = 0; j < fSize; j++) {
                            try {
                                futures.get(j).get();
                            } catch (Throwable t) {
                                t.printStackTrace();
                            }
                        }
                        futures.clear();
                    }
                    latch.countDown();
                }
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