封裝類BaseApi

package com.xinchuang.buynow.util.retrofitUtil;import android.os.AsyncTask;import android.util.Log;import com.xinchuang.buynow.model.BaseRetData;import com.xinchuang.buynow.util.MyLog;import com.xinchuang.buynow.util.constants.RequestUrl;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import okhttp3.ResponseBody;import retrofit2.Call;import retrofit2.Callback;import retrofit2.GsonConverterFactory;import retrofit2.Response;import retrofit2.Retrofit;import retrofit2.http.GET;import retrofit2.http.Streaming;import retrofit2.http.Url;/** * 網絡請求的基類  所有的網絡請求功能都要繼承它 * 里面自定義了ApiCallBack接口   如果不需要三個回調方法   可以實現ApiCallback接口 * Created by 123 on 17/2/21. */public class BaseApi {    PRivate static final String mBaseUrl =  RequestUrl.ip;    protected Retrofit mRetrofit;    private final String TAG = "BaseApi";    public BaseApi() {        mRetrofit = new Retrofit.Builder()                .baseUrl(mBaseUrl)                .addConverterFactory(GsonConverterFactory.create())                .build();    }    public BaseApi(String baseUrl) {        mRetrofit = new Retrofit.Builder()                .baseUrl(baseUrl)                .addConverterFactory(GsonConverterFactory.create())                .build();    }    /**     * 處理retrofit回調 并調用ApiCallback相應返回     * */    protected class RetrofitCallback<T> implements Callback<T> {        private ApiCallback<T> mCallback;        public RetrofitCallback(ApiCallback<T> callback) {            mCallback = callback;        }        @Override        public void onResponse(Call<T> call, Response<T> response) {            if(response.isSuccessful()) {                mCallback.onSuccess(((T)response.body()));//                if(((BaseRetData)response.body()).ret == 1) {//                    mCallback.onSuccess(((T)response.body()));//                } else {//                    mCallback.onError(((BaseRetData)response.body()).err_code, ((BaseRetData)response.body()).err_msg);//                }            } else {                mCallback.onFailure();            }        }        @Override        public void onFailure(Call<T> call, Throwable t) {            MyLog.e(TAG,"api failure,throw=" + t.getMessage());            t.printStackTrace();            mCallback.onFailure();        }    }    /**     * 自定義 Api 回調     * 子類如果不需要三個方法  可以選擇實現接口  重寫方法     */    public interface ApiCallback<T> {        void onSuccess(T ret);        //ret=1時返回        void onError(int err_code, String err_msg);   //ret=0時返回        void onFailure();   //網絡請求失敗    }    /**     * 文件下載回調     */    public interface FileDownloadCallback {        void onSuccess();   //下載成功返回        void onProcess(long fileSizeDownloaded, long fileSize);   //下載進度        void onFailure();   //網絡請求失敗    }    /**     * 下載文件     * @param fileUrl 下載url     * @param filePath 本地保存path     * @param callback FileDownloadCallback回調     */    public void downloadFile(final String fileUrl, final String filePath, final FileDownloadCallback callback) {        final ApiService apiStore = mRetrofit.create(ApiService.class);        new AsyncTask<Void, Long, Void>() {            @Override            protected Void doInBackground(Void... params) {                Call<ResponseBody> call = apiStore.downloadFile(fileUrl);                call.enqueue(new Callback<ResponseBody>() {                    @Override                    public void onResponse(Call<ResponseBody> call, final Response<ResponseBody> response) {                        if (response.isSuccessful()) {                            new AsyncTask<Void, Void, Void>() {                                private boolean mWrittenToDisk;                                @Override                                protected Void doInBackground(Void... voids) {                                    mWrittenToDisk = writeResponseBodyToDisk(response.body(), filePath, callback);                                    return null;                                }                                @Override                                protected void onPostExecute(Void aVoid) {                                    if(mWrittenToDisk) {                                        callback.onSuccess();                                    } else {                                        callback.onFailure();                                    }                                }                            }.execute();                        } else {                            callback.onFailure();                        }                    }                    @Override                    public void onFailure(Call<ResponseBody> call, Throwable t) {                        callback.onFailure();                    }                });                return null;            }        }.execute();    }    /**     * responsebody寫入文件     * @param body     * @param filePath     * @param callback     * @return     */    private boolean writeResponseBodyToDisk(ResponseBody body, String filePath, FileDownloadCallback callback) {        try {            File file = new File(filePath);            String dir = filePath.substring(0, filePath.lastIndexOf('/'));            File fileDir = new File(dir);            if(!fileDir.exists()) {                fileDir.mkdirs();            }            InputStream inputStream = null;            OutputStream outputStream = null;            try {                byte[] fileReader = new byte[4096];                long fileSize = body.contentLength();                long fileSizeDownloaded = 0;                inputStream = body.byteStream();                outputStream = new FileOutputStream(file);                while (true) {                    int read = inputStream.read(fileReader);                    if (read == -1) {                        break;                    }                    outputStream.write(fileReader, 0, read);                    fileSizeDownloaded += read;                    callback.onProcess(fileSizeDownloaded, fileSize);                }                outputStream.flush();                return true;            } catch (IOException e) {                file.delete();                return false;            } finally {                if (inputStream != null) {                    inputStream.close();                }                if (outputStream != null) {                    outputStream.close();                }            }        } catch (IOException e) {            return false;        }    }    /**     *  ApiStroe     */    public interface ApiService {        @Streaming        @GET        Call<ResponseBody> downloadFile(@Url String fileUrl);    }}實現類DemoApi
package com.xinchuang.buynow.util.retrofitUtil.Apis;import com.xinchuang.buynow.model.Owner;import com.xinchuang.buynow.util.retrofitUtil.BaseApi;import retrofit2.Call;import retrofit2.http.GET;import retrofit2.http.Query;/** *   Created by 123 on 2017/2/21. */public class DemoApi extends BaseApi{    private final ShowService showApi;    public DemoApi(String baseUrl) {        super(baseUrl);        showApi = mRetrofit.create(ShowService.class);    }    public void getAnswers(String tags,ApiCallback callback){        Call<Owner> ownerCall = showApi.getAnswers(tags);        ownerCall.enqueue(new RetrofitCallback<Owner>(callback));    }    public static class DemoCallBack implements ApiCallback<Owner>{        @Override        public void onSuccess(Owner ret) {        }        @Override        public void onError(int err_code, String err_msg) {        }        @Override        public void onFailure() {        }    }    public interface ShowService{        @GET("/answers?order=desc&sort=activity&site=stackoverflow")        Call<Owner> getAnswers(@Query("tagged") String tags);    }}在方法里調用
button.setOnClickListener(new View.OnClickListener() {    @Override    public void onClick(View v) {                new DemoApi("https://api.stackexchange.com/2.2/").getAnswers("java", new DemoApi.DemoCallBack(){            @Override            public void onSuccess(Owner ret) {                Toast.makeText(mContext,"success",Toast.LENGTH_LONG).show();            }        });    }});