第 7 周作业

public class WebTestResult {
	private int avgResponseTime;
	private int tp95ResponseTime;

	public WebTestResult(int avgResponseTime, int tp95ResponseTime) {
		super();
		this.avgResponseTime = avgResponseTime;
		this.tp95ResponseTime = tp95ResponseTime;
	}

	public int getAvgResponseTime() {
		return avgResponseTime;
	}

	public int getTp95ResponseTime() {
		return tp95ResponseTime;
	}

}

public class HttpUtils {

	public static String doGet(String url) throws ParseException, IOException {
		CloseableHttpClient httpClient = HttpClients.createDefault();
		HttpGet httpget = new HttpGet(url);

		CloseableHttpResponse response = httpClient.execute(httpget);

		// String content = EntityUtils.toString(response.getEntity(), "UTF-8");
		return "";
	}
}


public class WebTester {
	public WebTestResult test(String url, int requestTimes, int concurrentNum) {

		List<Integer> responses = new Vector<>();

		Thread[] threads = new Thread[concurrentNum];
		CountDownLatch latch = new CountDownLatch(threads.length);

		for (int i = 0; i < threads.length; i++) {
			threads[i] = new Thread(new Runnable() {
				@Override
				public void run() {
					for (int j = 0; j < requestTimes; j++) {
						try {
							Long beginTime = System.currentTimeMillis();
							HttpUtils.doGet(url);
							long endTime = System.currentTimeMillis();
							responses.add((int) (endTime - beginTime));

						} catch (Exception e) {
							System.out.println("got error " + e.getMessage() + ", finished " + j + " requests");
							break;
						}
					}

					latch.countDown();
				}
			});
		}

		for (Thread t : threads) {
			t.start();
		}

		try {
			latch.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

		int avgResponseTime = (int) responses.stream().mapToInt(res -> res.intValue()).average().getAsDouble();
		Collections.sort(responses);
		int tp95Position = requestTimes * concurrentNum * 95 / 100;
		int tp95ResponseTime = responses.get(tp95Position - 1);

		return new WebTestResult(avgResponseTime, tp95ResponseTime);

	}
}

public class Main {

	public static void main(String[] args) {
		
		String url = "http://www.baidu.com";
		int requestTimes = 1, concurrentNum = 100;
		WebTester webTester = new WebTester();
		WebTestResult result = webTester.test(url, requestTimes, concurrentNum);

		System.out.printf("test for %s,requestTimes:%d,concurrentNum:%d,avgResponseTime:%d,tp95ResponseTime:%d", url,
				requestTimes, concurrentNum, result.getAvgResponseTime(), result.getTp95ResponseTime());
		
		try {
			System.in.read();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}