取消/中止/中断 spring-android resttemplate 请求

Question

我在一个专门用于执行 spring android 请求的线程中使用 spring android。

我无法中止从 spring android 启动的请求（例如 getForObject）。

我试过了：

• 到达要关闭的底层输入流，但它完全包裹在 springandroid restemplate 中，无法从外部访问
• 中断线程
• 获取rest模板的请求工厂并调用destroy
• 获取工厂的连接管理器并调用shutdown
• 更改其余模板工厂的http客户端
• 更改其余模板工厂的请求工厂

但我无法中止请求并快速发送新请求。第一个必须达到超时。

我怎样才能“杀死”一个 spring android 请求以获得一个稳定的休息模板来发送一个新请求？

提前致谢。

Answer 1

我建议使用 ResponseExtractor。

你可以调用RestTemplate的execute方法，如下所示。

    File file = (File) restTemplate.execute(rootUrl.concat("/vocasets/{vocasetId}/{version}"), HttpMethod.GET, requestCallabck,
            responseExtractor, uriVariables);

ResponseExtractor 有 extractData 方法。您可以通过响应的 getBody() 从 extractData 方法获取正文输入流。

扩展 ResponseExtractor 以取消您的请求。

祝你好运。

就我而言，我使用了 Listener 方式。

static class FileResponseExtractor implements ResponseExtractor<File> {
            ...

    public void setListener(ReceivingListener listener) {
        this.listener = listener;
    }

    @Override
    public File extractData(ClientHttpResponse response) throws IOException {
        InputStream is = response.getBody();

        long contentLength = response.getHeaders().getContentLength();

        long availableSpace = AvailableSpaceHandler.getExternalAvailableSpaceInMB();
        long availableBytes = AvailableSpaceHandler.getExternalAvailableSpaceInBytes();
        Log.d(TAG, "available space: " + availableSpace + " MB");

        long spareSize = 1024 * 1024 * 100;
        if(availableBytes < contentLength + spareSize) {
            throw new NotEnoughWritableMemoryException(availableSpace);
        }

        File f = new File(temporaryFileName);
        if (f.exists())
            f.delete();
        f.createNewFile();

        OutputStream o = new FileOutputStream(f);

        listener.onStart(contentLength, null);
        boolean cancel = false;
        try {
            byte buf[] = new byte[bufferSize];
            int len;
            long sum = 0;
            while ((len = is.read(buf)) > 0) {
                o.write(buf, 0, len);
                sum += len;
                listener.onReceiving(sum, len, null);

                cancel = !listener.onContinue();
                if(cancel) {
                    Log.d(TAG, "Cancelled!!!");
                    throw new CancellationException();
                }
            }
        } finally {
            o.close();
            is.close();
            listener.onFinish(null);

            if(cancel) {
                f.delete();
            }
        }

        return f;

    }

}