在Java中，如何使用Google的guava CharStreams.toString进程中的inputStream？

Question

我正在执行一个进程，并希望将其输出读入字符串中。我希望使用 Guava CharStreams.toString（InputSupplier供应商）。不幸的是，Process的getInputStream()返回的流是InputStream类型，而不是InputSupplier。我如何使用它来创建一个 InputSupplier 以与 toString() 一起使用？

理想情况下我可以做这样的事情：

CharStreams.toString(CharStreams.newReaderSupplier(process.getInputStream()))

但是你不能从InputStream构造一个InputSupplier，而且我很难找到如何做到这一点。

Answer 1

我还没有找到用番石榴做到这一点的方法。我相信开发商这样做是有充分理由的。在保持最小化的同时，我得到的最接近的是：

 CharStreams.toString(CharStreams.newReaderSupplier(new InputSupplier<InputStream>() {
        @Override
        public InputStream getInput() throws IOException {
            return inputStream;
        }
    }, Charsets.UTF_16));

我使用了 CharStreams 中的 newReaderSupplier，因此您不必使用 InputStreamReader 包装它。

Answer 2

怎么样：

CharStreams.toString(new InputStreamReader(process.getInpusttream()))

它正在使用 CharStreams.toString(Readable)。

Answer 3

到目前为止，这是我能做的最好的事情：

String commandOutput = CharStreams.toString(new InputSupplier<InputStreamReader>() {
    public InputStreamReader getInput() throws IOException {
        return new InputStreamReader(process.getInputStream());
    }
});

Answer 4

正确的做法——以及 Guava 试图促使你做的事情——是改变为你提供 InputStream 的代码，改为为你提供一个 InputSupplier。

这样做的原因是，这样，Guava 获取流，读取字符串，然后关闭它，并且在 Guava 关闭它之后你不会意外地使用它，因为你一开始就没有对 InputStream 的引用。这消除了很多潜在的错误。

另一个重载 CharStreams.toString(Readable) 不会关闭 Readable。如果您想拥有自己的特殊逻辑来关闭输入流，Guava 可以让您这样做。

Guava 相当于 IOUtils.toString(InputStream) 说得比我好可以。

Answer 5

这应该可以做到：

InputStream is = process.getInputStream();
String content = CharStreams.toString(new InputStreamReader(is, Charsets.UTF_8));
is.close();

这是一个完整用法的现实例子：

HttpURLConnection connection = null;
URL url;
InputStream is = null;
try {
  url = new URL("https://graph.facebook.com/oauth/access_token?client_id=" + appId + "&client_secret=" + appSecret + "&grant_type=client_credentials");
  connection = (HttpURLConnection) url.openConnection();
  connection.setRequestProperty("accept-encoding", "gzip");

  is = connection.getInputStream();
  String content = CharStreams.toString(new InputStreamReader(is, Charsets.UTF_8));
  String[] tokens = content.split("=");
  System.out.println(tokens[1]);
} catch (IOException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
} finally {
  if (is != null) try {
    is.close();
  } catch (IOException e) {}
  connection.disconnect();
}

我知道这并不是真正的问题，但为了比较，他就是你如何使用 IOUtils 做到这一点 - IMO 更干净一些：

HttpURLConnection connection = null;
URL url;
InputStream is = null;

try {
  url = new URL("https://graph.facebook.com/oauth/access_token?client_id=" + appId + "&client_secret=" + appSecret + "&grant_type=client_credentials");
  connection = (HttpURLConnection) url.openConnection();
  connection.setRequestProperty("accept-encoding", "gzip");

  is = connection.getInputStream();

  String value = IOUtils.toString(is);
  if (!Strings.isNullOrEmpty(value)) {
    String[] splits = value.split("=");
    System.out.println(splits[1]);
  }
} catch (IOException e) {

} finally {
  IOUtils.closeQuietly(is);
  connection.disconnect();
}