Android开源-对Okhttp3进行二次封装

LucienneCra 8年前
   <p>对Okhttp3进行二次封装,对外提供了POST请求、GET请求、PATCH请求、PUT请求、DELETE请求、上传文件、下载文件、取消请求、Raw/Json/Gson返回、后台下载管理等功能</p>    <h2>1 前言</h2>    <p>之前的一篇文章 Android架构系列-封装自己的okhttp 对okhttp进行了一个简单的封装,具有POST、GET、上传下载功能和JSON、GSON格式返回。</p>    <p>升级版MyOkHttp进行了重构并增加许多功能点,如下</p>    <ol>     <li>所有请求全部优化为了Builder模式传参(方便参数扩展)</li>     <li>请求增加addHeader可以添加请求头</li>     <li>增加PATCH、PUT、DELETE请求方法</li>     <li>增加下载管理后台,包括断点续传、下载队列管理功能等</li>    </ol>    <h2>2 使用说明</h2>    <h3>2.1 创建MyOkHttp</h3>    <p>在项目入口创建唯一MyOkhttp实例</p>    <pre>  <code class="language-java">MyOkHttp mMyOkhttp = new MyOkHttp();</code></pre>    <p>也可以自行配置OkhttpClient.</p>    <pre>  <code class="language-java">OkHttpClient okHttpClient = new OkHttpClient.Builder()                    .connectTimeout(10000L, TimeUnit.MILLISECONDS)                    .readTimeout(10000L, TimeUnit.MILLISECONDS)                    //其他配置                   .build();    MyOkHttp mMyOkhttp = new MyOkHttp(okHttpClient);</code></pre>    <h3>2.2 调用方式</h3>    <p>整个调用采用链式调用的方式. 方便以后扩展.</p>    <h3>2.3 请求类型</h3>    <p>现在有Get, Post, Patch, Put, Delete, Upload, Download 这些请求方式</p>    <h3>2.4 添加参数方式</h3>    <p>添加参数可以使用addParam一个个添加, 也可以使用params一次性添加</p>    <h3>2.5 添加Header方式</h3>    <p>添加参数可以使用addHeader一个个添加, 也可以使用headers一次性添加</p>    <h3>2.6 回调格式</h3>    <p>现在回调格式有以下几种:</p>    <ol>     <li>Raw原生数据 RawResponseHandler</li>     <li>Json JsonResponseHandler</li>     <li>Gson GsonResponseHandler</li>    </ol>    <h3>2.7 调用示例</h3>    <p>2.7.1 POST请求 + Json回调示例</p>    <pre>  <code class="language-java">String url = "http://192.168.2.135/myokhttp/post.php";    Map<String, String> params = new HashMap<>();  params.put("name", "tsy");  params.put("age", "24");    mMyOkhttp.post()          .url(url)          .params(params)          .tag(this)          .enqueue(new JsonResponseHandler() {              @Override              public void onSuccess(int statusCode, JSONObject response) {                  Log.d(TAG, "doPost onSuccess:" + response);              }                @Override              public void onFailure(int statusCode, String error_msg) {                  Log.d(TAG, "doPost onFailure:" + error_msg);              }          });</code></pre>    <p>2.7.2 GET请求 + Raw回调示例</p>    <pre>  <code class="language-java">String url = "http://192.168.2.135/myokhttp/get.php";    mMyOkhttp.get()          .url(url)          .addParam("name", "tsy")          .addParam("id", "5")          .tag(this)          .enqueue(new RawResponseHandler() {              @Override              public void onSuccess(int statusCode, String response) {                  Log.d(TAG, "doGet onSuccess:" + response);              }                @Override              public void onFailure(int statusCode, String error_msg) {                  Log.d(TAG, "doGet onFailure:" + error_msg);              }          });</code></pre>    <p>2.7.3 Patch请求 + Json回调示例</p>    <pre>  <code class="language-java">String url = "http://192.168.2.135/myokhttp/patch.php/id/5/name/tsy";    mMyOkhttp.patch()          .url(url)          .tag(this)          .enqueue(new JsonResponseHandler() {              @Override              public void onSuccess(int statusCode, JSONObject response) {                  Log.d(TAG, "doPatch onSuccess:" + response);              }                @Override              public void onFailure(int statusCode, String error_msg) {                  Log.d(TAG, "doPatch onFailure:" + error_msg);              }          });</code></pre>    <p>2.7.4 上传文件 + Gson回调示例</p>    <pre>  <code class="language-java">String url = "http://192.168.2.135/myokhttp/upload.php";    mMyOkhttp.upload()          .url(url)          .addParam("name", "tsy")          .addFile("avatar",                  new File(Environment.getExternalStorageDirectory()                          + "/ahome/sasas.jpg"))        //上传已经存在的File  //                .addFile("avatar2", "asdsda.png", byteContents)    //直接上传File bytes          .tag(this)          .enqueue(new GsonResponseHandler<UploadModel>() {              @Override              public void onFailure(int statusCode, String error_msg) {                  Log.d(TAG, "doUpload onFailure:" + error_msg);              }                @Override              public void onProgress(long currentBytes, long totalBytes) {                  Log.d(TAG, "doUpload onProgress:" + currentBytes + "/" + totalBytes);              }                @Override              public void onSuccess(int statusCode, UploadModel response) {                  Log.d(TAG, "doUpload onSuccess:" + response.ret + " " + response.msg);              }          });</code></pre>    <p>2.7.5 下载文件</p>    <pre>  <code class="language-java">String url = "http://192.168.2.135/myokhttp/head.jpg";    mMyOkhttp.download()          .url(url)          .filePath(Environment.getExternalStorageDirectory() + "/ahome/a.jpg")          .tag(this)          .enqueue(new DownloadResponseHandler() {              @Override              public void onStart(long totalBytes) {                  Log.d(TAG, "doDownload onStart");              }                @Override              public void onFinish(File downloadFile) {                  Log.d(TAG, "doDownload onFinish:");              }                @Override              public void onProgress(long currentBytes, long totalBytes) {                  Log.d(TAG, "doDownload onProgress:" + currentBytes + "/" + totalBytes);              }                @Override              public void onFailure(String error_msg) {                  Log.d(TAG, "doDownload onFailure:" + error_msg);              }          });</code></pre>    <h3>2.8 取消请求(建议放在BaseActivity,BaseFragment的onDestroy中)</h3>    <pre>  <code class="language-java">mMyOkhttp.cancel(this);     //tag 即之前请求时传入的tag 建议直接将页面作为object传入</code></pre>    <h3>2.9 下载管理</h3>    <p>实现了下载管理的核心逻辑,包括添加下载任务、开始任务、暂停任务、删除任务、任务下载等待、下载进度和状态监听等功能。依赖于MyOkhttp</p>    <p>2.9.1 实现AbstractDownloadMgr</p>    <p>项目中创建DownloadMgr继承AbstractDownloadMgr,并实现下载任务的状态,进度的本地持久化保存。(AbstractDownloadMgr只负责在内存中存储所有任务,</p>    <p>需要项目自行实现本地持续化存储,重新进入App后的任务恢复等)</p>    <p>示例:</p>    <pre>  <code class="language-java">/**   * 实现下载管理 AbstractDownloadMgr   * Created by tsy on 2016/11/24.   */    public class DownloadMgr extends AbstractDownloadMgr {        private DownloadMgr(Builder builder) {          super(builder);      }        /**       * 初始进入app 恢复所有未完成的任务       */      @Override      public void resumeTasks() {          if(DEBUG) {              Log.i(TAG, "start resumeTasks");          }            //获取所有未完成的任务(已完成的不需要添加)          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          ArrayList<Task> tasks = downloadInteractor.parseTask(downloadInteractor.getAllUnfinishedDownloadTasks());            //将任务加到下载管理队列中          if(tasks != null && tasks.size() > 0) {              for(int i = 0; i < tasks.size(); i ++) {                  Task task = tasks.get(i);                  task.setDefaultStatus(DEFAULT_TASK_STATUS_PAUSE);       //所有任务初始设置为暂停                  addTask(tasks.get(i));              }                downloadInteractor.pauseAllTask();          }      }        /**       * 保存进度       * @param taskId taskId       * @param currentBytes 已经下载的bytes       * @param totalBytes 总共bytes       */      @Override      protected void saveProgress(String taskId, long currentBytes, long totalBytes) {          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          downloadInteractor.updateProgress(taskId, currentBytes, totalBytes);      }        /**       * 下载任务开始       * @param taskId task id       */      @Override      protected void onTaskStart(String taskId) {          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          downloadInteractor.startTask(taskId);      }        /**       * 下载任务暂停       * @param taskId task id       */      @Override      protected void onTaskPause(String taskId) {          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          downloadInteractor.pauseTask(taskId);      }        /**       * 下载任务完成       * @param taskId task id       */      @Override      protected void onTaskFinish(String taskId) {          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          downloadInteractor.finishTask(taskId);      }        /**       * 下载任务失败       * @param taskId task id       */      @Override      protected void onTaskFail(String taskId) {          //失败设置为暂停 允许用户再次尝试开始          DownloadContract.Interactor downloadInteractor = new DownloadInteractor();          downloadInteractor.pauseTask(taskId);      }        //实现Builder      public static class Builder extends AbstractDownloadMgr.Builder {            @Override          public AbstractDownloadMgr build() {              return new DownloadMgr(this);          }      }  }</code></pre>    <p>2.9.2 项目开始时初始化唯一实例DownloadMgr 并自定义配置</p>    <pre>  <code class="language-java">mDownloadMgr = (DownloadMgr) new DownloadMgr.Builder()                  .myOkHttp(mMyOkhttp)                  .maxDownloadIngNum(5)       //设置最大同时下载数量(不设置默认5)                  .saveProgressBytes(50 * 1024)  //设置每50kb触发一次saveProgress保存进度 (不能在onProgress每次都保存 过于频繁) 不设置默认50kb                  .build();</code></pre>    <p>2.9.3 恢复本地存储的所有未完成的任务</p>    <pre>  <code class="language-java">mDownloadMgr.resumeTasks();</code></pre>    <p>2.9.4 创建一个下载任务</p>    <pre>  <code class="language-java">DownloadMgr.Task task = new DownloadMgr.Task();  task.setTaskId(mDownloadMgr.genTaskId());       //生成一个taskId  task.setUrl("xxxxx");   //下载地址  task.setFilePath("xxxxxxx");    //下载后文件保存位置  task.setCompleteBytes(1234L);       //设置已完成的bytes (用于恢复任务时添加,如果新添加的任务不需要设置该字段)  task.setDefaultStatus(DownloadMgr.DEFAULT_TASK_STATUS_START);       //任务添加后开始状态 如果不设置 默认任务添加后就自动开始    mDownloadMgr.addTask(task);</code></pre>    <p>2.9.5 开始 暂停任务</p>    <pre>  <code class="language-java">mDownloadMgr.startTask("taskId");    mDownloadMgr.pauseTask("taskId");</code></pre>    <p>2.9.6 页面添加下载监听</p>    <p>PS:不要使用匿名类,会造成内存泄露。在onStart或者onResume时初始化监听,在onStop或者onPause时销毁监听</p>    <pre>  <code class="language-java">@Override  public void onResume() {      super.onResume();        //每次显示页面的时候加上监听      mDownloadTaskListener = new DownloadTaskListener() {          @Override          public void onStart(String taskId, long completeBytes, long totalBytes) {              //开始下载          }            @Override          public void onProgress(String taskId, long currentBytes, long totalBytes) {              //下载进度                //建议使用handler延迟刷新下载进度 不然过于频繁刷新              if(!mMyHandler.hasMessages(MSG_DELAY_NOTIFICAION)) {                  Message message = new Message();                  message.what = MSG_DELAY_NOTIFICAION;                  mMyHandler.sendMessageDelayed(message, 300);              }          }            @Override          public void onPause(String taskId, long currentBytes, long totalBytes) {              //下载暂停          }            @Override          public void onFinish(String taskId, File file) {              //下载完成          }            @Override          public void onFailure(String taskId, String error_msg) {              //下载失败          }      };        //加入监听      mDownloadMgr.addListener(mDownloadTaskListener);  }    @Override  public void onPause() {        //释放监听 防止内存泄露      mDownloadMgr.removeListener(mDownloadTaskListener);      mDownloadTaskListener = null;        super.onPause();  }</code></pre>    <p> </p>    <p> </p>    <p> </p>