OKHttp封裝

純干貨·~~嘻嘻

stodio 添加上

compile 'com.squareup.okhttp:okhttp:2.4.0'
compile 'com.squareup.okio:okio:1.5.0'

/**
Created by ht on 2016/4/21.

*/

> public class OkHttpClientManager {
private static OkHttpClientManager mInstance;
private OkHttpClient mOkHttpClient;
private Handler mDelivery;
private Gson mGson;


>private static final String TAG = "OkHttpClientManager";

>private OkHttpClientManager()
    {
mOkHttpClient = new OkHttpClient();
//cookie enabled
mOkHttpClient.setCookieHandler(new CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER));
mDelivery = new Handler(Looper.getMainLooper());
mGson = new Gson();
    }

>public static OkHttpClientManager getInstance()
    {
if (mInstance == null)
        {
synchronized (OkHttpClientManager.class)
            {
if (mInstance == null)
                {
mInstance = new OkHttpClientManager();
                }
            }
        }
return mInstance;
    }

/**
     * 同步的Get請求
     *
     * @param url
     * @return Response
     */
>private Response _getAsyn(String url) throws IOException
    {
final Request request = new Request.Builder()
                .url(url)
                .build();
        Call call = mOkHttpClient.newCall(request);
        Response execute = call.execute();
return execute;
    }

/**
     * 同步的Get請求
     *
     * @param url
     * @return 字符串
     */
>private String _getAsString(String url) throws IOException
    {
        Response execute = _getAsyn(url);
return execute.body().string();
    }

/**
      * 異步的get請求
     * @param url
     * @param callback*/
>private void _getAsyn(String url, final ResultCallback callback)
    {
final Request request = new Request.Builder()
                .url(url)
                .build();
        deliveryResult(callback, request);
    }


/**
     * 同步的Post請求
     *
     * @param url
     * @param params post的參數(shù)
     * @return
*/
> private Response _post(String url, Param... params) throws IOException
    {
        Request request = buildPostRequest(url, params);
        Response response = mOkHttpClient.newCall(request).execute();
return response;
    }


/**
     * 同步的Post請求
     *
     * @param url
     * @param params post的參數(shù)
     * @return 字符串
     */
> private String _postAsString(String url, Param... params) throws IOException
    {
        Response response = _post(url, params);
return response.body().string();
    }

/**
     * 異步的post請求
     *
     * @param url
     * @param callback
      * @param params
*/
> private void _postAsyn(String url, final ResultCallback callback, Param... params)
    {
        Request request = buildPostRequest(url, params);
        deliveryResult(callback, request);
    }

/**
     * 異步的post請求
     *
     * @param url
      * @param callback
      * @param params
*/
> private void _postAsyn(String url, final ResultCallback callback, Map<String, String> params)
    {
        Param[] paramsArr = map2Params(params);
        Request request = buildPostRequest(url, paramsArr);
        deliveryResult(callback, request);
    }

/**
     * 同步基于post的文件上傳
     *
     * @param params
     * @return
*/
> private Response _post(String url, File[] files, String[] fileKeys, Param... params) throws IOException
    {
        Request request = buildMultipartFormRequest(url, files, fileKeys, params);
return mOkHttpClient.newCall(request).execute();
    }

> private Response _post(String url, File file, String fileKey) throws IOException
    {
        Request request = buildMultipartFormRequest(url, new File[]{file}, new String[]{fileKey}, null);
return mOkHttpClient.newCall(request).execute();
    }

> private Response _post(String url, File file, String fileKey, Param... params) throws IOException
    {
        Request request = buildMultipartFormRequest(url, new File[]{file}, new String[]{fileKey}, params);
return mOkHttpClient.newCall(request).execute();
    }

/**
     * 異步基于post的文件上傳
     *
     * @param url
     * @param callback
     * @param files
      * @param fileKeys
      * @throws IOException
     */
> private void _postAsyn(String url, ResultCallback callback, File[] files, String[] fileKeys, Param... params) throws IOException
    {
        Request request = buildMultipartFormRequest(url, files, fileKeys, params);
        deliveryResult(callback, request);
    }

/**
     * 異步基于post的文件上傳,單文件不帶參數(shù)上傳
     *
     * @param url
      * @param callback
     * @param file
     * @param fileKey
     * @throws IOException
     */
> private void _postAsyn(String url, ResultCallback callback, File file, String fileKey) throws IOException
    {
        Request request = buildMultipartFormRequest(url, new File[]{file}, new String[]{fileKey}, null);
        deliveryResult(callback, request);
    }

/**
     * 異步基于post的文件上傳,單文件且攜帶其他form參數(shù)上傳
     *
     * @param url
     * @param callback
      * @param file
    * @param fileKey
     * @param params
    * @throws IOException
     */
> private void _postAsyn(String url, ResultCallback callback, File file, String fileKey, Param... params) throws IOException
    {
        Request request = buildMultipartFormRequest(url, new File[]{file}, new String[]{fileKey}, params);
        deliveryResult(callback, request);
    }

/**
     * 異步下載文件
     *
     * @param url
     * @param destFileDir 本地文件存儲的文件夾
     * @param callback
*/
> private void _downloadAsyn(final String url, final String destFileDir, final ResultCallback callback)
    {
final Request request = new Request.Builder()
                .url(url)
                .build();
final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback()
        {
@Override
> public void onFailure(final Request request, final IOException e)
            {
                sendFailedStringCallback(request, e, callback);
            }

> @Override
> public void onResponse(Response response)
            {
                InputStream is = null;
byte[] buf = new byte[2048];
int len = 0;
                FileOutputStream fos = null;
try
{
                    is = response.body().byteStream();
                    File file = new File(destFileDir, getFileName(url));
                    fos = new FileOutputStream(file);
while ((len = is.read(buf)) != -1)
                    {
                        fos.write(buf, 0, len);
                    }
                    fos.flush();
//如果下載文件成功猖任,第一個參數(shù)為文件的絕對路徑
sendSuccessResultCallback(file.getAbsolutePath(), callback);
                } catch (IOException e)
                {
                    sendFailedStringCallback(response.request(), e, callback);
                } finally
{
try
{
if (is != null) is.close();
                    } catch (IOException e)
                    {
                    }
try
{
if (fos != null) fos.close();
                    } catch (IOException e)
                    {
                    }
                }

            }
        });
    }

> private String getFileName(String path)
    {
int separatorIndex = path.lastIndexOf("/");
return (separatorIndex < 0) ? path : path.substring(separatorIndex + 1, path.length());
    }

/**
     * 加載圖片
     *
      @param view
      @param url
      @throws IOException
     */
> private void _displayImage(final ImageView view, final String url, final int errorResId)
    {
final Request request = new Request.Builder()
                .url(url)
                .build();
        Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback()
        {
@Override
> public void onFailure(Request request, IOException e)
            {
                setErrorResId(view, errorResId);
            }

@Override
> public void onResponse(Response response)
            {
                InputStream is = null;
try
{
                    is = response.body().byteStream();
                    ImageUtils.ImageSize actualImageSize = ImageUtils.getImageSize(is);
                    ImageUtils.ImageSize imageViewSize = ImageUtils.getImageViewSize(view);
int inSampleSize = ImageUtils.calculateInSampleSize(actualImageSize, imageViewSize);
try
{
                        is.reset();
                    } catch (IOException e)
                    {
                        response = _getAsyn(url);
                        is = response.body().byteStream();
                    }
 BitmapFactory.Options ops = new BitmapFactory.Options();
                    ops.inJustDecodeBounds = false;
                    ops.inSampleSize = inSampleSize;
final Bitmap bm = BitmapFactory.decodeStream(is, null, ops);
mDelivery.post(new Runnable()
                    {
@Override
> public void run()
                        {
view.setImageBitmap(bm);
                        }
                    });
                } catch (Exception e)
                {
                    setErrorResId(view, errorResId);
                } finally
{
if (is != null) try
{
                        is.close();
                    } catch (IOException e)
                    {
                        e.printStackTrace();
                    }
                }
            }
        });
    }

> private void setErrorResId(final ImageView view, final int errorResId)
    {
mDelivery.post(new Runnable()
        {
@Override
public void run()
            {
view.setImageResource(errorResId);
            }
        });
    }


//*************對外公布的方法******************************************************************************************************************************


> public static Response getAsyn(String url) throws IOException
    {
return getInstance()._getAsyn(url);
    }



> public static String getAsString(String url) throws IOException
    {
return getInstance()._getAsString(url);
    }

> public static void getAsyn(String url, ResultCallback callback)
    {
         getInstance()._getAsyn(url, callback);
    }

> public static Response post(String url, Param... params) throws IOException
    {
return getInstance()._post(url, params);
    }

> public static String postAsString(String url, Param... params) throws IOException
    {
return getInstance()._postAsString(url, params);
    }

> public static void postAsyn(String url, final ResultCallback callback, Param... params)
    {
getInstance()._postAsyn(url, callback, params);
    }


> public static void postAsyn(String url, final ResultCallback callback, Map<String, String> params)
    {
getInstance()._postAsyn(url, callback, params);
    }


> public static Response post(String url, File[] files, String[] fileKeys, Param... params) throws IOException
    {
return getInstance()._post(url, files, fileKeys, params);
    }

> public static Response post(String url, File file, String fileKey) throws IOException
    {
return getInstance()._post(url, file, fileKey);
    }

> public static Response post(String url, File file, String fileKey, Param... params) throws IOException
    {
return getInstance()._post(url, file, fileKey, params);
    }

> public static void postAsyn(String url, ResultCallback callback, File[] files, String[] fileKeys, Param... params) throws IOException
    {
getInstance()._postAsyn(url, callback, files, fileKeys, params);
    }


> public static void postAsyn(String url, ResultCallback callback, File file, String fileKey) throws IOException
    {
getInstance()._postAsyn(url, callback, file, fileKey);
    }


> public static void postAsyn(String url, ResultCallback callback, File file, String fileKey, Param... params) throws IOException
    {
getInstance()._postAsyn(url, callback, file, fileKey, params);
    }

> public static void displayImage(final ImageView view, String url, int errorResId) throws IOException
    {
getInstance()._displayImage(view, url, errorResId);
    }


> public static void displayImage(final ImageView view, String url)
    {
getInstance()._displayImage(view, url, -1);
    }

> public static void downloadAsyn(String url, String destDir, ResultCallback callback)
    {
getInstance()._downloadAsyn(url, destDir, callback);
    }

//****************************


> private Request buildMultipartFormRequest(String url, File[] files, String[] fileKeys, Param[] params) {
        params = validateParam(params);
        MultipartBuilder builder = new MultipartBuilder()
                .type(MultipartBuilder.FORM);
for (Param param : params)
        {
            builder.addPart(Headers.of("Content-Disposition", "form-data; name=\"" + param.key + "\""),
                    RequestBody.create(null, param.value));
        }
if (files != null)
        {
            RequestBody fileBody = null;
for (int i = 0; i < files.length; i++)
            {
                File file = files[i];
                String fileName = file.getName();
                fileBody = RequestBody.create(MediaType.parse(guessMimeType(fileName)), file);
//TODO 根據(jù)文件名設(shè)置contentType
builder.addPart(Headers.of("Content-Disposition",
"form-data; name=\"" + fileKeys[i] + "\"; filename=\"" + fileName + "\""),
                        fileBody);
            }
        }
        RequestBody requestBody = builder.build();
return new Request.Builder()
                .url(url)
                .post(requestBody)
                .build();
    }

> private String guessMimeType(String path)
    {
        FileNameMap fileNameMap = URLConnection.getFileNameMap();
        String contentTypeFor = fileNameMap.getContentTypeFor(path);
if (contentTypeFor == null)
        {
            contentTypeFor = "application/octet-stream";
        }
return contentTypeFor;
    }
> private Param[] validateParam(Param[] params)
    {
if (params == null)
return new Param[0];
else return params;
    }

> private Param[] map2Params(Map<String, String> params)
    {
if (params == null) return new Param[0];
int size = params.size();
        Param[] res = new Param[size];
        Set<Map.Entry<String, String>> entries = params.entrySet();
int i = 0;
for (Map.Entry<String, String> entry : entries)
        {
            res[i++] = new Param(entry.getKey(), entry.getValue());
        }
return res;
    }

> private static final String SESSION_KEY = "Set-Cookie";
> private static final String mSessionKey = "JSESSIONID";

> private Map<String, String> mSessions = new HashMap<String, String>();

> private void deliveryResult(final ResultCallback callback, Request request)
    {
mOkHttpClient.newCall(request).enqueue(new Callback()
        {
@Override
> public void onFailure(final Request request, final IOException e)
            {
                sendFailedStringCallback(request, e, callback);
            }

@Override

 public void onResponse(final Response response)
            {
try
{
final String string = response.body().string();
if (callback.mType == String.class)
                    {
                        sendSuccessResultCallback(string, callback);
                    } else
{
                        Object o = mGson.fromJson(string, callback.mType);
                        sendSuccessResultCallback(o, callback);
                    }
                } catch (IOException e)
                {
                    sendFailedStringCallback(response.request(), e, callback);
                } catch (com.google.gson.JsonParseException e)//Json解析的錯誤
{
                    sendFailedStringCallback(response.request(), e, callback);
                }
            }
        });
    }


> private void sendFailedStringCallback(final Request request, final Exception e, final ResultCallback callback)
    {
mDelivery.post(new Runnable()
        {
@Override
> public void run()
            {
if (callback != null)
callback.onError(request, e);
            }
        });
    }

> private void sendSuccessResultCallback(final Object object, final ResultCallback callback)
    {
mDelivery.post(new Runnable()
        {
@Override
> public void run()
            {
if (callback != null)
                {
callback.onResponse(object);
                }
            }
        });
    }

> private Request buildPostRequest(String url, Param[] params)
    {
if (params == null)
        {
            params = new Param[0];
        }
        FormEncodingBuilder builder = new FormEncodingBuilder();
for (Param param : params)
        {
            builder.add(param.key, param.value);
        }
        RequestBody requestBody = builder.build();
return new Request.Builder()
                .url(url)
                .post(requestBody)
                .build();
    }


> public static abstract class ResultCallback<T>
    {
        Type mType;

> public ResultCallback()
        {
mType = getSuperclassTypeParameter(getClass());
        }
> static Type getSuperclassTypeParameter(Class<?> subclass)
        {
            Type superclass = subclass.getGenericSuperclass();
if (superclass instanceof Class)
            {
throw new RuntimeException("Missing type parameter.");
            }
            ParameterizedType parameterized = (ParameterizedType) superclass;
return $Gson$Types.canonicalize(parameterized.getActualTypeArguments()[0]); }
> public abstract void onError(Request request, Exception e);
public abstract void onResponse(T response);
    }
public static class Param
    {
public Param()
        {
        }
> public Param(String key, String value)
        {
this.key = key;
this.value = value;
        }
        String key;
        String value;
    }
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末速址,一起剝皮案震驚了整個濱河市洋满,隨后出現(xiàn)的幾起案子踩身,更是在濱河造成了極大的恐慌稍浆,老刑警劉巖,帶你破解...
    沈念sama閱讀 218,451評論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件试和,死亡現(xiàn)場離奇詭異讯泣,居然都是意外死亡,警方通過查閱死者的電腦和手機灰署,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,172評論 3 394
  • 文/潘曉璐 我一進店門判帮,熙熙樓的掌柜王于貴愁眉苦臉地迎上來局嘁,“玉大人溉箕,你說我怎么就攤上這事晦墙。” “怎么了肴茄?”我有些...
    開封第一講書人閱讀 164,782評論 0 354
  • 文/不壞的土叔 我叫張陵晌畅,是天一觀的道長。 經(jīng)常有香客問我寡痰,道長抗楔,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,709評論 1 294
  • 正文 為了忘掉前任拦坠,我火速辦了婚禮连躏,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘贞滨。我一直安慰自己入热,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 67,733評論 6 392
  • 文/花漫 我一把揭開白布晓铆。 她就那樣靜靜地躺著勺良,像睡著了一般。 火紅的嫁衣襯著肌膚如雪骄噪。 梳的紋絲不亂的頭發(fā)上尚困,一...
    開封第一講書人閱讀 51,578評論 1 305
  • 那天,我揣著相機與錄音链蕊,去河邊找鬼事甜。 笑死,一個胖子當(dāng)著我的面吹牛滔韵,可吹牛的內(nèi)容都是我干的讳侨。 我是一名探鬼主播,決...
    沈念sama閱讀 40,320評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼奏属,長吁一口氣:“原來是場噩夢啊……” “哼跨跨!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起囱皿,我...
    開封第一講書人閱讀 39,241評論 0 276
  • 序言:老撾萬榮一對情侶失蹤勇婴,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后嘱腥,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體耕渴,經(jīng)...
    沈念sama閱讀 45,686評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,878評論 3 336
  • 正文 我和宋清朗相戀三年齿兔,在試婚紗的時候發(fā)現(xiàn)自己被綠了橱脸。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片础米。...
    茶點故事閱讀 39,992評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖添诉,靈堂內(nèi)的尸體忽然破棺而出屁桑,到底是詐尸還是另有隱情,我是刑警寧澤栏赴,帶...
    沈念sama閱讀 35,715評論 5 346
  • 正文 年R本政府宣布蘑斧,位于F島的核電站,受9級特大地震影響须眷,放射性物質(zhì)發(fā)生泄漏竖瘾。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,336評論 3 330
  • 文/蒙蒙 一花颗、第九天 我趴在偏房一處隱蔽的房頂上張望捕传。 院中可真熱鬧,春花似錦扩劝、人聲如沸庸论。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,912評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽葡公。三九已至,卻和暖如春条霜,著一層夾襖步出監(jiān)牢的瞬間催什,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,040評論 1 270
  • 我被黑心中介騙來泰國打工宰睡, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留蒲凶,地道東北人。 一個月前我還...
    沈念sama閱讀 48,173評論 3 370
  • 正文 我出身青樓拆内,卻偏偏與公主長得像旋圆,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子麸恍,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 44,947評論 2 355

推薦閱讀更多精彩內(nèi)容