第三方网络引擎的搭建

1. 概述


目前市面上边比较火的第三方网络引擎会有很多,像早期的 AsyncTask、XUtils就不说了,之前的Volley、现在的Okhttp、Retrofit等等这些网络框架,我们一般在开发项目的过程中绝大部分的小伙伴可能都是只去用其中的一种,那么如果说我们后期项目需要去更换网络框架的时候,就会比较麻烦了,所以说如果有一种情况就是:只需要去在配置的基类中修改以下相关配置就可以随意切换网络框架就显得尤为重要,那么接下来我们就来看下如何实现这样的一个功能。

2. 分析


要想实现一个 可以修改配置的基类中的相关网络的代码就可以随意切换任何的网络框架,这里边是需要解决几个问题:首先是回调的问题、然后就是请求网络的问题,而我们采用的方式就是:回调我们用自己的,请求网络我们也用自己的,这样的话,这几个问题就迎刃而解了,主要就是4个类,那么下边我们就来看下具体的代码是怎样实现的。

1>:引擎规范如下:

/**
 * Email: 2185134304@qq.com
 * Created by JackChen 2018/4/6 12:23
 * Version 1.0
 * Params:
 * Description:  引擎的规范
*/
public interface IHttpEngine {
    // get请求
    void get(Context context , String url , Map<String , Object> params , EngineCallBack callBack) ;
    // post请求
    void post(Context context , String url , Map<String , Object> params , EngineCallBack callBack) ;


    // 上传文件
    // 下载文件
    // https 添加证书

}

2>:网络引擎的回调接口 EnginueCallBack代码如下:

/**
 * Email: 2185134304@qq.com
 * Created by JackChen 2018/4/6 12:33
 * Version 1.0
 * Params:
 * Description:   我们自己的网络引擎的回调
*/
public interface EngineCallBack {

    /**
     * 网络请求成功
     */
    public void onSuccess(String result) ;

    /**
     * 网络请求失败
     */
    public void onError(Exception e) ;


    /**
     * 默认的,里边什么也不干
     */
    public final EngineCallBack DEFAULT_CALL_BACK = new EngineCallBack() {
        @Override
        public void onSuccess(String result) {

        }

        @Override
        public void onError(Exception e) {

        }
    } ;
}

3>:我们自己的OKHttpEngine网络代码如下:

/**
 * Email: 2185134304@qq.com
 * Created by JackChen 2018/4/6 12:29
 * Version 1.0
 * Params:
 * Description:   我们自己默认的网络请求  -->  OkHttpEngine
*/
public class OkHttpEngine implements IHttpEngine {
    private static OkHttpClient mOkHttpClient = new OkHttpClient();

    @Override
    public void post(Context context, String url, Map<String, Object> params, final EngineCallBack callBack) {

        final String jointUrl = HttpUtils.jointParams(url,params);  //打印
        Log.e("Post请求路径:",jointUrl);

        // 了解 Okhhtp
        RequestBody requestBody = appendBody(params);
        Request request = new Request.Builder()
                .url(url)
                .tag(context)
                .post(requestBody)
                .build();

        mOkHttpClient.newCall(request).enqueue(
                new Callback() {
                    @Override
                    public void onFailure(okhttp3.Call call, IOException e) {
                        callBack.onError(e);
                    }

                    @Override
                    public void onResponse(okhttp3.Call call, Response response) throws IOException {
                        // 这个 两个回掉方法都不是在主线程中
                        String result = response.body().string();
                        Log.e("Post返回结果:",jointUrl);
                        callBack.onSuccess(result);
                    }
                }
        );
    }

    /**
     * 组装post请求参数body
     */
    protected RequestBody appendBody(Map<String, Object> params) {
        MultipartBody.Builder builder = new MultipartBody.Builder()
                .setType(MultipartBody.FORM);
        addParams(builder, params);
        return builder.build();
    }

    // 添加参数
    private void addParams(MultipartBody.Builder builder, Map<String, Object> params) {
        if (params != null && !params.isEmpty()) {
            for (String key : params.keySet()) {
                builder.addFormDataPart(key, params.get(key) + "");
                Object value = params.get(key);
                if (value instanceof File) {
                    // 处理文件 --> Object File
                    File file = (File) value;
                    builder.addFormDataPart(key, file.getName(), RequestBody
                            .create(MediaType.parse(guessMimeType(file
                                    .getAbsolutePath())), file));
                } else if (value instanceof List) {
                    // 代表提交的是 List集合
                    try {
                        List<File> listFiles = (List<File>) value;
                        for (int i = 0; i < listFiles.size(); i++) {
                            // 获取文件
                            File file = listFiles.get(i);
                            builder.addFormDataPart(key + i, file.getName(), RequestBody
                                    .create(MediaType.parse(guessMimeType(file
                                            .getAbsolutePath())), file));
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                } else {
                    builder.addFormDataPart(key, value + "");
                }
            }
        }
    }

    /**
     * 猜测文件类型
     */
    private String guessMimeType(String path) {
        FileNameMap fileNameMap = URLConnection.getFileNameMap();
        String contentTypeFor = fileNameMap.getContentTypeFor(path);
        if (contentTypeFor == null) {
            contentTypeFor = "application/octet-stream";
        }
        return contentTypeFor;
    }

    @Override
    public void get(Context context,String url, Map<String, Object> params, final EngineCallBack callBack) {
        url = HttpUtils.jointParams(url, params);

        Log.e("Get请求路径:", url);

        Request.Builder requestBuilder = new Request.Builder().url(url).tag(context);
        //可以省略,默认是GET请求
        Request request = requestBuilder.build();

        mOkHttpClient.newCall(request).enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                callBack.onError(e);
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                String resultJson = response.body().string();
                callBack.onSuccess(resultJson);
                Log.e("Get返回结果:", resultJson);
            }
        });
    }

}

4>:自己实现的一套网络请求:

/**
 * Email: 2185134304@qq.com
 * Created by JackChen 2018/4/6 12:21
 * Version 1.0
 * Params:
 * Description:  自己的一套实现网络请求
*/

public class HttpUtils{


    // 上下文
    private Context mContext ;
    // 直接带参数,最好是链式调用
    private String mUrl ;
    // 请求方式
    private int mType = GET_TYPE;

    private static final int GET_TYPE = 0x0011 ;

    private static final int POST_TYPE = 0x0011 ;


    private Map<String , Object> mParams ;

    private HttpUtils(Context context){
        this.mContext = context ;
        mParams = new HashMap<>() ;
    }


    /**
     * 这里最好不要用单例,否则内存泄露,因为所有的设计模式都有自己的特定场景
     */
    public static HttpUtils with(Context context){
        return new HttpUtils(context) ;
    }


    /**
     * 添加 url 路径
     */
    public HttpUtils url(String url){
        this.mUrl = url ;
        return this ;
    }


    /**
     * 请求的方式 -->  post
     * 这里为了链式调用,只需要返回this就ok
     */
    public HttpUtils post(){
        mType = POST_TYPE ;
        return this ;
    }


    /**
     * 请求的方式 -->  get
     * 这里为了链式调用,只需要返回this就ok
     */
    public HttpUtils get(){
        mType = GET_TYPE ;
        return this ;
    }


    /**
     * 一次添加一个参数
     */
    public HttpUtils addParam(String key , Object value){
        mParams.put(key , value) ;
        return this ;
    }


    /**
     * 一次添加多个参数
     */
    public HttpUtils addParams(Map<String , Object> params){
        mParams.putAll(params) ;
        return this ;
    }


    /**
     * 添加回调 , 最终去执行
     */
    public void execute(EngineCallBack callBack){
        if (callBack == null){
            callBack = DEFAULT_CALL_BACK ;
        }

        // 判断执行方法
        if (mType == POST_TYPE){
            post(mUrl , mParams , callBack);
        }

        if (mType == GET_TYPE){
            get(mUrl , mParams , callBack);
        }
    }

    public void execute(){
        execute(null);
    }

    // 默认是 OKHttpEngine
    private static IHttpEngine mHttpEngine = new OkHttpEngine() ;


    /**
     * 这个是在 BaseApplication中初始化引擎的
     */
    public static void init(IHttpEngine httpEngine){
        mHttpEngine = httpEngine ;
    }


    /**
     * 这个是 我们每次可以自带引擎:
     * 比如每次去new Volley()、new OkHttp()、new Retrofit()等不同的引擎
     */
    public static void exchange(IHttpEngine httpEngine){

    }



    private void get(String url, Map<String, Object> params, EngineCallBack callBack) {
        mHttpEngine.get(mContext , url , params , callBack);
    }


    private void post(String url, Map<String, Object> params, EngineCallBack callBack) {
        mHttpEngine.post(mContext , url , params , callBack);
    }


    /**
     * 拼接参数
     */
    public static String jointParams(String url, Map<String, Object> params) {
        if (params == null || params.size() <= 0) {
            return url;
        }

        StringBuffer stringBuffer = new StringBuffer(url);
        if (!url.contains("?")) {
            stringBuffer.append("?");
        } else {
            if (!url.endsWith("?")) {
                stringBuffer.append("&");
            }
        }

        for (Map.Entry<String, Object> entry : params.entrySet()) {
            stringBuffer.append(entry.getKey() + "=" + entry.getValue() + "&");
        }

        stringBuffer.deleteCharAt(stringBuffer.length() - 1);

        return stringBuffer.toString();
    }

    /**
     * 解析一个类上面的class信息
     */
    public static Class<?> analysisClazzInfo(Object object) {
        Type genType = object.getClass().getGenericSuperclass();
        Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
        return (Class<?>) params[0];
    }
}

最终只需要在MainActivity中的initData()方法中直接调用就ok

    @Override
    protected void initData() {
        HttpUtils.with(this).url("").addParam("" , "").get().execute(new EngineCallBack() {
            @Override
            public void onSuccess(String result) {
                Toast.makeText(MainActivity.this , "请求网络成功" , Toast.LENGTH_SHORT).show();
            }

            @Override
            public void onError(Exception e) {

            }
        });
    }

代码已上传至github:
https://github.com/shuai999/EssayJoke_day_09.git

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,717评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,501评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,311评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,417评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,500评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,538评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,557评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,310评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,759评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,065评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,233评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,909评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,548评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,172评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,420评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,103评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,098评论 2 352

推荐阅读更多精彩内容