架构师训练营 -week07- 作业

import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
public class HttpStressTest {
  public static Map<String, Long> hashMap = new ConcurrentHashMap<>();
  public static void main(String[] args) {
    long start = System.currentTimeMillis();
    ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
    for (int i = 0; i < 100; i++) {
      fixedThreadPool.execute(new Runnable() {
        @Override
        public void run() {
          long startTime = System.currentTimeMillis();
          int statusCode = 0;
          try {
            //使用apache的httpclient包，向指定URL发送请求
            statusCode = doGetSimple("http://www.baidu.com");
          } catch (IOException e) {
            e.printStackTrace();
          }
          long endTime = System.currentTimeMillis();
          long useTime = endTime - startTime;
          System.out.print("useTime" + useTime + " ");
          System.out.println();
          hashMap.put(UUID.randomUUID().toString(), useTime);
        }
      });
    }
    fixedThreadPool.shutdown();
    while (true) {
      if (fixedThreadPool.isTerminated()) {
        System.out.println((System.currentTimeMillis() - start) + "ms");
        System.out.println("执行完毕");
        AtomicReference<Long> allTime = new AtomicReference<>(0l);
        List<Long> nineFiveTime = new ArrayList<>();
        AtomicInteger i = new AtomicInteger();
        hashMap.forEach((k, v) -> {
          allTime.updateAndGet(v1 -> v1 + v);
          nineFiveTime.add(v);
        });
        nineFiveTime.sort(Comparator.comparingLong(Long::longValue));
        System.out.println("平均响应时间：" + allTime.get() / 100 + "ms");
        System.out.println("95%响应时间：" + nineFiveTime.get(95) + "ms");
        break;
      }
    }
  }
  public static int doGetSimple(String url) throws IOException {
    CloseableHttpClient httpClient = null;
    CloseableHttpResponse response = null;
    int result = 0;
    // 通过址默认配置创建一个httpClient实例
    httpClient = HttpClients.createDefault();
    // 创建httpGet远程连接实例
    HttpGet httpGet = new HttpGet(url);
    // 执行get请求得到返回对象
    response = httpClient.execute(httpGet);
    result = response.getStatusLine().getStatusCode();
    return result;
  }
}

平均响应时间：185ms
95%响应时间：1708ms