Android
/
BaseOkHttp


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172
							package com.mylove.okhttp;

import android.annotation.SuppressLint;
import android.content.Context;
import android.support.annotation.NonNull;

import java.io.IOException;
import java.util.concurrent.TimeUnit;

import okhttp3.Cache;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import rx.Subscriber;

/**
 * @author myLove
 * @time 2017/11/15 13:52
 * @e-mail mylove.520.y@gmail.com
 * @overview
 */

class OkCall {
    @SuppressLint("StaticFieldLeak")
    private static Context mContext;
    private String mCacheUrl;
    private Subscriber<? super ResultMsg> subscriber;
    private Call call;
    @SuppressLint("StaticFieldLeak")
    private static OkCall instance;
    private CallType callType;
    private static OkHttpClient okHttpClient;

    private OkCall(String mCacheUrl, Request request, Subscriber<? super ResultMsg> subscriber, CallType callType) {
        this.mCacheUrl = mCacheUrl;
        this.subscriber = subscriber;
        this.call = okHttpClient.newCall(request);
        this.callType = callType;
    }

    /**
     * okHttpClient初始化，并添加拦截及缓存
     *
     * @param context    上下文
     * @param mCacheUrl  缓存地址
     * @param request    请求
     * @param subscriber 返回
     * @param callType   请求类型
     * @return
     */
    public static OkCall getInstance(Context context, String mCacheUrl, Request request, Subscriber<? super ResultMsg> subscriber, CallType callType) {
//        if (instance == null) {
//            synchronized (OkCall.class) {
//                if (instance == null) {
                    mContext = context;
                    OkHttpClient httpClient = new OkHttpClient();
                    okHttpClient = httpClient.newBuilder()
                            .addNetworkInterceptor(new CacheInterceptor())
                            .cache(privateCache())
                            .connectTimeout(30, TimeUnit.SECONDS)
                            .readTimeout(30, TimeUnit.SECONDS)
                            .build();
                    instance = new OkCall(mCacheUrl, request, subscriber, callType);
//                }
//            }
//        }
        return instance;
    }

    /**
     * 请求
     */
    void sendCall() {
        if (callType == CallType.SYNC) {
            sync();
        } else if (callType == CallType.ASYNC) {
            async();
        }
    }

    /**
     * 同步请求
     */
    private void sync() {
        try {
            Response execute = call.execute();
            ResultMsg msg = new ResultMsg();
            int code = execute.code();
            msg.setCode(code + "");
            msg.setResult("");
            if (execute.isSuccessful()) {
                String str = execute.body().string();
                msg.setResult(str);
                if (!str.contains("<!DOCTYPE html>")) {
                    if (FormatUtil.isNotEmpty(mCacheUrl)) {
                        CacheUtils.getInstance(mContext).setCacheToLocalJson(mCacheUrl, str);
                    }
                }
                subscriber.onNext(msg);
                subscriber.onCompleted();
            } else {
                String json = CacheUtils.getInstance(mContext).getCacheToLocalJson(mCacheUrl);
                if (FormatUtil.isNotEmpty(json)) {
                    msg.setResult(json);
                    subscriber.onNext(msg);
                } else {
                    subscriber.onError(new Exception("请求失败"));
                }
                subscriber.onCompleted();
            }
        } catch (IOException e) {
            String json = CacheUtils.getInstance(mContext).getCacheToLocalJson(mCacheUrl);
            ResultMsg msg = new ResultMsg();
            msg.setCode("404");
            if (FormatUtil.isNotEmpty(json)) {
                msg.setResult(json);
                subscriber.onNext(msg);
            } else {
                subscriber.onError(e);
            }
            e.printStackTrace();
            subscriber.onCompleted();
        }
    }

    /**
     * 异步请求
     */
    private void async() {
        call.enqueue(new Callback() {
            @Override
            public void onFailure(@NonNull Call call, @NonNull IOException e) {
                String json = CacheUtils.getInstance(mContext).getCacheToLocalJson(mCacheUrl);
                ResultMsg msg = new ResultMsg();
                msg.setCode("404");
                if (FormatUtil.isNotEmpty(json)) {
                    msg.setResult(json);
                    subscriber.onNext(msg);
                } else {
                    subscriber.onError(e);
                }
                e.printStackTrace();
                subscriber.onCompleted();
            }

            @Override
            public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {
                String str = response.body().string();
                ResultMsg msg = new ResultMsg();
                int code = response.code();
                msg.setCode(code + "");
                msg.setResult(str);
                if (!str.contains("<!DOCTYPE html>")) {
                    if (FormatUtil.isNotEmpty(mCacheUrl)) {
                        CacheUtils.getInstance(mContext).setCacheToLocalJson(mCacheUrl, str);
                    }
                }
                subscriber.onNext(msg);
                subscriber.onCompleted();
            }
        });
    }

    /**
     * 设置缓存路径，以及缓存文件大小
     */
    private static Cache privateCache() {
        return new Cache(mContext.getCacheDir(), 1024 * 1024);
    }
}