架构师训练营第七周课后作业

public class LoadTestTool {	private ExecutorService executorService;		private AtomicInteger count = new AtomicInteger(0);		private int threadNum = 0;	private String url;	private int totalReqNum = 0;		public LoadTestTool(String url, int threadNum, int totalReqNum) {		init(url,threadNum,totalReqNum);	}		private void init(String url, int threadNum, int totalReqNumm) {		this.threadNum = threadNum;		this.url = url;		this.totalReqNum = totalReqNumm;		ThreadFactory threadFactory = new ThreadFactoryBuilder()		        .setNameFormat("web-load-%d").build();				this.executorService = new ThreadPoolExecutor(threadNum, threadNum,		        0L, TimeUnit.MILLISECONDS,		        new LinkedBlockingQueue<Runnable>(1024), threadFactory, new ThreadPoolExecutor.AbortPolicy());;	}		public void runLoadTest() throws IOException {		for(int i = 0;i < this.totalReqNum ;i++) {			this.executorService.execute(new WorkRunnable(this.url));		}	}		public void shutDown() {		this.executorService.shutdown();	}		public boolean isFinish() {		return this.executorService.isTerminated();	}}

public class WorkRunnable implements Runnable{
	private HttpURLConnection conn;	private String path;		public WorkRunnable(String path) throws IOException {		this.path = path;		URL url = new URL(this.path);        conn = (HttpURLConnection) url.openConnection();        conn.setRequestMethod("GET");	}		@Override	public void run() {		Long start = System.currentTimeMillis();		try {			conn.connect();		} catch (IOException e) {			e.printStackTrace();		}		InputStream is = null;	    BufferedReader reader = null;		int resCode = 0;		try {			resCode = conn.getResponseCode();		} catch (IOException e) {			e.printStackTrace();		}        if (resCode == HttpURLConnection.HTTP_OK) {        	 try {				is = conn.getInputStream();			} catch (IOException e) {				e.printStackTrace();			}             try {				reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));			} catch (UnsupportedEncodingException e) {				e.printStackTrace();			}             StringBuffer sb = new StringBuffer();             String strRead = null;             try {				while ((strRead = reader.readLine()) != null) {				     sb.append(strRead);				 }			} catch (IOException e) {				e.printStackTrace();			}        }else {        	System.out.println("请求失败");        }				Long end = System.currentTimeMillis();		GlobalStatistic.time.add(end - start);	}}

public class GlobalStatistic {	public static CopyOnWriteArrayList<Long> time = new CopyOnWriteArrayList<>();}

int threadNum = 10;		int totalRequest = 100;				LoadTestTool tool = new LoadTestTool("http://www.baidu.com",threadNum,totalRequest);		tool.runLoadTest();		tool.shutDown();		while(!tool.isFinish()) {			Thread.sleep(1);		}		Double avg = GlobalStatistic.time.stream().collect(Collectors.averagingLong(i -> i));		System.out.println("响应平均值:"+avg+"ms");				int percent95 = (totalRequest * 95 / 100);				long e95 = GlobalStatistic.time.stream().sorted().collect(Collectors.toList()).get(percent95);		System.out.println("95%响应时间:"+e95+"ms");