记一次对OkGo的封装

我司项目的接口最近放开了几个，准备开始网络请求数据。本来想用Retrofit + Rxjava 的，自己尝试的封装了一下，一般般（其实是我菜，哭！）。于是乎去网上找了找有什么封装比较好的第三方，转了一圈没有什么满意的，转而其次使用OkGo，目前GitHub上面有5K+的星，还是不错的。

基本上所有功能，包括网络请求都需要进行一次二次封装，以便于以后的维护更迭，所以自己准备对OkGo进行一下封装。（我才不会说我是网上找了一下，没有找到合适的！！！网上都是的说OkGo哪里好，或者基本使用方法，好一点的提供简单的封装一下，但是根本不适合在项目中使用。）

在与我司另外一位Android程序猿合力下终于封装好了，下面记录一下思路及实现。

自己简单写的封装，要改进的很多。先这样吧！有更好的方法请联系我。

1.建立一个类，专门用来保存api，同时根据api的code，获取对应的get/post/put/delete请求。

/**
 * 存放所有的API
 */

public class Urls {

    //网络请求返回码
    public static final int REUSLT_CODE_SUCCESS = 200;//成功

    //版本号
    public static int VERSION = 1;


    //APICode：用于识别是那个地址的
    public static final int GET_SMS_CODE = 0;//获取验证码
    public static final int LOGIN_CODE = 1;//登录
    //这里不列举了，以此类推


    //APIUrl：具体地址
    public static final String BASE_URL = "https:/xxxxx" + VERSION;
    public static final String SMS_URL = BASE_URL + "/user/sms";//验证码
    public static final String LOGIN_URL = BASE_URL + "/user/login";//登录
    

    /**
     * 根据APICode来获取对应的请求方式:
     * GET：0  POST：1  PUT：2  DELETE：3  错误:-1
     *
     * @param APICode
     * @return
     */
    public static int getOrPost(int APICode) {
        int code = -1;
        switch (APICode) {

            case HOME_CODE://查询首页数据
                code = 0;
                break;
            case GET_SMS_CODE://获取验证码
            case LOGIN_CODE://登录
                code = 1;
                break;
            case SHOP_CART_CHANGE_DATA_CODE://修改购物车数据
                code = 2;
                break;
            case SHOP_CART_DEL_DATA_CODE://删除购物车数据
                code = 3;
                break;
        }

        return code;
    }

2.建立一个接口，用来请求数据成功、失败、错误的回调，就3个方法，这里就不写了。

3.建立一个转换器，用来讲获取的String的json数据转换为bean对象，（okgo文档里面有，我这里也列出来了，泛型用的贼垃圾，有大神改进的话联系我嘿嘿）

/**
 * 用于将json数据转换为Bean对象
 */

public class JsonConvert<T> implements Converter<T> {

    private Type type;
    private Class clazz;

    public JsonConvert(Type type) {
        this.type = type;
    }

    public JsonConvert(Class t) {
        this.clazz = t;
    }

    public JsonConvert() {

    }

    /**
     * 该方法是子线程处理，不能做ui相关的工作
     * 主要作用是解析网络返回的 response 对象，生成onSuccess回调中需要的数据对象
     */
    @Override
    public T convertResponse(Response response) throws Throwable {

        ResponseBody body = response.body();
        if (body == null) return null;

        T data = null;
        Gson gson = new Gson();
        JsonReader jsonReader = new JsonReader(body.charStream());
        if (type != null) data = gson.fromJson(jsonReader, type);
        if (clazz != null) data = gson.fromJson(jsonReader, clazz);
        return data;
    }


}

4.建立一个工具类，进行请求方法设置。

public class HttpUtils<T> {

//这里对应4种请求方式。
public static final int GET = 0;
public static final int POST = 1;
public static final int PUT = 2;
public static final int DEL = 3;

/**
 * get请求：返回Observable
 */
public Observable<T> getObservable(String url, Map<String, String> paramerMap, Class c) {
        return OkGo.<T>get(url)
                .headers("xxx", xxx)
                .converter(new JsonConvert<T>(c))
                .adapt(new ObservableBody<T>());
}

/**
 * post请求：返回Observable
 */
public Observable<T> postObservable(String url, Map<String, String> paramerMap, Class c) {

        return OkGo.<T>post(url)
                 .headers("xxx", xxx)
                .params(paramerMap)
                .converter(new JsonConvert<T>(c))
                .adapt(new ObservableBody<T>());
}

//put和del请求同理

/**
 * 请求数据
 */
public void getBeanData(final int urlCode, String url, int requestCode, Map<String, String> map, Class c, final OnConnectionListener listener) {

    Observer observer = new Observer() {
        @Override
        public void onSubscribe(@NonNull Disposable d) {
        }

        @Override
        public void onNext(@NonNull Object o) {
            这里的listener就是第二步建立的接口
            listener.onResponse(urlCode, o);
        }

        @Override
        public void onError(@NonNull Throwable e) {
            Logger.e("连接失败========" + e.toString());
            listener.onError(urlCode);
        }

        @Override
        public void onComplete() {
        }
    };

    if (requestCode == GET) {
        //get请求
        getObservable(url, map, c)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe(new Consumer<Disposable>() {
                    @Override
                    public void accept(@NonNull Disposable disposable) throws Exception {
                      
                        listener.onPreConnect(urlCode);
                    }
                })
                .subscribe(observer);


    } else if (requestCode == POST) {
        //post请求
        postObservable(url, map, c)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe(new Consumer<Disposable>() {
                    @Override
                    public void accept(@NonNull Disposable disposable) throws Exception {
                        listener.onPreConnect(urlCode);
                    }
                })
                .subscribe(observer);

    }

}

}

5.在model完成请求的相关监听

public class Model extends BaseModel implements OnConnectionListener {

    private final Context mContext;
    private final HttpUtils httpUtils;

    public Model (Context context) {
        this.mContext = context;
        httpUtils = new HttpUtils();
    }

 
     * 获取首页的数据
     */
    public Model getHomeData() {

        //进行联网
        Map<String, String> map = new HashMap<>();
        httpUtils.getBeanData(Urls.HOME_CODE, Urls.HOME_URL, Urls.getOrPost(Urls.HOME_CODE), map,HomeBean.class, this);

        return this;
    }


    /**
     * 对请求的回调： 请求之前
     *
     * @param responseCode
     */
    @Override
    public void onPreConnect(int responseCode) {
        
    }

    //请求成功
    @Override
    public void onResponse(int responseCode, Object o) {

        switch (responseCode) {
            case Urls.HOME_CODE://首页数据
               HomeBean homeBean = (HomeBean) o;
                int code = homeBean.getCode();
                if (code == 200) {
                    mOnRequestListener.onSuccessed(responseCode, o);
                } else {
                    String message = homeBean.getMessage();
                    mOnRequestListener.onFailed(responseCode, message);
                }
                break;
        }
    }


    //请求失败
    @Override
    public void onError(int responseCode) {
 
    }


    /**
     * 联网请求数据之后的接口回调
     */
    private OnRequestListener mOnRequestListener;

    public void setOnRequestListener(OnRequestListener listener) {
        this.mOnRequestListener = listener;
    }

}

6.具体请求

直接在代码中，model.getHomeData().setOnRequestListener(this);然后实现接口，就会有数据回调。

其实有很多地方没有处理好比如说 httpUtils里面就可以优化很多，目前还没有好的想法。包括model也有很多的优化要做的。