如何持续刷新Scanner以获取输入流中的最新数据？

首先得说清楚：Scanner的内部缓存机制就是你遇到这个问题的核心。当你把InputStream传入Scanner时，它会先把流里当前可用的数据读到自己的内部缓冲区里，之后所有的findWithinHorizon操作都是基于这个缓冲区来做的。如果InputStream后面又有新数据写进来，Scanner不会主动去读这些新内容——它觉得自己已经处理完了当前"视界"内的所有数据，不会自动刷新缓冲区。

针对异步场景下要持续获取流里最新数据的需求，给你几个可行的方案：

方案一：换掉Scanner，用BufferedReader + Matcher手动处理 #

别用Scanner了，改用BufferedReader来逐行（或者逐块）读取流，然后搭配Matcher来应用正则表达式。这种方式你能主动控制什么时候读取新数据，完美适配异步流动态写入的场景。

示例代码：

BufferedReader reader = new BufferedReader(new InputStreamReader(response.getContentInputStream()));
Pattern pattern = Pattern.compile(PATTERN);
String line;
StringBuilder buffer = new StringBuilder();

while (true) {
    // 读取新行，同步场景下会阻塞等新数据，异步场景可以配合线程处理
    line = reader.readLine();
    if (line == null) {
        // 流已经结束，退出循环
        break;
    }
    buffer.append(line).append("\n");
    Matcher matcher = pattern.matcher(buffer);
    
    // 找出所有匹配的内容
    while (matcher.find()) {
        String extractedData = matcher.group();
        // 执行你的检查操作
        // 处理完可以把已经匹配过的部分从buffer里删掉，避免重复处理
        buffer.delete(0, matcher.end());
        matcher = pattern.matcher(buffer);
    }
}

这种方式的好处是你完全掌控数据的读取和匹配过程，只要流里有新数据进来，readLine()（或者read()方法）就能读到新内容，然后你立刻就能用正则去匹配，绝对不会错过新数据。

方案二：手动刷新Scanner缓冲区（不推荐） #

Scanner没有公开的方法能强制刷新缓冲区，不过你可以试试调用scanner.reset()来重置它的状态，但这会清空已经匹配的状态，而且不一定能保证读到流里的新数据——因为底层InputStream的读取位置可能已经被Scanner移动过了，这种方式可靠性很低，不建议在生产环境用。

方案三：用异步IO框架（适合高并发场景） #

如果你的异步场景涉及高并发或者大量流数据处理，可以考虑用Java的NIO框架（比如AsynchronousFileChannel）或者第三方的异步IO库，这些框架原生支持异步流的监听和数据读取，处理动态写入的流数据会更高效，搭配正则匹配也更灵活。

几个要注意的点 #

• 异步场景下，一定要保证流的写入和读取操作是线程安全的，避免并发修改出问题。
• 如果你的检查操作是异步的，处理匹配到的数据时要注意线程同步，别搞出数据错乱的情况。

内容的提问来源于stack exchange，提问作者Katy