架构师训练营第七周作业

import java.io.IOException;import java.net.HttpURLConnection;import java.net.URL;import java.util.*;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;
public class WebRunner {
    public static void main(String[] args){        String url="http://www.jd.com";        Long totalCount=100L;        Long concurrent=10L;        WebRunner webRunner=new WebRunner();        webRunner.test(url,totalCount,concurrent);    }
    /**     *      * @param url url     * @param totalCount 总次数     * @param concurrent 并发数     */    public void test(String url,Long totalCount,Long concurrent){        long perTotalCount=totalCount/concurrent;        long lastTotalCount=perTotalCount+totalCount%concurrent;        List<FutureTask<List<Long>>> runnerHandlerList=new ArrayList<>();        List<Thread> runnerThreadList=new ArrayList<>();        List<Long> costTimeList=new ArrayList<>();        for(long i=0;i<concurrent;i++){            long runnerTotalCount=i!=totalCount-1?perTotalCount:lastTotalCount;            FutureTask<List<Long>> futureTask = new FutureTask<>(new RunnerHandler(url,runnerTotalCount));            Thread thread = new Thread(futureTask);            runnerHandlerList.add(futureTask);            runnerThreadList.add(thread);        }        runnerThreadList.parallelStream().forEach(Thread::start);        runnerHandlerList.forEach(it->{            try {                List<Long> longs=it.get();                costTimeList.addAll(longs);            } catch (InterruptedException e) {                e.printStackTrace();            } catch (ExecutionException e) {                e.printStackTrace();            }        });        //avg        double avg = costTimeList.stream().mapToLong((x) -> x).average().getAsDouble();        System.out.println("平均响应时间:" + avg+"毫秒");
        Collections.sort(costTimeList);
        Double indexD=(costTimeList.size()*0.95);        int index=indexD.intValue()-1;        System.out.println("95%响应时间:"+costTimeList.get(index)+"毫秒");
//        costTimeList.forEach(it->{//            System.out.println(it);//        });    }}class RunnerHandler implements Callable<List<Long>>{    private String url;    private Long totalCount;    public RunnerHandler(String url, Long totalCount){        this.url=url;        this.totalCount=totalCount;    }
    @Override    public List<Long> call() throws Exception {        List<Long> responseTimeList=new ArrayList<>();        for(long i=0;i<totalCount;i++){            long beginTime=System.currentTimeMillis();            doConnect(this.url);            long endTime=System.currentTimeMillis();            long costTime=endTime-beginTime;            responseTimeList.add(costTime);        }        return responseTimeList;    }    private void doConnect(String httpUrl){        try {            URL url = new URL(httpUrl);            HttpURLConnection  connection = (HttpURLConnection) url.openConnection();            //设置请求方式            connection.setRequestMethod("GET");            //设置连接超时时间            connection.setReadTimeout(15000);            //开始连接            connection.connect();        } catch (IOException e) {            e.printStackTrace();        }    }}

平均响应时间:15.51毫秒95%响应时间:51毫秒