架构师训练营 week7 作业

package cn.geekshell.utils;
import com.sun.javafx.binding.StringFormatter;
import org.apache.hc.client5.http.fluent.Request;
import org.apache.hc.core5.http.HttpResponse;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.*;
public class PerformanceTestUtil {
    public static String startTest(String url,Integer requestCount,Integer concurrentCount) throws InterruptedException {
        List<Long> responseTimeList = new ArrayList<Long>(requestCount);
        ExecutorService executorService = Executors.newFixedThreadPool(concurrentCount);
        List<Callable<String>> tasks = new ArrayList<>(concurrentCount);
        for (int i = 0; i < requestCount; i = i+concurrentCount  ){
            int finalI = i;
            for(int j = 0; j < concurrentCount; j++){
                int finalJ = j;
                tasks.add(() -> {
                    long start = System.currentTimeMillis();
                    try {
                        HttpResponse response = Request.get(url).execute().returnResponse();
                        long end = System.currentTimeMillis();
                        responseTimeList.add(end - start);
                        if (response.getCode() == 200) {
                            return "响应成功:" + finalI + finalJ;
                        } else {
                            return "响应失败:" + finalI + finalJ;
                        }
                    } catch (Exception e) {
                        long end = System.currentTimeMillis();
                        responseTimeList.add(end - start);
                        e.printStackTrace();
                        return "响应失败:" + finalI + finalJ;
                    }
                });
            }
            executorService.invokeAll(tasks).stream()
                    .map(future -> {
                        try {
                            return future.get();
                        }
                        catch (Exception e) {
                            throw new IllegalStateException(e);
                        }
                    })
                    .forEach(System.out::println);
            tasks.clear();
        }
        executorService.shutdown();
        try {
            executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
        } catch (InterruptedException e) {
        }
        return String.format("请求网址：%s, 请求总数：%d, 请求并发数:%d，平均响应时间: %.2f，95%%响应时间 ：%.2f",
                url,(int)requestCount,(int)concurrentCount,average(responseTimeList),percentileResponseTime(responseTimeList,0.95));
    }
    private static double percentileResponseTime(List<Long> list,double p){
        int size = list.size();
        Collections.sort(list);
        double px =  p*(size-1);
        int i = (int)java.lang.Math.floor(px);
        double g = px - i;
        if(g==0){
            return list.get(0);
        }else{
            return (1 - g) * list.get(i) + g * list.get(i+1);
        }
    }
    private static double average(List<Long> responseTime){
        if (responseTime != null){
            double total = responseTime.stream().mapToDouble(time -> time).sum();
            return total / responseTime.size();
        }
        return 0;
    }
    public static void main(String[] args) throws InterruptedException {
        String result = PerformanceTestUtil.startTest("http://www.baidu.com", 100, 10);
        System.out.println(result);
    }
}

输出：
请求网址：http://www.baidu.com, 请求总数：100, 请求并发数:10，平均响应时间: 117.91，95%响应时间 ：382.00