架构师 0 期 07 周作业

public static ResponseEntity<?> httpGet(final String url,
        final Map<String, String> headerMap) {
        final RestTemplate restTemplate = buildRestTemple();
        final HttpHeaders headers = buildHeader(headerMap);
        final ResponseEntity response = restTemplate.exchange(url,
                HttpMethod.GET,
                new HttpEntity<>(headers), String.class);
        return response;
    }
    public static ResponseEntity<?> httpDelete(final String url,
            final Map<String, String> headerMap) {
        final RestTemplate restTemplate = buildRestTemple();
        final HttpHeaders headers = buildHeader(headerMap);
        final ResponseEntity response = restTemplate.exchange(url,
                HttpMethod.DELETE,
                new HttpEntity<>(headers), String.class);
        return response;
    }
    private static RestTemplate buildRestTemple() {
        final HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
        final HttpClient httpClient = HttpClientBuilder.create()
                .setRedirectStrategy(new LaxRedirectStrategy()).build();
        factory.setHttpClient(httpClient);
        final RestTemplate restTemplate = new RestTemplate();
        restTemplate.getMessageConverters().set(1,
                new StringHttpMessageConverter(StandardCharsets.UTF_8));
        restTemplate.setRequestFactory(factory);
        return restTemplate;
    }

@PostMapping("/http/test")
    public void testHttpGet(
            @RequestParam(value = "url") final String url,
            @RequestParam(value = "num") final Integer num,
            @RequestParam(value = "concurrentCount") final Integer concurrentCount) {
        final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //配置核心线程数
        executor.setCorePoolSize(concurrentCount);
        //配置最大线程数
        executor.setMaxPoolSize(concurrentCount);
        //配置队列大小
        executor.setQueueCapacity(num);
        //配置线程池中的线程的名称前缀
        executor.setThreadNamePrefix("service-async-task");
        //执行初始化
        executor.initialize();
        final ConcurrentLinkedQueue<Long> queue = new ConcurrentLinkedQueue<>();
        for (int i = 0; i < num; i++) {
            CompletableFuture<Void> result = CompletableFuture.runAsync(() -> httpGet(url, queue)
                    , executor);
            result.join();
        }
        final List<Long> timeLists = new ArrayList<Long>(queue);
        Collections.sort(timeLists);
        int index = (int) (0.95 * num);
        System.out.println("P95时间" + timeLists.get(index));
    }
    void httpGet(final String url, ConcurrentLinkedQueue<Long> timeLists) {
        final long start = System.currentTimeMillis();
        ResponseEntity<?> result = HttpUtil.httpGet(url, Maps.newHashMap());
        final long end = System.currentTimeMillis();
        timeLists.add(end - start);
    }