Jackson JSON流解析器

Question

我想从HttpRequest (JSON对象)作为流处理响应。这意味着只过滤我感兴趣的data字段，并将其作为流返回并进一步处理(作为HttpServletResponse发送)。我不想将其加载到内存中，因为response.body()可能很大(1 000 000+行)。不幸的是，我在JsonParser类上没有看到任何返回流的方法。

HttpResponse<InputStream> response = client.send(httpRequest, BodyHandlers.ofInputStream());
InputStream result = response.body();
JsonFactory factory = new JsonFactory();
try(JsonParser parser = factory.createParser(result)){
while (parser.nextToken() != JsonToken.END_OBJECT) {
if ("data".equals(parser.getCurrentName())) {
parser.getValueAsString(); // it returns correct lines but as String
}
}
}

有人知道怎么处理吗?或者我应该使用其他库/API?

Answer 1

您已经将输入数据作为流处理，因此可以轻松地将其写入另一个流，如HttpServletResponse。

获取要传输数据的输出流:

ServletOutputStream out = httpServletResponse.getOutputStream();

对于每个数据字符串，将值写入新流:

while ... {
if ("data".equals(parser.getCurrentName())) {
String data = parser.getValueAsString();
out.write(data.getBytes("UTF-8"));
}
}