http請求類庫（okHttpClient、restTemplate、flux-webclient）

public final class HttpTest {

    public static OkHttpClient httpClient = new OkHttpClient.Builder()
            .readTimeout(2, TimeUnit.SECONDS)
            .writeTimeout(2, TimeUnit.SECONDS)
            .connectTimeout(3, TimeUnit.SECONDS)
            .build();
    private Map<String, Object> map = new ConcurrentHashMap<String, Object>();
    private static String URL_FACTOR = FileUtil.readString(new File("D:\\WorkSpace\\url.txt"), "utf-8");
    private final static String AUTH_VALULE = FileUtil.readString(new File("D:\\WorkSpace\\auth.txt"), "utf-8");
    private final static List<String> IMEIS = Files.linesOf(new File("D:\\WorkSpace\\param.txt"), "utf-8");

    /**
     * 先指定工做目錄，否則會超時告警
     * @throws IOException
     */
    @Test
    public void test01() throws IOException {
        AtomicInteger atomicInteger = new AtomicInteger();
        long stratTime = System.currentTimeMillis();
        for(String imei : this.IMEIS){
//            getResponseDataByWebClient(imei, this.map);
//            getResponseDate(imei, this.map);
            getResponseByRestTemplate(imei, this.map);
            atomicInteger.getAndIncrement();
            if (atomicInteger.get() == 20){
                break;
            }
        }
        System.out.println("查詢耗時：" + (System.currentTimeMillis() - stratTime));
        System.out.println("查得量: " + map.size());
    }

    // ========= okhttpclient test
    
    public void getResponseDate(String imei, Map<String, Object> map) throws IOException {
        String url = URL_FACTOR.replace("{imei}", URLEncoder.encode(imei, "UTF-8"));
        Request request = new Request.Builder()
                .url(url)
                .addHeader("Authorization", AUTH_VALULE)
                .get()
                .build();
        Response response = httpClient.newCall(request).execute();
        String string = response.body().string();
        Map<String, Object> data = JSON.parseObject(string).getObject("data", Map.class);
        if(data != null){
            map.putAll(data);
        }
    }

    // ========= webclient test
    private static WebClient webClient = WebClient.builder().baseUrl("http://host:port").build();
    private static String requestPath = "uri{param}";

    public void getResponseDataByWebClient(String imei, Map<String, Object> map) throws UnsupportedEncodingException {
        String uri = requestPath.replace("{param}", URLEncoder.encode(imei, "UTF-8"));
        String response = webClient
                      .get()
                      .uri(uri)
                      .header(HttpHeaders.AUTHORIZATION, AUTH_VALULE)
//                      .exchange()
//                      .block(Duration.ofSeconds(3)).bodyToFlux(String.class).blockFirst();
//                      .flatMap(clientResponse -> clientResponse.bodyToMono(String.class)).block();
                       .retrieve().bodyToMono(String.class).block();
//
        Map<String, Object> data = JSON.parseObject(response).getObject("data", Map.class);
        if (data != null){
            map.putAll(data);
        }
    }

   // ========= restTemplate test
   private static RestTemplate restTemplate = new RestTemplate();

   public void getResponseByRestTemplate(String imei, Map<String, Object> map) throws UnsupportedEncodingException {
       String url = URL_FACTOR.replace("{param}", URLEncoder.encode(imei, "UTF-8"));
       HttpHeaders httpHeaders = new HttpHeaders();
       httpHeaders.add(HttpHeaders.AUTHORIZATION, AUTH_VALULE);
       httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8);

       HttpEntity<String> requestEntity = new HttpEntity<>(null, httpHeaders);
       String resp = restTemplate.exchange(url, HttpMethod.GET, requestEntity, String.class).getBody();
       Map<String, Object> data = JSON.parseObject(resp).getObject("data", Map.class);
       if (data != null){
            map.putAll(data);
       }
   }

    @Test
    public void test03() throws IOException {
        String url = "www.baidu.com";
        Request request = new Request.Builder()
                .url(url)
                .get()
                .build();
        Response response = httpClient.newCall(request).execute();
        String data = response.body().string();
        System.out.println(data);
    }


    static class FileUtil{

        public static String readString(File file, String charsetName){
            InputStream inputStream = null;
            InputStreamReader inputStreamReader = null;
            BufferedReader bufferedReader = null;
            try {
                inputStream = new FileInputStream(file);
                inputStreamReader = new InputStreamReader(inputStream);
                bufferedReader = new BufferedReader(inputStreamReader);
                return bufferedReader.readLine();
            } catch (Exception e) {
                e.printStackTrace();
            }finally {
                try {
                    bufferedReader.close();
                    inputStreamReader.close();
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            return null;
        }
    }
}

總結： 

一、單線程下效率比較  okhttpclient  > restTemplate（不包含異步） > flux-webclient

二、異步比較未測試    預計  flux-webclient > okhttpclient > restTemplate (不包含異步)