本demo主要对异步请求封装 本博客链接地址：http://blog.csdn.net/vpingchangxin/article/details/23375461 可用作基本项目框架来使用 网络请求等等小细节已经ok 如有需要请进一步更改 1）封装HttpClient 2）由于用到线程池，可以进行多任务网络请求操作 3）没有网络的时候进行网络状态检查 4）对请求的数据根据URL进行缓存到本地sqlite数据库中（我刚刚想起了 post请求的时候需要对缓存url及本地数据存取做修改才可以正常用 如果不想进行修改可以用get形式） 5）本demo可以直接运行 本来想测试protobuf进行数据处理的 要放在github上就改成json了（entity中有简单的xml解析：Menu.java 其他的都是json的 json 也可用Gson更方便） 先介绍下流程图 1）主要核心代码 AnsynHttpRequest.java 主要对 http暴露get post 调用方法 在内部中使用ThreadPoolExecutor线程池并开放公共异步方 法进行post、get进行网络请求 [java] view plaincopy /** * * 访问网络初始化函数 支持GET请求方式 * * @param callBack 回调执行函数 支持线程 * @param url 每个执行url * @param map 参数 * @param isCache 是否本地缓存 * @param isShowDialog 是否弹出提示等待框 */ public static void requestByGet(Context context, final ObserverCallBack callBack, int url, Map<String, String> map, boolean isCache, boolean isShowDialog) { //组织URL 及判断网络处理 省略 。。。。 // 异步请求数据 doAsynRequest(GET, null ,context, callBack, requestUrl, isCache, isShowDialog, url); } /** * 异步请求网络数据 * * @param sendType 请求类型 * @param map 参数 * @param context * @param callBack 回调对象 * @param url * @param isCache 是否缓存 * @param isShowDialog 是否有提示框 * @param intUrl */ private static void doAsynRequest(final int sendType, final Map<String, String> map, final Context context, final ObserverCallBack callBack, final String url, final boolean isCache, final boolean isShowDialog, final int intUrl) { if(isShowDialog) ((Activity)context).showDialog(1); // 加载对话框提示等待。。 // 请求 ThreadPoolUtils.execute(new MyRunnable(sendType, map, context, callBack, url, isCache, isShowDialog, intUrl)); } /** * * 访问网络初始化函数 支持Post请求方式 * * @param context * @param http_head 请求头传null或者在C.http类中配置 * @param callBack 回调执行函数 支持线程 * @param url 每个执行url * @param map 参数 * @param isCache 是否本地缓存 * @param isShowDialog 是否弹出提示等待框 */ public static void requestByPost(Context context,String http_head, final ObserverCallBack callBack, int url, Map<String, String> map, boolean isCache, boolean isShowDialog) { //组织URL及判断网络处理 省略 。。。。 // 异步请求数据 doAsynRequest(POST, map ,context, callBack, requestUrl, isCache, isShowDialog, url); } 2）ThreadPoolUtils.java 线程池类在网上找的直接用了 具体不解释了 [java] view plaincopy package com.vic.http.utils; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; /** * 线程池辅助类，整个应用程序就只有一个线程池去管理线程。 可以设置核心线程数、最大线程数、额外线程空状态生存时间，阻塞队列长度来优化线程池。 * 下面的数据都是参考Android的AsynTask里的数据。 * * @author zet * */ public class ThreadPoolUtils { private ThreadPoolUtils() { } // 线程池核心线程数 private static int CORE_POOL_SIZE = 5; // 线程池最大线程数 private static int MAX_POOL_SIZE = 100; // 额外线程空状态生存时间 private static int KEEP_ALIVE_TIME = 10000; // 阻塞队列。当核心线程都被占用，且阻塞队列已满的情况下，才会开启额外线程。 private static BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<Runnable>( 10); // 线程工厂 private static ThreadFactory threadFactory = new ThreadFactory() { private final AtomicInteger integer = new AtomicInteger(); @Override public Thread newThread(Runnable r) { return new Thread(r, "myThreadPool thread:" + integer.getAndIncrement()); } }; // 线程池 private static ThreadPoolExecutor threadPool; static { threadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS, workQueue, threadFactory); } /** * 从线程池中抽取线程，执行指定的Runnable对象 * * @param runnable */ public static void execute(Runnable runnable) { threadPool.execute(runnable); } } 3）在ActivityUI线程中调用方式（可以支持多个url请求同时执行因为异步请求方法中用了线程池进行调度你懂的） [java] view plaincopy // by get map = new HashMap<String, String>(); // map.put("method", "adv_list"); // map.put("regionid", "320200"); AnsynHttpRequest.requestByGet(context, callbackData, C.http.http_adv, map, true, true); // by post map = new HashMap<String, String>(); map = new MapData().addData(map, context); AnsynHttpRequest.requestByPost(context, C.http.http_test_bb,callbackData, C.http.http_area, map, false, false); // http初始化 map = new HashMap<String, String>(); // map.put("method", "businesscategory_list"); AnsynHttpRequest.requestByPost(context, C.http.http_test_cc,callbackData, C.http.http_area, map, false, false); 4）回调函数及handler进行UI线程中更新数据处理 [java] view plaincopy /** * 异步回调回来并处理数据 */ private ObserverCallBack callbackData = new ObserverCallBack(){ public void back(String data, int url) { switch (url) { case C.http.http_area: // 进行数据解析 if(data == null) { return; } try { // Index index = new Index(); // index = index.convertHttpHead(context,data); //// App.index = index; // Log.i(tag, index.toString()); Message msg = new Message(); msg.what = 1; // msg.obj = index; mHandler.sendMessage(msg); } catch (Exception e) { e.printStackTrace(); } break; default: Message msg = new Message(); msg.what = url; mHandler.sendMessage(msg); break; } } }; /** * 处理UI线程中数据 */ private Handler mHandler = new Handler() { public void handleMessage(Message msg) { Intent intent = null; switch (msg.what) { case 1: Toast.makeText(context, "测试数据 数据编号："+msg.what, Toast.LENGTH_SHORT).show(); break; case 2: break; case 3: break; case 4: break; case 5: break; case 6: break; case 7: // setListViewHeightBasedOnChildren(mListView); // setListViewHeightBasedOnChildren(mListView); break; case 8: // Bitmap bmp = (Bitmap)msg.obj; // SendMsg.weixin(context, mCategory, bmp); break; default: Toast.makeText(context, "测试数据 数据编号："+msg.what, Toast.LENGTH_SHORT).show(); break; } }; }; 5）demo 中也有对网络是否通畅进行判断及封装 具体看demo吧 感觉有用的必须顶一下哟 谢谢搜看 好了最后附上代码github链接：https://github.com/pingchangxin/android_http_ansyn_packaging csdn下载链接：http://download.csdn.net/detail/vpingchangxin/7173687