android - 当请求已经在 getBody() 方法中时，是否可以取消请求？

Question

我有一个 MultipartPostRequest，它具有在 getBody() 方法中实现的进度计数功能。所以我在通知栏显示进度。当用户点击显示进度的通知时，它应该被取消，就像 Facebook 的实现方式一样。

我尝试在实际的 Request 对象上使用 Request.cancel() 和 RequestQueue.cancelAll(Object tag) 但请求仍然没有被取消。

我读到一个正在进行的请求不能被取消，但在这种情况下它仍然只是在 getBody() 方法中，所以我认为(我不太确定)它应该被取消正确的？因为我还记录了 isCancelled() 方法的返回，是的，当单击通知时它确实返回 true，并且在返回上传请求进度的方法中调用日志，因此意味着它在 getBody() 方法中。

但令人惊讶且令人沮丧的是，该请求仍然通过，因为它仍然返回结果!

有解决办法吗？或者有没有办法像 Facebook 那样实现它？如果可以，我很乐意为此悬赏。

我正在使用这个答案中的类(class):https://stackoverflow.com/a/28144660/1744379

由于某些情况，我无法分享我的代码。但是这个类正是我使用的，我只是做了一些小的调整。 CountingOutputStream 的放置与 CountingOutputStream 和 MultipartPostProgressListener 相同。因此，检查 isCancelled 方法的 Log 位于我在 Service

中实现的 transferred 方法中>

Answer 1

海事组织，您可以引用以下内容:

首先，需要的变量:

public class MainActivity extends AppCompatActivity {
    private Context mContext = this;
    private Uri mFileUri;
    private String mFilePath;
    private ImageView mImagePreview;
    private ProgressBar mProgressBar;
    StringRequest mStringRequest;
    private long mFileLength;
    private MultipartProgressListener multipartProgressListener;
    ...

假设您获得了从手机的相机(图库)文件夹中选择图像文件的代码，并成功获得了文件路径(mFilePath)。

private void cancelUpload(){    
    mStringRequest.cancel();
}

private void uploadFile(){
    mProgressBar.setProgress(0);
    String url = "http://yourserver/fileupload";
    MultipartEntityBuilder entityBuilder = MultipartEntityBuilder.create();
    entityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);

    if (mFilePath != null) {
        File file = new File(mFilePath);
        if (file.exists()) {
            mFileLength = file.length();
            FileBody fileBody = new FileBody(file);
            entityBuilder.addPart("file", fileBody);

            final HttpEntity httpEntity = entityBuilder.build();

            mStringRequest = new StringRequest(Request.Method.POST, url, new Response.Listener<String>() {
                @Override
                public void onResponse(String response) {
                    mFilePath = "";
                    Log.i("Multipart", response);
                }
            }, new Response.ErrorListener() {
                @Override
                public void onErrorResponse(VolleyError error) {
                    Log.e("Multipart", error.toString());
                }
            }) {
                @Override
                public String getBodyContentType() {
                    return httpEntity.getContentType().getValue();
                }

                @Override
                public byte[] getBody() throws AuthFailureError {
                    ByteArrayOutputStream bos = new ByteArrayOutputStream();
                    try {
                        //httpEntity.writeTo(bos);
                        httpEntity.writeTo(new CountingOutputStream(bos, mFileLength,
                                multipartProgressListener));
                    } catch (IOException e) {
                        Log.e("Multipart", e.toString());
                    }
                    return bos.toByteArray();

                }
            };
            mStringRequest.setRetryPolicy(new DefaultRetryPolicy(DefaultRetryPolicy.DEFAULT_TIMEOUT_MS * 5, DefaultRetryPolicy.DEFAULT_MAX_RETRIES, DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));
            VolleySingleton.getInstance(mContext).addToRequestQueue(mStringRequest);
        }
    }
}

以下代码来自您问题中的链接，我做了一些更新(请注意它们不再是static)

    public interface MultipartProgressListener {
        void transferred(long transfered, int progress);
    }

    public class CountingOutputStream extends FilterOutputStream {
        private final MultipartProgressListener progListener;
        private long transferred;
        private long fileLength;

        public CountingOutputStream(final OutputStream out, long fileLength,
                                    final MultipartProgressListener listener) {
            super(out);
            this.fileLength = fileLength;
            this.progListener = listener;
            this.transferred = 0;
        }

        public void write(byte[] b, int off, int len) throws IOException {
            Log.i("isCanceled", String.valueOf(mStringRequest.isCanceled()));
            if (!mStringRequest.isCanceled()) {
                out.write(b, off, len);
                if (progListener != null) {
                    this.transferred += len;
                    int prog = (int) (transferred * 100 / fileLength);
                    this.progListener.transferred(this.transferred, prog);
                }
            } else {
                Log.w("Multipart", "Request canceled!");
                out.flush();
                out.close();
            }
        }

        public void write(int b) throws IOException {
            if (!mStringRequest.isCanceled()) {
                out.write(b);
                if (progListener != null) {
                    this.transferred++;
                    int prog = (int) (transferred * 100 / fileLength);
                    this.progListener.transferred(this.transferred, prog);
                }
            } else {
                Log.w("Multipart", "Request canceled!");
                out.flush();
                out.close();
            }
        }
    }

P/S:你应该选择大文件大小:)