欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

网络封装()

程序员文章站 2022-03-04 08:48:14
...
  • function:
  • 1.因为okhttp代码太多,太冗余,使用的时候不是太方便,两行代码搞定 -----doGet,doPost
  • 2.都要创建OKhttp和咱们的handler对象,对象创建太多,导致内存过多的消耗 ----单例
  • 3.异步请求okhttp,数据请求成功以后,数据在子线程,所以我们还要写handler,把数据放到主线程去,逻辑复杂 -----handler和接口
    1. okhttp,handler,单例模式,接口

*/
public class OkhtttpUtilsTwo {
////////////////////////////////////////////////单例//////////////////////////////////////
private final Handler mHandler;
private final OkHttpClient mOkHttpClient;
private static OkhtttpUtilsTwo sOkhtttpUtilsTwo;

//构造方法不私有
private OkhtttpUtilsTwo(){
    //如果创建Handler的对象,是在一个普通的类里创建,那么一定要加上Looper.getMainLooper()这个参数
    mHandler = new Handler(Looper.getMainLooper());
    mOkHttpClient = new OkHttpClient.Builder()
            .readTimeout(5000, TimeUnit.MILLISECONDS)
            .connectTimeout(5000, TimeUnit.MILLISECONDS)
            .writeTimeout(5000, TimeUnit.MILLISECONDS)
            .build();
}

//单例暴露一个普通的方法,给对方,双重锁模式
public static OkhtttpUtilsTwo getInstance(){
    if (sOkhtttpUtilsTwo  ==null){
        synchronized (OkhtttpUtilsTwo.class){
            if (sOkhtttpUtilsTwo == null){
                return sOkhtttpUtilsTwo =new OkhtttpUtilsTwo();
            }
        }
    }
    return sOkhtttpUtilsTwo;
}
//////////////////////////////////////////////////////接口////////////////////////////////
public interface OkCallback {
    void onFailure (Exception e);
    void onResponse(String json);
}
////////////////////////////////////////////okhttp与handler///////////////////////////
/////封装doGEt的网络封装,参数定义两个,一个是URL网址   一个实现接口的对象
public void doGet(String url , final OkCallback ycfOkCallback){
    Request request = new Request.Builder()
            .get()
            .url(url)
            .build();
    Call call = mOkHttpClient.newCall(request);
    call.enqueue(new Callback() {
        @Override
        public void onFailure(Call call, final IOException e) {
            if (ycfOkCallback !=null){
                //切换到主线程
                mHandler.post(new Runnable() {
                    @Override
                    public void run() {
                        ycfOkCallback.onFailure(e);
                    }
                });
            }
        }
        @Override
        public void onResponse(Call call, Response response) throws IOException {
            if(response !=null && response.isSuccessful()){
                final String json = response.body().string();
                if (ycfOkCallback !=null){
                    //切换到主线程
                    mHandler.post(new Runnable() {
                        @Override
                        public void run() {
                            ycfOkCallback.onResponse(json);
                        }
                    });
                }
            }

        }
    });
}

//封装doPost的逻辑代码
public void doPost(String url, Map<String,String> map, final OkCallback ycfOkCallback){
    //创建FormBody对象,把表单添加到FormBody
    FormBody.Builder builder = new FormBody.Builder();
    //集合对象不为null的情况下
    if (map != null){
        for(String key: map.keySet()){
            builder.add(key,map.get(key));
        }
    }

    FormBody formBody = builder.build();

    //创建Request对象
    Request request = new Request.Builder()
            .post(formBody)
            .url(url)
            .build();

    Call call = mOkHttpClient.newCall(request);
    call.enqueue(new Callback() {
        @Override
        public void onFailure(Call call, final IOException e) {
            if (ycfOkCallback !=null){
                //切换到主线程
                mHandler.post(new Runnable() {
                    @Override
                    public void run() {
                        ycfOkCallback.onFailure(e);
                    }
                });
            }
        }

        @Override
        public void onResponse(Call call, Response response) throws IOException {
            if(response !=null && response.isSuccessful()){
                final String json = response.body().string();
                if (ycfOkCallback !=null){
                    //切换到主线程
                    mHandler.post(new Runnable() {
                        @Override
                        public void run() {
                            ycfOkCallback.onResponse(json);
                        }
                    });
                }
            }
        }
    });

}

}