| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
m45y
9年前发布

android-async-http实现下载和上传

android-async-http,是一个android异步网络数据请求框架,网络处理均基于Android的非UI线程,通过回调方法处理请求结果。本篇简单介绍一下它的用法,分别实现上传和下载文件的功能。

一.android-async-http简介

  1. 开源项目android-async-http地址:
    https://github.com/loopj/android-async-http

  2. android-async-http核心组件:
    a). AsyncHttpResponseHandler ——这是一个请求返回处理,成功,失败,开始,完成,等自定义的消息的类;
    b). BinaryHttpResponseHandler extends AsyncHttpResponseHandler ——继承AsyncHttpResponseHandler的子类,这是一个字节流返回处理的类, 该类用于处理图片等类;
    c). JsonHttpResponseHandler extends AsyncHttpResponseHandler ——继承AsyncHttpResponseHandler的子类,这是一个json请求返回处理服务器与客户端用json交流时使用的类;
    d). AsyncHttpRequest implements Runnable ——基于线程的子类,用于 异步请求类, 通过AsyncHttpResponseHandler回调。
    e). PersistentCookieStore implements CookieStore ——这是一个基于CookieStore的子类, 使用HttpClient处理数据,并且使用cookie持久性存储接口。

    f). RequestParams ——封装了参数处理 例如:

RequestParams params = new RequestParams();  params.put("uid", "00001");  params.put("password", "111111");

核心操作类:
a). RetryHandler implements HttpRequestRetryHandler——这是一个多个线程同步处理的类;
b). SerializableCookie implements Serializable——这是操作cookie 放入/取出数据的类;
c). SimpleMultipartEntity implements HttpEntity——用于处理多个请求实体封装;
d). SyncHttpClient extends AsyncHttpClient——同步客户端请求的类;
e). AsyncHttpClient——异步客户端请求的类。

二.android-async-http实践

  1. HttpClientUtil封装类的实现:
    这个class对AsyncHttpClient进行了封装。
public class HttpClientUtil {      // 实例话对象      private static AsyncHttpClient client = new AsyncHttpClient();      static {            client.setTimeout(11000); // 设置链接超时,如果不设置,默认为10s      }        public static AsyncHttpClient getClient() {          return client;      }        // 用一个完整url获取一个string对象      public static void get(String urlString, AsyncHttpResponseHandler res) {          client.get(urlString, res);      }        // url里面带参数      public static void get(String urlString, RequestParams params,              AsyncHttpResponseHandler res) {          client.get(urlString, params, res);      }        // 不带参数,获取json对象或者数组      public static void get(String urlString, JsonHttpResponseHandler res) {          client.get(urlString, res);      }        // 带参数,获取json对象或者数组      public static void get(String urlString, RequestParams params,              JsonHttpResponseHandler res) {          client.get(urlString, params, res);      }        // 下载数据使用,会返回byte数据      public static void get(String uString, BinaryHttpResponseHandler bHandler) {          client.get(uString, bHandler);      }        //多个url?      public static void get(String urlString, RequestParams params,              BinaryHttpResponseHandler bHandler) {          client.get(urlString, params, bHandler);      }        //post      public static void post(String urlString, RequestParams params,              ResponseHandlerInterface bHandler) {          client.post(urlString, params, bHandler);      }

2. MyImageDownLoader的实现:

提供了下载图片的函数

  public class MyImageDownLoader {        private static final String TAG = "MyImageDownLoader";        Context mContext;        public interface DownLoaderListener {          public void onResult(int res, String s);      }        public MyImageDownLoader() {        }        //download image      public void downloadImage(String uri, String savePath, DownLoaderListener downLoaderListener){            // 指定文件类型            String[] allowedContentTypes = new String[] { "image/png", "image/jpeg" };                HttpClientUtil.get(uri, new ImageResponseHandler(allowedContentTypes,savePath, downLoaderListener));          }            public class ImageResponseHandler extends BinaryHttpResponseHandler{              private String[] allowedContentTypes;              private String savePathString;            DownLoaderListener mDownLoaderListener;              public ImageResponseHandler(String[] allowedContentTypes, String path, DownLoaderListener downLoaderListener){                  super();                  this.allowedContentTypes = allowedContentTypes;                  savePathString = path;                mDownLoaderListener = downLoaderListener;            }              @Override          public void onSuccess(int statusCode, Header[] headers,                  byte[] binaryData) {              Log.i(TAG, " statusCode=========" + statusCode);              Log.i(TAG, " statusCode=========" + headers);              Log.i(TAG, " statusCode====binaryData len=====" + binaryData.length);              if (statusCode == 200 && binaryData!=null && binaryData.length > 0) {                  boolean b = saveImage(binaryData,savePathString);                   if (b) {                        mDownLoaderListener.onResult(0, savePathString);                      }                  else {                      //fail                      mDownLoaderListener.onResult(-1, savePathString);                  }              }          }          @Override          public void onFailure(int statusCode, Header[] headers,                  byte[] binaryData, Throwable error) {              Log.i(TAG, "download failed");          }              private boolean saveImage(byte[] binaryData, String savePath) {              Bitmap bmp = BitmapFactory.decodeByteArray(binaryData, 0,                        binaryData.length);                  Log.i(TAG,"saveImage==========" +  savePath);              File file = new File(savePath);                // 压缩格式                CompressFormat format = Bitmap.CompressFormat.JPEG;                // 压缩比例                int quality = 100;                try {                    if (file.createNewFile()){                      OutputStream stream = new FileOutputStream(file);                        // 压缩输出                        bmp.compress(format, quality, stream);                        stream.close();                        return true;                  }                } catch (IOException e) {                   Log.i(TAG,"saveImage====003======" +  savePath);                  e.printStackTrace();                }                Log.i(TAG,"saveImage====004======" +  savePath);              return false;          }        }    }

3. HttpAsyncUploader的实现:

/**   * 异步上传单个文件   */  public class HttpAsyncUploader {      private static final String TAG = "HttpAsyncUploader";        Context mContext;        public HttpAsyncUploader() {      }        public void uploadFile(String uri, String path) {            File file = new File(path);          RequestParams params = new RequestParams();            try {              params.put("image", file, "application/octet-stream");                AsyncHttpClient client = new AsyncHttpClient();                HttpClientUtil.post(path, params, new AsyncHttpResponseHandler() {                  @Override                  public void onSuccess(int statusCode, Header[] headers,                          byte[] responseBody) {                      Log.i(TAG, " statusCode=========" + statusCode);                      Log.i(TAG, " statusCode=========" + headers);                      Log.i(TAG, " statusCode====binaryData len====="+ responseBody.length);                  }                    @Override                  public void onFailure(int statusCode, Header[] headers,                          byte[] responseBody, Throwable error) {                      Log.i(TAG, " statusCode=========" + statusCode);                      Log.i(TAG, " statusCode=========" + headers);                      Log.i(TAG, " statusCode====binaryData len====="+ responseBody.length);                      Log.i(TAG," statusCode====error====="+ error.getLocalizedMessage());                    }                });            } catch (FileNotFoundException e) {            }      }  }

4. 调用方法:仅以MyImageDownLoader 来举例说明。

1)MyImageDownLoader 测试函数(在activity中实现):

private static String URL_PHOTO = "http://img001.us.expono.com/100001/100001-1bc30-2d736f_m.jpg";  private void downloadTest() {      String url =URL_PHOTO;      String fileName = "" + System.currentTimeMillis() + ".jpg";      String savePath = mContext.getCacheDir() + File.separator + fileName;      MyImageDownLoader mMyImageDownLoader = new MyImageDownLoader();          // 开始异步下载      mMyImageDownLoader.downloadImage(              url,              savePath,              new DownLoaderListener() {                  @Override                  public void onResult(int res, String s) {                      Log.i(TAG,"onResult====res===" + res);                      Log.i(TAG, "onResult====s===" + s);                      if (res == 0) {                          // 下载成功                          Toast.makeText(mContext, "download success!", Toast.LENGTH_LONG).show();                          } else {                              // 下载photo失败                              Toast.makeText(mContext, "download fail!", Toast.LENGTH_LONG).show();                          }                      }                  });      }

5 项目demo地址:

https://github.com/ranke/HttpAsyncTest/tree/master/code/src/com/util/http