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及参数。