相關(guān)blog鏈接https://blog.csdn.net/ouyang111222/article/details/78884634
pom文件內(nèi)引入對應(yīng)jar文件

<dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpasyncclient</artifactId>
            <version>4.1</version>
        </dependency>

新建httpUtil類

public class HttpUtil {

    private static int socketTimeout = 1000;// 設(shè)置等待數(shù)據(jù)超時時間5秒鐘 根據(jù)業(yè)務(wù)調(diào)整

    private static int connectTimeout = 2000;// 連接超時

    private static int poolSize = 100;// 連接池最大連接數(shù)

    private static int maxPerRoute = 10;// 每個主機的并發(fā)最多10


    /**
     * 創(chuàng)建非異步的可關(guān)閉的且跳過https 驗證的 httpClient
     * @return
     */
    public static CloseableHttpClient createSSLClientDefault() {
        try {
            SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
                @Override
                public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
                    return true;
                }
            }).build();
            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext);
            return HttpClients.custom().setSSLSocketFactory(sslsf).build();
        } catch (KeyManagementException e) {
            e.printStackTrace();
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (KeyStoreException e) {
            e.printStackTrace();
        }
        return HttpClients.createDefault();
    }

    /**
     * 創(chuàng)建異步的可關(guān)閉的跳過https驗證的 httpClient對象
     * @param connManager  連接管理器  可以調(diào)用本類的getConnManager 生成
     * @return
     */
    public static CloseableHttpAsyncClient getClient(PoolingNHttpClientConnectionManager connManager) {
        if (null == connManager) {
            return null;
        }
        // 設(shè)置連接參數(shù)
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(HttpUtil.socketTimeout).setConnectTimeout(HttpUtil.connectTimeout).build();
        // 創(chuàng)建自定義的httpclient對象
        CloseableHttpAsyncClient client = HttpAsyncClients.custom().setDefaultRequestConfig(requestConfig)
                .setConnectionManager(connManager).disableCookieManagement().build();
        return client;
    }

    /**
     * 創(chuàng)建異步的可關(guān)閉的跳過https驗證的 httpClient對象(綁定本地網(wǎng)卡)
     * @param connManager
     * @param localAddress
     * @return
     * @throws
     */
    public static CloseableHttpAsyncClient getClient(PoolingNHttpClientConnectionManager connManager, String localAddress) throws UnknownHostException {
        if (null == connManager || null == localAddress) {
            return null;
        }
        String[] ipStrArr = localAddress.split("\\.");
        if(ipStrArr.length != 4){
            return null;
        }
        byte[] ip = new byte[]{ (byte)(Integer.parseInt(ipStrArr[0])), (byte) (Integer.parseInt(ipStrArr[1])), (byte) (Integer.parseInt(ipStrArr[2])), (byte) (Integer.parseInt(ipStrArr[3])) };

        // 設(shè)置連接參數(shù)
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(HttpUtil.socketTimeout).setConnectTimeout(HttpUtil.connectTimeout).setLocalAddress(InetAddress.getByAddress(ip)).build();
        // 創(chuàng)建自定義的httpclient對象
        CloseableHttpAsyncClient client = HttpAsyncClients.custom().setDefaultRequestConfig(requestConfig)
                .setConnectionManager(connManager).disableCookieManagement().build();
        return client;
    }

    /**
     * 初始化 連接管理器
     * @return
     */
    public static PoolingNHttpClientConnectionManager getConnManager() {

        try {
            // 繞過證書驗證，處理https請求
            SSLContext sslcontext = createIgnoreVerifySSL();

            // 設(shè)置協(xié)議http和https對應(yīng)的處理socket鏈接工廠的對象
            Registry<SchemeIOSessionStrategy> sessionStrategyRegistry = RegistryBuilder
                    .<SchemeIOSessionStrategy> create().register("http", NoopIOSessionStrategy.INSTANCE)
                    .register("https", new SSLIOSessionStrategy(sslcontext, new AllowAllHostnameVerifier())).build();
            // 配置io線程
            IOReactorConfig ioReactorConfig = IOReactorConfig.custom().setConnectTimeout(HttpUtil.socketTimeout).setSoTimeout(HttpUtil.connectTimeout)
                    .setRcvBufSize(8192).setSndBufSize(8192).build();

            // 設(shè)置連接池大小
            ConnectingIOReactor ioReactor = new DefaultConnectingIOReactor(ioReactorConfig);

            PoolingNHttpClientConnectionManager connManager = new PoolingNHttpClientConnectionManager(ioReactor, null,
                    sessionStrategyRegistry, null);
            connManager.setDefaultMaxPerRoute(maxPerRoute);
            connManager.setMaxTotal(poolSize);
            return connManager;
        } catch (IOReactorException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 繞過驗證
     *
     * @return
     * @throws NoSuchAlgorithmException
     * @throws KeyManagementException
     */
    public static SSLContext createIgnoreVerifySSL() {
        SSLContext sc = null;
        try {
            sc = SSLContext.getInstance("TLS");
            // 實現(xiàn)一個X509TrustManager接口，用于繞過驗證，不用修改里面的方法
            X509TrustManager trustManager = new X509TrustManager() {
                @Override
                public void checkClientTrusted(X509Certificate[] paramArrayOfX509Certificate, String paramString) {
                }

                @Override
                public void checkServerTrusted(X509Certificate[] paramArrayOfX509Certificate, String paramString) {
                }

                @Override
                public X509Certificate[] getAcceptedIssuers() {
                    return null;
                }
            };
            sc.init(null, new TrustManager[] { trustManager }, null);
        } catch (NoSuchAlgorithmException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (KeyManagementException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return sc;

    }
}

創(chuàng)建調(diào)用工廠

@Component
public class AsynHttpClientFactory {

    private static Logger logger = LoggerFactory.getLogger(AsynHttpClientFactory.class);


    private static CloseableHttpAsyncClient httpclient;
    private static PoolingNHttpClientConnectionManager connManager;
    public AsynHttpClientFactory() {
        connManager = HttpUtil.getConnManager();
        httpclient = HttpUtil.getClient(connManager);
        httpclient.start();
        logger.info("異步httpClient啟動完成");
    }

    public static CloseableHttpAsyncClient getCloseableHttpAsyncClient(){
        return httpclient;
    }
}

測試實例

 CloseableHttpAsyncClient httpClient = AsynHttpClientFactory.getCloseableHttpAsyncClient();
        final CountDownLatch latch = new CountDownLatch(urls.length);
        for(final HttpGet request: urls){

            Future<HttpResponse> future =  httpClient.execute(request,  new FutureCallback(){
                @Override
                public void completed(Object obj) {
                    final HttpResponse response = (HttpResponse)obj;
                    latch.countDown();
                    PlatformInfo platformInfo =  map.get(request.getURI().toString());
                    if( response.getStatusLine().getStatusCode() == 200){
                        if(platformInfo != null){
                            platformInfo.setStatus(PlatformStatus.SUCCESS.getStatus());
                        }
                    }else{
                        if(platformInfo != null){
                            platformInfo.setStatus(PlatformStatus.ERROR.getStatus());
                        }
                    }

                }

                @Override
                public void failed(Exception excptn) {
                    latch.countDown();
                    PlatformInfo platformInfo =  map.get(request.getURI().toString());
                    if(platformInfo != null){
                        platformInfo.setStatus(PlatformStatus.ERROR.getStatus());
                    }
                }

                @Override
                public void cancelled() {
                    latch.countDown();
                    PlatformInfo platformInfo =  map.get(request.getURI().toString());
                    if(platformInfo != null){
                        platformInfo.setStatus(PlatformStatus.ERROR.getStatus());
                    }
                }

            });
           /* HttpResponse response = future.get();
            PlatformInfo platformInfo =  map.get(request.getURI().toString());
            if(response.getStatusLine().getStatusCode() == 200){
                if(platformInfo != null){
                    platformInfo.setStatus(PlatformStatus.SUCCESS.getStatus());
                }
            };*/
            request.releaseConnection();
        }

        try {
            latch.await();
        } catch (Exception ex) {
            ex.printStackTrace();
            logger.error("定時任務(wù)出錯："+ex.getMessage());
        }
       /*
        finally{
            try {
                httpClient.close();
            }
            catch (IOException ex) {
                logger.error("定時任務(wù)出錯："+ex.getMessage());
            }
        }*/
        /*try {
            httpClient.close();
        }
        catch (IOException ex) {
            logger.error("定時任務(wù)出錯："+ex.getMessage());
        }*/