Android下基於線程池的網絡訪問基礎框架

引言

　　現在的Android開發很多都使用Volley、OkHttp、Retrofit等框架，這些框架固然有優秀的地方(以后會寫代碼學習分享)，但是我們今天介紹一種基於Java線程池的網絡訪問框架。

實現思路及實現

　　APP界面上面的數據都是通過網絡請求獲取的，我們能不能將網絡請求依次入隊，然后配合着Java線程池，讓線程依次處理我們的請求，最后返回結果給我們。下面我們先來看一下線程池工具類的實現：

public class ThreadPoolUtils {

    private ThreadPoolUtils() {}
    //核心線程數
    private static int CORE_POOL_SIZE = 8;
    //最大線程數
    private static int MAX_POOL_SIZE = 64;
    //線程池中超過corePoolSize數目的空閑線程最大存活時間；可以allowCoreThreadTimeOut(true)使得核心線程有效時間
    private static int KEEP_ALIVE_TIME = 5;
    //任務隊列
    private static BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(64);

    private static ThreadPoolExecutor threadpool;

    static {
        threadpool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS, workQueue);
    }

    public static void execute(Runnable runnable) {
        threadpool.execute(runnable);
    }
}

　　我們來看一下ThreadPoolExecutor的構造函數及相關參數：

參數名	作用
corePoolSize	核心線程池大小
maximumPoolSize	最大線程池大小
keepAliveTime	線程池中超過corePoolSize數目的空閑線程最大存活時間；可以allowCoreThreadTimeOut(true)使得核心線程有效時間
TimeUnit	keepAliveTime時間單位
workQueue	阻塞任務隊列
threadFactory	新建線程工廠
RejectedExecutionHandler	當提交任務數超過maxmumPoolSize+workQueue之和時，任務會交給RejectedExecutionHandler來處理

　　重點講解：
　　其中比較容易讓人誤解的是：corePoolSize，maximumPoolSize，workQueue之間關系。
　　1.當線程池小於corePoolSize時，新提交任務將創建一個新線程執行任務，即使此時線程池中存在空閑線程。
　　2.當線程池達到corePoolSize時，新提交任務將被放入workQueue中，等待線程池中任務調度執行
　　3.當workQueue已滿，且maximumPoolSize>corePoolSize時，新提交任務會創建新線程執行任務
　　4.當提交任務數超過maximumPoolSize時，新提交任務由RejectedExecutionHandler處理
　　5.當線程池中超過corePoolSize線程，空閑時間達到keepAliveTime時，關閉空閑線程
　　6.當設置allowCoreThreadTimeOut(true)時，線程池中corePoolSize線程空閑時間達到keepAliveTime也將關閉

網絡訪問的封裝

　　通過上面的分析，我們知道ThreadPoolExecutor里面可以執行Runable對象，那么我們將網絡訪問邏輯封裝成Runable對象，然后扔進線程池進行執行。我們來看一下封裝的邏輯：

/**
 * post線程
 */
public class HttpPostThread implements Runnable {

    private Handler hand;
    private String strURL;
    private String method;
    private List<String> params;
    private Handler netHand;

    public HttpPostThread(Handler hand, String strURL, String method, List<String> params) {
        this.hand = hand;
        //實際的傳值
        this.strURL = strURL;
        this.method = method;
        this.params = params;
    }

    public HttpPostThread(Handler hand, Handler netHand, String strURL, String method, List<String> params) {
        this.hand = hand;
        //實際的傳值
        this.strURL = strURL;
        this.method = method;
        this.params = params;
        this.netHand = netHand;
    }

    @Override
    public void run() {
        Message msg = hand.obtainMessage();
        try {
            String result;
            if(!strURL.startsWith("https")) {
                RpcHttp rpcHttp = new RpcHttp();
                result = rpcHttp.post(strURL, method, params);
            }
            else {
                RpcHttps rpcHttps = new RpcHttps();
                result = rpcHttps.post(strURL, method, params);
            }
            /**
             * 根據訪問http來設置標識位
             * 然后發送msg到handlerMessage進行處理(此處配合Handler進行使用)
             */
            if (result.equals("noNet")) {
                if (netHand != null) {
                    netHand.sendEmptyMessage(600);
                }
            } else {
                msg.what = 200;
                msg.obj = result;
            }
        } catch(Exception e){
            e.printStackTrace();
        }
        finally {
            hand.sendMessage(msg);
        }
    }
}

　　我們看到，我們封裝的這個類的構造函數只需要使用者提供回調的Handler、Http訪問的Url、訪問的方法及參數。這樣就可以將其放入線程中進行處理，然后我們只需要在客戶端使用寫好回調的Handler即可。我們看34-40行，這時候我們看到會使用封裝的Http類去進行網絡訪問，我們來看一下：

 /**
     * post請求
     *
     * @param strURL 請求的地址
     * @param method 請求方法
     * @param params 請求元素
     * @return
     */
    public String post(String strURL, String method, List<String> params) {
        Log.e("開始請求","獲取請求");
        String RequestParams = "";
        long timestamp = System.currentTimeMillis();
        RequestParams += "{\"method\":\"" + method + "\"";
        if (params != null && params.size() > 0) {
            RequestParams += ",\"params\":{";
            for (String item : params) {
                String first = item.substring(0, item.indexOf(":"));
                String second = item.substring(item.indexOf(":") + 1);
                RequestParams += "\"" + first + "\":\"" + second + "\",";
            }

            RequestParams = RequestParams.substring(0, (RequestParams.length() - 1));
            RequestParams += "}";
        } else {
            RequestParams += ",\"params\":{}";
        }
        RequestParams += ",\"id\":\"" + timestamp + "\"";
        RequestParams += "}";
        return this.post(strURL, RequestParams);
    }

    private String post(String strURL, String params) {
        try {
            URL url = new URL(strURL);// 創建連接
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();

            connection.setDoOutput(true);
            connection.setDoInput(true);
            connection.setUseCaches(false);
            connection.setInstanceFollowRedirects(true);
            connection.setRequestMethod("POST"); // 設置請求方式
            connection.setRequestProperty("Accept", "application/json"); // 設置接收數據的格式
            connection.setRequestProperty("Content-Type", "application/json"); // 設置發送數據的格式
            connection.setConnectTimeout(10000);//設置超時
            connection.setReadTimeout(10000);//設置超時
            Log.e("開始連接","開始連接");
            connection.connect();

            OutputStreamWriter out = new OutputStreamWriter(connection.getOutputStream(), "UTF-8"); // utf-8編碼
            out.append(params);
            out.flush();
            out.close();

            String result = convertStreamToString(connection.getInputStream());
            Log.e("responseContent",result);
            return result;
        } catch (Exception e) {
            Log.e("responseException",String.valueOf(e.getStackTrace()));
            Log.e("responseException",String.valueOf(e.getLocalizedMessage()));
            Log.e("responseException",String.valueOf(e.getMessage()));
            e.printStackTrace();
        }
        return "noNet"; // 自定義錯誤信息
    }

　　我們看到，我們將Http訪問進行了簡單的封裝。在客戶端使用的時候我們就只需要簡單的幾行代碼即可：

List<String> params = new ArrayList<>();
params.add("access_token:" + getAccessToken());
//開始用戶更新信息
ThreadPoolUtils.execute(new HttpPostThread(userhand, APIAdress.UserClass, APIAdress.GetUserInfoMethod, params));

　　我們看到，我們創建了一個Runable實例，然后傳遞了回調的Handler、Url、Method及參數。