我该如何解决这个流读取问题？

Question

我正在尝试从发送 JSON 正文的 URL 读取响应。但是我的代码无法读取完整的响应。我的代码有问题，但我没有明白。val url: URL = new URL("https://jsonplaceholder.typicode.com/todos/1")val httpsConnection: HttpsURLConnection = url.openConnection().asInstanceOf[HttpsURLConnection]httpsConnection.setRequestMethod("GET")httpsConnection.setRequestProperty("Accept", "application/json")httpsConnection.setRequestProperty("Accept-Language", "en_US")val streamReader: InputStreamReader = new InputStreamReader(httpsConnection.getInputStream)val bufferedReader = new BufferedReader(streamReader)val stringBuffer: StringBuffer =new StringBuffer()while(bufferedReader.readLine() != null){  stringBuffer.append(bufferedReader.readLine())}println(stringBuffer.toString)上面的代码没有给我实际结果。但是，如果我避免使用常规的 Java 样式并使用 scala 源代码：Source.fromInputStream(httpsConnection.getInputStream,"UTF8").getLines().foreach(println)这给出了实际的 JSON。我的第一部分代码有什么问题？

Answer 1

在这个地方：

while(bufferedReader.readLine() != null){

  stringBuffer.append(bufferedReader.readLine())

}

你readLine先打电话两次来检查它是否不为空，然后追加到stringBuffer. 但实际上，第二个电话得到了另一条线路，所以你每隔一行就输一次。

在 Java 中读取缓冲流的常用方法是：

String line;

while ((line = r.readLine()) != null) {

   // do your stuff...

}

但是 Scala 中的分配返回Unit所以它不会工作。

所以也许使用Stream.continually是可行的方法？

Stream

    .continually(bufferedReader.readLine())

    .takeWhile(_ != null)

    .foreach(stringBuffer.append)

Answer 2

我知道这不是您要找的东西，但数据操作有时会非常复杂，尤其是当您涉及网络时。因此，为了简单起见，我建议使用外部库JSON从URL.

以下代码使用JSON.simple和Apache Commons IOJSON提供的方法从您提供的链接中检索您的文件：

public void getJson() throws IOException {

    java.net.URL url = new java.net.URL("https://jsonplaceholder.typicode.com/todos/1");

    String json = IOUtils.toString(url, Charset.forName("UTF-8"));

    System.out.println(json);

}

Answer 3

readLine 被调用了两次，InputStreamReader 应该使用源的字符集。这里我采用了 ISO-8859-1，因为它不会像 UTF-8 那样给出错误。readLine 也删除了行结尾，而 StringBuilder 更快。

val streamReader: InputStreamReader = new InputStreamReader(httpsConnection.getInputStream,

    "ISO-8859-1")

val bufferedReader = new BufferedReader(streamReader)

val stringBuilder: StringBuilder = new StringBuilder()

while (true) {

  val line = bufferedReader.readLine();

  if (line == null) {

      break;

  }

  stringBuilder.append(line).append("\r\n");

}