2. 程式人生 > >Httpclient多執行緒連線池封裝

Httpclient多執行緒連線池封裝

阿新 • • 發佈：2019-02-07

1、封裝

package com.suning.search.utils;



import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;


import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;

import org.apache.http.HttpStatus;
import org.apache.http.HttpVersion;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.scheme.PlainSocketFactory;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.http.impl.conn.PoolingClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.params.HttpParams;
import org.apache.http.params.HttpProtocolParams;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class CommonHttpClient {
private static final Logger log = LoggerFactory.getLogger(CommonHttpClient.class);
    private static final String CHARSET = "UTF-8";
    private static Map<ClientName, HttpClient> clientMap = new HashMap<ClientName, HttpClient>(
            ClientName.values().length);


    public static int HTTP_CONNECT_TIMEOUT = 5000;
    public static int HTTP_SO_TIMEOUT = 5000;
    public static int HTTP_POOL_TIMEOUT = 1000;
    public static int HTTP_MAX_ROUTE_CONNECTIONS = 128;
    public static int HTTP_MAX_TOTAL_CONNECTIONS = 10;

    private CommonHttpClient() {


    }
    public static void initHttpClients() {
        clientMap.clear();
    }
    /**
     * http client模組名稱的列舉類
     */
    public static enum ClientName {
        DEFAULT_CLIENT
    }


    public static class ClientParam {
        private int poolTimeout;        
        private int connectionTimeout;
        private int soTimeout;
        private int maxRouteConnections;
        private int maxTotalConnections;


        public ClientParam(int poolTimeout, int connectionTimeout,
                           int soTimeout, int maxRouteConnections, int maxTotalConnections) {
            this.poolTimeout = poolTimeout;
            this.connectionTimeout = connectionTimeout;
            this.soTimeout = soTimeout;
            this.maxRouteConnections = maxRouteConnections;
            this.maxTotalConnections = maxTotalConnections;
        }


        public int getPoolTimeout() {
            return poolTimeout;
        }


        public void setPoolTimeout(int poolTimeout) {
            this.poolTimeout = poolTimeout;
        }


        public int getConnectionTimeout() {
            return connectionTimeout;
        }


        public void setConnectionTimeout(int connectionTimeout) {
            this.connectionTimeout = connectionTimeout;
        }


        public int getSoTimeout() {
            return soTimeout;
        }


        public void setSoTimeout(int soTimeout) {
            this.soTimeout = soTimeout;
        }


        public int getMaxRouteConnections() {
            return maxRouteConnections;
        }


        public void setMaxRouteConnections(int maxRouteConnections) {
            this.maxRouteConnections = maxRouteConnections;
        }


        public int getMaxTotalConnections() {
            return maxTotalConnections;
        }


        public void setMaxTotalConnections(int maxTotalConnections) {
            this.maxTotalConnections = maxTotalConnections;
        }


        @Override
        public String toString() {
            return "ClientParam [poolTimeout=" + poolTimeout
                    + ", connectionTimeout=" + connectionTimeout
                    + ", soTimeout=" + soTimeout + ", maxRouteConnections="
                    + maxRouteConnections + ", maxTotalConnections="
                    + maxTotalConnections + "]";
        }


    }
    /**
     * 根據http client名稱獲取對應的引數
     *
     * @param clientName CommonHttpClient.HTTP_SPES_INTERFACE_CLIENT,
     *                   CommonHttpClient.SUNING_DOMAIN_CLIENT
     * @return ClientParam
     */
    private static ClientParam getClientParam(ClientName clientName) {
        ClientParam param = null;


        switch (clientName) {
            // default httpclient 初始化引數
            case DEFAULT_CLIENT:
                param = new ClientParam(HTTP_POOL_TIMEOUT,
                        HTTP_CONNECT_TIMEOUT,
                        HTTP_SO_TIMEOUT,
                        HTTP_MAX_ROUTE_CONNECTIONS,
                        HTTP_MAX_TOTAL_CONNECTIONS);
                break;


            default:
                param = new ClientParam(HTTP_POOL_TIMEOUT,
                        HTTP_CONNECT_TIMEOUT,
                        HTTP_SO_TIMEOUT,
                        HTTP_MAX_ROUTE_CONNECTIONS,
                        HTTP_MAX_TOTAL_CONNECTIONS);
                break;
        }


        return param;
    }
    /**
     * 建立httpclient
     */
@SuppressWarnings("deprecation")
public static synchronized HttpClient createHttpClient(ClientName clientName) {
        HttpClient httpClient = clientMap.get(clientName);
        if (httpClient != null) {
            return httpClient;
        }


        ClientParam clientParam = getClientParam(clientName);
HttpParams params = new BasicHttpParams();
        // 設定一些基本引數
        HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);
        HttpProtocolParams.setContentCharset(params, CHARSET);
        HttpProtocolParams.setUseExpectContinue(params, true);
        HttpProtocolParams
                .setUserAgent(
                        params,
                        "Mozilla/5.0(Linux;U;Android 2.2.1;en-us;Nexus One Build.FRG83) "
                                + "AppleWebKit/553.1(KHTML,like Gecko) Version/4.0 Mobile Safari/533.1");
        // 超時設定
        /* 從連線池中取連線的超時時間 */
        /* 連線超時 */
        params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT,
                clientParam.getConnectionTimeout());
        /* 請求超時 */
        params.setParameter(CoreConnectionPNames.SO_TIMEOUT,
                clientParam.getSoTimeout());
        params.setParameter(CoreConnectionPNames.SO_KEEPALIVE,"true");


        // 設定我們的HttpClient支援HTTP和HTTPS兩種模式
        SchemeRegistry schReg = new SchemeRegistry();
        schReg.register(new Scheme("http", 80, PlainSocketFactory
                .getSocketFactory()));
        schReg.register(new Scheme("https", 443, SSLSocketFactory
                .getSocketFactory()));
        // 使用執行緒安全的連線管理來建立HttpClient
        PoolingClientConnectionManager pccm = new PoolingClientConnectionManager(
                schReg);
        // MAX_ROUTE_CONNECTIONS為要設定的每個路由最大連線數
        pccm.setDefaultMaxPerRoute(clientParam.getMaxRouteConnections());
        pccm.setMaxTotal(clientParam.getMaxTotalConnections());
        HttpClient client = new DefaultHttpClient(pccm, params);
        clientMap.put(clientName, client);
        return client;


    }
    /**
     * 根據http客戶端名獲取相應的連線例項
     *
     * @param clientName
     * @return
     */
    public static HttpClient getHttpClient(ClientName clientName) {
        HttpClient httpClient = clientMap.get(clientName);//由於在類的初始化時並沒有賦值，所以必定為null
        if (null == httpClient) {
            httpClient = createHttpClient(clientName);
        }
        return httpClient;
    }
    public static String get(String url, ClientName clientName) {
        try {
            HttpGet httpget = new HttpGet(url);
            HttpResponse response = getHttpClient(clientName).execute(httpget);
            HttpEntity httpEntity = response.getEntity();
            String result = null;
            if (httpEntity != null) {
                result = EntityUtils.toString(httpEntity);
                EntityUtils.consume(httpEntity);
            }
            return result;
        } catch (UnsupportedEncodingException e) {
<

相關推薦

Httpclient多執行緒連線池封裝

1、封裝 package com.suning.search.utils; import java.io.IOException;import java.io.UnsupportedEncodingException;import java.util.ArrayLis

多執行緒連線池

package com.mom.pi.common; import org.apache.log4j.Logger; import java.util.HashMap; import java.util.concurrent.*; public class ThreadPool {

2.3四種執行緒連線池的配置和使用（和自定義執行緒池）

四種執行緒連線池的配置和使用 最終呼叫類和方法 {引數有 核心執行緒數目，最大執行緒數目，存活時間（當前執行緒執行完這個任務之後，等待下一個任務到來的最長等待時間。如果在這個時間內沒有新的任務來到，那當前執行緒就會退出），時間單位，等待佇列（用於存放待執行的任務）} public

2.2四種執行緒連線池的作用

四種執行緒連線池的作用及其使用 執行緒池的作用： 執行緒池作用就是限制系統中執行執行緒的數量。 根據系統的環境情況，可以自動或手動設定執行緒數量，達到執行的最佳效果；少了浪費了系統資源，多了造成系統擁擠效率不高。用執行緒池控制執行緒數量，其他執行緒排 隊等候。一個任務執行完畢，再

httpClient多執行緒請求

  1  package generate.httpclient;   2    3  import java.util.List;   4  import java.util.concurrent.ExecutorService;   5  impor

提高C++效能的程式設計技術筆記：多執行緒記憶體池+測試程式碼

為了使多個執行緒併發地分配和釋放記憶體，必須在分配器方法中新增互斥鎖。 全域性記憶體管理器(通過new()和delete()實現)是通用的，因此它的開銷也非常大。 因為單執行緒記憶體管理器要比多執行緒記憶體管理器快的多，所以如果要分配的大多數記憶體塊限於單執行緒中使用，那麼可以顯著提升效

socket accept()多執行緒連線 詳解

你也可以檢視我的其他同類文章，也會讓你有一定的收貨！ 在使用accept函式的時候，如果伺服器面向多個客戶的連線， 必須使用while迴圈，每次迴圈阻塞在accept函式，等待新的連線到來

oracle linux proc 多執行緒連線庫 程式碼示例

#include "sqlca.h" #include "sqlda.h" #define SQLCODE sqlca.sqlcode #define SQLNOTFOUND 1403 #define SQLCODE sqlca.sqlcode #define S

httpclient 多執行緒高併發Get請求

public class HttpRequest {     private static PoolingClientConnectionManager conMgr = null;    static {         HttpParams params = new BasicHttpParams();

Solaris10 下的多執行緒和Mysql多執行緒連線

1. Solairs下的多執行緒 執行緒分成兩種，一種是POSIX格式的（使用 pthread.h），一種是Solairs格式的（thread.h），建議使用 POSIX格式。 int pthread_create(pthread_t *restrict th

Android多執行緒操作sqlite資料庫連線池框架的一種設計思路

我們在Android應用程式開發當中經常會用到資料庫，一般在有兩種主要開發思路。 第一種：每次需要對資料庫操作的時候建立連線，操作完成後，馬上關閉連線。 這個方式一般用於不怎麼頻繁操作資料庫的情況，用完後馬上關閉達到節省系統資源的目的。 第二種：應用程式一

Android 多執行緒 執行緒池原理 封裝執行緒池

我自己理解看來。執行緒池顧名思義就是一個容器的意思，需要注意的是，每一個執行緒都是需要CPU分配資源去執行的。如果由於總是new Thread()開啟一個執行緒，那麼就會大量的消耗CPU的資源，導致Android執行變慢，甚至OOM(out of memory)，因而J

執行緒池中多執行緒設定超時退出監控

前言 在寫多執行緒程式時，大多數情況下會先excutor建立執行緒池，然後再建立執行緒，但是對一些讀資料庫或者其他IO操作，容易堵住執行緒，此時就需要給執行緒設定超時時間，幹掉超時的執行緒再重新拉起一個執行緒來，但是java執行緒建立並沒有預留超時引數，研究了一下網上也沒找到

JAVA多執行緒(三) 執行緒池和鎖的深度化

 github演示程式碼地址：https://github.com/showkawa/springBoot_2017/tree/master/spb-demo/src/main/java/com/kawa/thread 1.執行緒池  1.1 執行緒池是什麼 Java中的執行緒

【多執行緒】執行緒池

1、好處 第一：降低資源消耗。通過重複利用已建立的執行緒降低執行緒建立和銷燬造成的消耗。 第二：提高響應速度。當任務到達時，任務可以不需要等到執行緒建立就能立即執行。 第三：提高執行緒的可管理性。執行緒是稀缺資源，如果無限制地建立，不僅會消耗系統資源， 還會降低系統的穩定性，使用執行

多執行緒學習----執行緒池(九)

1.固定執行緒池 建立一個執行緒池，裡邊放三個執行緒，建立十個任務，讓三個執行緒誰有空閒誰去執行這十個任務，直到任務結束。 public class ThreadPoolStudy { public static void main(String[] args) { //建

java多執行緒7.使用執行緒池

只有當任務都是同類型並且相互獨立時，執行緒池的效能才能達到最佳。如果將執行時間較長的與執行時間較短的任務混合在一起，那麼除非執行緒池很大，否則將可能造成擁塞，如果提交的任務依賴於其他任務，那麼除非執行緒池無線大，否則將可能造成死鎖。 例如飢餓死鎖：執行緒池中的任務需要無限等待一些必須由池中其他任務才能提供的

Java多執行緒 - 執行緒池 ThreadPoolExecutor類的使用

ThreadPoolExecutor類可以非常方便的建立執行緒池物件，而不需要程式設計師設計大量的new去例項化Thread相關的程式碼 最常用的構造方法 (不過threadFactory可以視情況設或不設) ThreadPoolExecutor(   &nb

CnComm多執行緒串列埠通訊類的封裝實現v0.02

 在CnComm多執行緒串列埠通訊類的封裝實現一文中實現了對於cncomm多執行緒串列埠類的簡單封裝，新版本將串列埠管理類改成了工廠類和單例類，實現了對於動態擴充套件新的串列埠，新的版本符合開閉原則。 1.串列埠管理類 #ifndef _COMM_MANAGE_H_ #def

多執行緒基礎 6 執行緒池

  執行緒池概述 * 程式啟動一個新執行緒成本是比較高的，因為它涉及到要與作業系統進行互動。而使用執行緒池可以很好的提高效能，尤其是當程式中要建立大量生存期很短的執行緒時，更應該考慮使用執行緒池。執行緒池裡的每一個執行緒程式碼結束後，並不會死亡，而是再次回到執行緒池中成為空閒狀態