4

私はSpring Androidのリクエストを実行する専用のスレッドでSpring Androidを使用しています。

春のアンドロイド（たとえば、getForObject）から起動されたリクエストを中止することはできません。

私がしようとしました ：

  • 基になる入力ストリームに到達して閉じますが、完全に springandroid restemplate でラップされており、外部からアクセスすることはできません
  • スレッドを中断する
  • 残りのテンプレートのリクエスト ファクトリを取得し、destroy を呼び出します
  • ファクトリの接続マネージャーを取得し、シャットダウンを呼び出します
  • 残りのテンプレート ファクトリの http クライアントを変更する
  • 残りのテンプレート ファクトリのリクエスト ファクトリを変更する

しかし、リクエストを中止して新しいリクエストをすぐに送信することはできません。最初のものはタイムアウトに達する必要があります。

春のAndroidリクエストを「殺して」、新しいリクエストを送信するための安定した残りのテンプレートを取得するにはどうすればよいですか?

前もって感謝します。

4

1 に答える 1

3

ResponseExtractor の使用をお勧めします。

以下のような RestTemplate の execute メソッドを呼び出すことができます。

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

ResponseExtractor には extractData メソッドがあります。応答の getBody() を介して、extractData メソッドからボディ入力ストリームを取得できます。

リクエストをキャンセルするために ResponseExtractor を拡張します。

幸運を。

私の場合、リスナーの方法を使用しました。

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;

    }

}
于 2012-10-19T08:01:17.240 に答える