diff --git a/app/src/main/java/com/github/why168/androidhttputils/HomeActivity.java b/app/src/main/java/com/github/why168/androidhttputils/HomeActivity.java
index 8281f95..4876ba0 100644
--- a/app/src/main/java/com/github/why168/androidhttputils/HomeActivity.java
+++ b/app/src/main/java/com/github/why168/androidhttputils/HomeActivity.java
@@ -35,7 +35,7 @@
 
 public class HomeActivity extends AppCompatActivity {
     private TextView tv_text;
-    private HttpUtils goHttp;
+    private HttpUtils androidHttp;
     private ImageView image;
 
     // 魂斗罗下载 http://124.193.230.12/imtt.dd.qq.com/16891/A1BFDC1BD905CEF01F3076509F920FD3.apk?mkey=59424b6446b6ee89&f=ae12&c=0&fsname=com.tencent.shootgame_1.2.33.7260_337260.apk&csr=1bbd&p=.apk
@@ -47,7 +47,7 @@ protected void onCreate(Bundle savedInstanceState) {
         setContentView(R.layout.activity_home);
         tv_text = (TextView) findViewById(R.id.tv_text);
         image = (ImageView) findViewById(R.id.image);
-        goHttp = new HttpUtils();
+        androidHttp = new HttpUtils();
 
     }
 
@@ -63,7 +63,7 @@ public void onGetJSONObject() {
                 .headers(headers)
                 .build();
 
-        Call call = goHttp.newCall(request);
+        Call call = androidHttp.newCall(request);
         call.enqueue(new JsonCallback() {
             @Override
             public void onFailure(Exception e) {
@@ -105,10 +105,10 @@ public void postHttp() {
                 .url("http://dev.xiaobee1.com/api/verification/")
                 .method("POST")
                 .headers(headers)
-                .bodys(body.getBytes())
+                .body(body.getBytes())
                 .build();
 
-        Call call = goHttp.newCall(request);
+        Call call = androidHttp.newCall(request);
         call.enqueue(new StringCallback() {
             @Override
             public void onFailure(Exception e) {
@@ -138,13 +138,14 @@ public void getFileHttp() {
                 .url("http://124.193.230.12/imtt.dd.qq.com/16891/3EC8D23CFE6DC65DCA209E5E732ADE93.apk?mkey=5947105e46b6ee89&f=6e20&c=0&fsname=com.u17.comic.phone_3.3.2.1_3320100.apk&csr=1bbd&p=.apk")
                 .method("GET")
                 .headers(headers)
+                .tag("tagNameA")
                 .build();
 
 
         String path = Environment.getExternalStorageDirectory().getAbsolutePath();
 
-        Call call = goHttp.newCall(request);
-        call.enqueue(new FileCallback(path, System.currentTimeMillis() + ".apk") {
+        Call call = androidHttp.newCall(request);
+        call.enqueue(new FileCallback(path, System.currentTimeMillis() + "A.apk") {
             @Override
             public void onFailure(Exception e) {
                 Log.e("Edwin", e.toString());
@@ -152,7 +153,7 @@ public void onFailure(Exception e) {
 
             @Override
             public void onSuccessful(Response response, File results) throws IOException {
-                Log.e("Edwin",response.toString());
+                Log.e("Edwin", response.toString());
 
                 Log.e("Edwin", results.getAbsolutePath());
 
@@ -164,6 +165,31 @@ public void onProgress(long progress, long total) {
             }
         });
 
+        request = new Request.Builder()
+                .url("http://124.193.230.12/imtt.dd.qq.com/16891/3EC8D23CFE6DC65DCA209E5E732ADE93.apk?mkey=5947105e46b6ee89&f=6e20&c=0&fsname=com.u17.comic.phone_3.3.2.1_3320100.apk&csr=1bbd&p=.apk")
+                .method("GET")
+                .headers(headers)
+                .tag("tagNameB")
+                .build();
+
+        androidHttp.newCall(request).enqueue(new FileCallback(path, System.currentTimeMillis() + "B.apk") {
+            @Override
+            public void onFailure(Exception e) {
+                Log.e("Edwin", "B------------- " + e.toString());
+            }
+
+            @Override
+            public void onSuccessful(Response response, File results) throws IOException {
+                Log.e("Edwin", "B------------- " + response.toString());
+
+                Log.e("Edwin", "B------------- " + results.getAbsolutePath());
+            }
+
+            @Override
+            public void onProgress(long progress, long total) {
+                Log.e("Edwin", "B------------- progress = " + progress + " total = " + total);
+            }
+        });
     }
 
     public void onGetBitmap() {
@@ -178,7 +204,7 @@ public void onGetBitmap() {
                 .headers(headers)
                 .build();
 
-        Call call = goHttp.newCall(request);
+        Call call = androidHttp.newCall(request);
         call.enqueue(new BitmapCallback() {
             @Override
             public void onFailure(Exception e) {
@@ -208,7 +234,18 @@ public void onGetFile(View view) {
 
     public void onStop(View view) {
         Log.e("Edwin", "onStop");
-        goHttp.getDispatcher().cancelAll();
+        androidHttp.getDispatcher().cancelAll();
+    }
+
+    public void onStopA(View view) {
+        Log.e("Edwin", "onStopA");
+        androidHttp.getDispatcher().cancelWithTAG("tagNameA");
+
+    }
+
+    public void onStopB(View view) {
+        Log.e("Edwin", "onStopB");
+        androidHttp.getDispatcher().cancelWithTAG("tagNameB");
 
     }
 
diff --git a/app/src/main/res/layout/activity_home.xml b/app/src/main/res/layout/activity_home.xml
index 59be5b8..7db305c 100644
--- a/app/src/main/res/layout/activity_home.xml
+++ b/app/src/main/res/layout/activity_home.xml
@@ -16,6 +16,7 @@
             android:layout_height="wrap_content"
             android:text="Hello World!" />
     </ScrollView>
+
     <ImageView
         android:id="@+id/image"
         android:layout_width="wrap_content"
@@ -45,6 +46,17 @@
         android:onClick="onStop"
         android:text="取消所有请求" />
 
+    <Button
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:onClick="onStopA"
+        android:text="取消A请求" />
+
+    <Button
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:onClick="onStopB"
+        android:text="取消B请求" />
 
     <Button
         android:layout_width="wrap_content"
diff --git a/http-library/src/main/java/com/github/why168/http/BitmapCallback.java b/http-library/src/main/java/com/github/why168/http/BitmapCallback.java
index 1a380e9..b2da891 100644
--- a/http-library/src/main/java/com/github/why168/http/BitmapCallback.java
+++ b/http-library/src/main/java/com/github/why168/http/BitmapCallback.java
@@ -3,6 +3,8 @@
 import android.graphics.Bitmap;
 import android.graphics.BitmapFactory;
 
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
@@ -15,7 +17,20 @@
 public abstract class BitmapCallback extends Callback<Bitmap> {
     @Override
     public Bitmap parseNetworkResponse(Response response, AtomicBoolean isCancelled) throws Exception {
-        byte[] body = response.getBody();
+        InputStream is = response.getInputStream();
+        ByteArrayOutputStream out = new ByteArrayOutputStream(2048);
+        byte[] buffer = new byte[2048];
+        int len = 0;
+        while ((len = is.read(buffer)) != -1) {
+            if (isCancelled.get()) {
+                throw new RuntimeException("http cancel");
+            }
+            out.write(buffer, 0, len);
+        }
+        out.flush();
+        is.close();
+        out.close();
+        byte[] body = out.toByteArray();
         return BitmapFactory.decodeByteArray(body, 0, body.length);
     }
 
diff --git a/http-library/src/main/java/com/github/why168/http/HttpDispatcher.java b/http-library/src/main/java/com/github/why168/http/HttpDispatcher.java
index 170df3e..c4ea9ae 100644
--- a/http-library/src/main/java/com/github/why168/http/HttpDispatcher.java
+++ b/http-library/src/main/java/com/github/why168/http/HttpDispatcher.java
@@ -70,6 +70,20 @@ public synchronized int queuedCallsCount() {
         return readyAsyncCalls.size();
     }
 
+    public synchronized void cancelWithTAG(String tag) {
+        for (RealCall.AsyncCall call : readyAsyncCalls) {
+            if (tag.equalsIgnoreCase(call.name)) {
+                call.cancel();
+                break;
+            }
+        }
+        for (RealCall.AsyncCall call : runningAsyncCalls) {
+            if (tag.equalsIgnoreCase(call.name)) {
+                call.cancel();
+            }
+        }
+    }
+
     public synchronized void cancelAll() {
         for (RealCall.AsyncCall call : readyAsyncCalls) {
             call.cancel();
diff --git a/http-library/src/main/java/com/github/why168/http/JsonCallback.java b/http-library/src/main/java/com/github/why168/http/JsonCallback.java
index 4e53ab1..a8d91dc 100644
--- a/http-library/src/main/java/com/github/why168/http/JsonCallback.java
+++ b/http-library/src/main/java/com/github/why168/http/JsonCallback.java
@@ -2,6 +2,8 @@
 
 import org.json.JSONObject;
 
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
@@ -15,7 +17,19 @@ public abstract class JsonCallback extends Callback<JSONObject> {
 
     @Override
     public JSONObject parseNetworkResponse(Response response, AtomicBoolean isCancelled) throws Exception {
-        String results = new String(response.getBody());
-        return new JSONObject(results);
+        InputStream is = response.getInputStream();
+        ByteArrayOutputStream out = new ByteArrayOutputStream(2048);
+        byte[] buffer = new byte[2048];
+        int len = 0;
+        while ((len = is.read(buffer)) != -1) {
+            if (isCancelled.get()) {
+                throw new RuntimeException("http cancel");
+            }
+            out.write(buffer, 0, len);
+        }
+        out.flush();
+        is.close();
+        out.close();
+        return new JSONObject(new String(out.toByteArray()));
     }
 }
diff --git a/http-library/src/main/java/com/github/why168/http/RealCall.java b/http-library/src/main/java/com/github/why168/http/RealCall.java
index ee12ff6..1b1a040 100644
--- a/http-library/src/main/java/com/github/why168/http/RealCall.java
+++ b/http-library/src/main/java/com/github/why168/http/RealCall.java
@@ -7,7 +7,6 @@
 import com.github.why168.http.code.HandlerExecutor;
 import com.github.why168.http.util.StringUtils;
 
-import java.io.ByteArrayOutputStream;
 import java.io.DataOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
@@ -51,7 +50,12 @@ public Request request() {
 
     @Override
     public void enqueue(Callback responseCallback) {
-        client.getDispatcher().enqueue(new AsyncCall(responseCallback));
+        String tag = request.getTag();
+        if (TextUtils.isEmpty(tag)) {
+            client.getDispatcher().enqueue(new AsyncCall(responseCallback));
+        } else {
+            client.getDispatcher().enqueue(new AsyncCall(responseCallback, tag));
+        }
     }
 
     @Override
@@ -86,6 +90,11 @@ private AsyncCall(Callback responseCallback) {
             this.responseCallback = responseCallback;
         }
 
+        private AsyncCall(Callback responseCallback, String name) {
+            super(name);
+            this.responseCallback = responseCallback;
+        }
+
         RealCall get() {
             return RealCall.this;
         }
@@ -111,11 +120,9 @@ protected void execute() {
         }
 
         private void postHttpRequest(Request request, HttpUtils httpUtils) {
-
             HttpURLConnection connection = null;
             InputStream is = null;
             DataOutputStream dataOut = null;
-            ByteArrayOutputStream out = null;
             try {
                 checkIfCancelled();
 
@@ -132,7 +139,6 @@ private void postHttpRequest(Request request, HttpUtils httpUtils) {
                 dataOut = new DataOutputStream(connection.getOutputStream());
                 byte[] body = request.getBody();
                 if (body != null) {
-
                     checkIfCancelled();
 
                     dataOut.write(body);
@@ -146,7 +152,7 @@ private void postHttpRequest(Request request, HttpUtils httpUtils) {
                     throw new IOException("Could not retrieve response code from HttpUrlConnection.");
                 }
 
-                if (responseCode >= 200 && responseCode <= 300) {
+                if (responseCode >= 200 && responseCode < 300) {
                     // Log
                     Log.e("Edwin", "responseCode = " + responseCode + "\n" +
                             "contentLength = " + StringUtils.getPrintSize(connection.getContentLength()) + "\n" +
@@ -169,19 +175,7 @@ private void postHttpRequest(Request request, HttpUtils httpUtils) {
 
                     checkIfCancelled();
 
-                    out = new ByteArrayOutputStream(2048);
-                    byte[] buffer = new byte[2048];
-                    int len;
-                    while ((len = is.read(buffer)) != -1) {
-
-                        checkIfCancelled();
-
-                        out.write(buffer, 0, len);
-                        out.flush();
-                    }
-
                     Map<String, String> headers = new HashMap<>();
-
                     Map<String, List<String>> headerFields = connection.getHeaderFields();
                     for (Map.Entry<String, List<String>> entry : headerFields.entrySet()) {
                         String key = entry.getKey();
@@ -195,7 +189,6 @@ private void postHttpRequest(Request request, HttpUtils httpUtils) {
                     final Response response = new Response.Builder()
                             .request(request)
                             .inputStream(is)
-                            .body(out.toByteArray())
                             .code(responseCode)
                             .header(headers)
                             .message("成功:" + connection.getResponseMessage())
@@ -236,8 +229,6 @@ public void run() {
                         dataOut.close();
                     if (is != null)
                         is.close();
-                    if (out != null)
-                        out.close();
                 } catch (Exception e) {
                     e.printStackTrace();
                 } finally {
@@ -251,7 +242,6 @@ public void run() {
         private void getHttpRequest(Request request, HttpUtils httpUtils) {
             HttpURLConnection connection = null;
             InputStream is = null;
-            ByteArrayOutputStream out = null;
             try {
 
                 checkIfCancelled();
@@ -273,7 +263,7 @@ private void getHttpRequest(Request request, HttpUtils httpUtils) {
                     throw new IOException("Could not retrieve response code from HttpUrlConnection.");
                 }
 
-                if (responseCode >= 200 && responseCode <= 300) {
+                if (responseCode >= 200 && responseCode < 300) {
 
                     // Log
                     Log.e("Edwin", "responseCode = " + responseCode + "\n" +
@@ -297,30 +287,6 @@ private void getHttpRequest(Request request, HttpUtils httpUtils) {
 
                     checkIfCancelled();
 
-//                    out = new ByteArrayOutputStream(2048);
-//                    byte[] buffer = new byte[2048];
-//                    int len = 0;
-//                    long sum = 0;
-//                    while ((len = is.read(buffer)) != -1) {
-//
-//                        if (isCancelled.get())
-//                            return;
-//
-//                        final long finalSum = sum;
-//                        final HttpURLConnection finalConnection = connection;
-//
-//                        HandlerExecutor.getInstance().execute(new Runnable() {
-//                            @Override
-//                            public void run() {
-//                                responseCallback.onProgress(finalSum, finalConnection.getContentLength());
-//                            }
-//                        });
-//
-//
-//                        out.write(buffer, 0, len);
-//                    }
-//                    out.flush();
-
                     Map<String, String> headers = new HashMap<>();
 
                     Map<String, List<String>> headerFields = connection.getHeaderFields();
@@ -337,13 +303,12 @@ private void getHttpRequest(Request request, HttpUtils httpUtils) {
                             .request(request)
                             .lenght(connection.getContentLength())
                             .inputStream(is)
-//                            .body(out.toByteArray())
                             .code(responseCode)
                             .header(headers)
                             .message("成功:" + connection.getResponseMessage())
                             .build();
 
-                    final Object o = responseCallback.parseNetworkResponse(response,isCancelled);
+                    final Object o = responseCallback.parseNetworkResponse(response, isCancelled);
 
                     HandlerExecutor.getInstance().execute(new Runnable() {
                         @Override
@@ -369,8 +334,6 @@ public void run() {
                 try {
                     if (is != null)
                         is.close();
-                    if (out != null)
-                        out.close();
                 } catch (IOException e) {
                     e.printStackTrace();
                 } finally {
diff --git a/http-library/src/main/java/com/github/why168/http/Request.java b/http-library/src/main/java/com/github/why168/http/Request.java
index 05d0878..f386cb5 100644
--- a/http-library/src/main/java/com/github/why168/http/Request.java
+++ b/http-library/src/main/java/com/github/why168/http/Request.java
@@ -15,6 +15,7 @@ public final class Request {
     private final String method;
     private final Map<String, String> headers;
     private final byte[] body;
+    private final String tag;
 
 
     private Request(Builder builder) {
@@ -22,6 +23,7 @@ private Request(Builder builder) {
         this.method = builder.method;
         this.headers = builder.headers;
         this.body = builder.body;
+        this.tag = builder.tag;
     }
 
     public String getUrl() {
@@ -40,11 +42,16 @@ public byte[] getBody() {
         return body;
     }
 
+    public String getTag() {
+        return tag;
+    }
+
     public static class Builder {
         private String url;
         private String method;
         private Map<String, String> headers;
         private byte[] body;
+        private String tag;
 
 
         public Builder() {
@@ -69,9 +76,15 @@ public Builder headers(Map<String, String> headers) {
             return this;
         }
 
-        public Builder bodys(byte[] bodys) {
-            if (bodys == null) throw new NullPointerException("body == null");
-            this.body = bodys;
+        public Builder body(byte[] body) {
+            if (body == null) throw new NullPointerException("body == null");
+            this.body = body;
+            return this;
+        }
+
+        public Builder tag(String tag) {
+            if (tag == null) throw new NullPointerException("tag == null");
+            this.tag = tag;
             return this;
         }
 
@@ -88,7 +101,8 @@ public String toString() {
                 "url='" + url + '\'' +
                 ", method='" + method + '\'' +
                 ", headers=" + headers +
-                ", body=" + Arrays.toString(body) +
+                ", body length=" + Arrays.toString(body) +
+                ", tag='" + tag + '\'' +
                 '}';
     }
 }
diff --git a/http-library/src/main/java/com/github/why168/http/Response.java b/http-library/src/main/java/com/github/why168/http/Response.java
index d100407..6c1e132 100644
--- a/http-library/src/main/java/com/github/why168/http/Response.java
+++ b/http-library/src/main/java/com/github/why168/http/Response.java
@@ -15,7 +15,6 @@ public class Response {
     private final int code;
     private final String message;
     private final Map<String, String> headers;
-    private final byte[] body;
     private final long length;
     private final InputStream inputStream;
 
@@ -24,7 +23,6 @@ public Response(Builder builder) {
         code = builder.code;
         message = builder.message;
         headers = builder.headers;
-        body = builder.body;
         inputStream = builder.inputStream;
         length = builder.length;
     }
@@ -34,7 +32,6 @@ public static class Builder {
         private int code = -1;
         private String message;
         private Map<String, String> headers;
-        private byte[] body;
         private InputStream inputStream;
         private long length;
 
@@ -61,11 +58,6 @@ public Builder header(Map<String, String> headers) {
             return this;
         }
 
-        public Builder body(byte[] body) {
-            this.body = body;
-            return this;
-        }
-
         public Builder inputStream(InputStream inputStream) {
             this.inputStream = inputStream;
             return this;
@@ -97,10 +89,6 @@ public Map<String, String> getHeaders() {
         return headers;
     }
 
-    public byte[] getBody() {
-        return body;
-    }
-
     public InputStream getInputStream() {
         return inputStream;
     }
@@ -116,7 +104,7 @@ public String toString() {
                 ", code=" + code +
                 ", message='" + message + '\'' +
                 ", headers=" + headers +
-                ", body length=" + length +
+                ", length=" + length +
                 '}';
     }
 }
diff --git a/http-library/src/main/java/com/github/why168/http/StringCallback.java b/http-library/src/main/java/com/github/why168/http/StringCallback.java
index c487225..88d19af 100644
--- a/http-library/src/main/java/com/github/why168/http/StringCallback.java
+++ b/http-library/src/main/java/com/github/why168/http/StringCallback.java
@@ -1,5 +1,7 @@
 package com.github.why168.http;
 
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
@@ -13,6 +15,19 @@ public abstract class StringCallback extends Callback<String> {
 
     @Override
     public String parseNetworkResponse(Response response, AtomicBoolean isCancelled) throws Exception {
-        return new String(response.getBody());
+        InputStream is = response.getInputStream();
+        ByteArrayOutputStream out = new ByteArrayOutputStream(2048);
+        byte[] buffer = new byte[2048];
+        int len = 0;
+        while ((len = is.read(buffer)) != -1) {
+            if (isCancelled.get()) {
+                throw new RuntimeException("http cancel");
+            }
+            out.write(buffer, 0, len);
+        }
+        out.flush();
+        is.close();
+        out.close();
+        return new String(out.toByteArray());
     }
 }