让 InputStream 读取不止一次，不管 markSupported()

Question

我需要能够多次重复使用java.io.InputStream，我认为下面的代码可以工作，但它只能在第一次工作。

代码

---

public class Clazz
{
  private java.io.InputStream dbInputStream, firstDBInputStream;
  private ArrayTable db;

  public Clazz(java.io.InputStream defDB)
  {
    this.firstDBInputStream = defDB;
    this.dbInputStream = defDB;
    if (db == null)
      throw new java.io.FileNotFoundException("Could not find the database at " + db);
    if (dbInputStream.markSupported())
      dbInputStream.mark(Integer.MAX_VALUE);
    loadDatabaseToArrayTable();
  }

  public final void loadDatabaseToArrayTable() throws java.io.IOException
  {
    this.dbInputStream = firstDBInputStream;
    if (dbInputStream.markSupported())
      dbInputStream.reset();

    java.util.Scanner fileScanner = new java.util.Scanner(dbInputStream);
    String CSV = "";
    for (int i = 0; fileScanner.hasNextLine(); i++)
      CSV += fileScanner.nextLine() + "\n";
    db = ArrayTable.createArrayTableFromCSV(CSV);
  }

  public void reloadDatabase()//A method called by the UI
  {
    try
    {
      loadDatabaseToArrayTable();
    }
    catch (Throwable t)
    {
      //Alert the user that an error has occurred
    }
  }
}

注意 ArrayTable 是我的一个类，它使用数组来提供处理表格的接口。

问题

---

在这个程序中，数据库在调用reloadDatabase() 方法后立即直接显示给用户，因此任何涉及将初始读取保存到内存中的对象的解决方案都是无用的，因为这不会刷新数据（把它想象成一个浏览器；当你按下“刷新”时，你希望它再次获取信息，而不仅仅是显示它第一次获取的信息）。 如何多次阅读java.io.InputStream？

Answer 1

您不一定能多次读取 InputStream。有些实现支持它，有些不支持。您正在做的是检查 markSupported 方法，如果您可以两次读取相同的流，这确实是一个指标，但是您忽略了结果。您必须调用该方法来查看您是否可以读取两次流，如果不能，请进行其他安排。

编辑（回应评论）：当我写下我的答案时，我的“其他安排”是获得一个新的 InputStream。但是，当我在您的 cmets 中阅读您关于您想要做什么的问题时，我不确定这是否可能。对于操作的基础知识，您可能需要 RandomAccessFile （至少这是我的第一个猜测，如果它有效，那将是最简单的） - 但是您将遇到文件访问问题。您有一个应用程序主动写入文件，而另一个应用程序正在读取该文件，您将遇到问题 - 确切的问题将取决于操作系统，因此无论哪种解决方案都需要更多测试。我建议针对这一点提出一个关于 SO 的单独问题，尝试过该问题的人或许可以为您提供更多见解。

Answer 2

您永远不会标记要重置的流

public Clazz(java.io.InputStream defDB)
  {
    firstDBInputStream = defDB.markSupported()?defDB:new BufferedInputStream(defDB);
      //BufferedInputStream supports marking
    firstDBInputStream.mark(500000);//avoid IOException on first reset
  }

public final void loadDatabaseToArrayTable() throws java.io.IOException
  {
    this.dbInputStream = firstDBInputStream;

    dbInputStream.reset();
    dbInputStream.mark(500000);//or however long the data is

    java.util.Scanner fileScanner = new java.util.Scanner(dbInputStream);
    StringBuilder CSV = "";//StringBuilder is more efficient in a loop
    while(fileScanner.hasNextLine())
      CSV.append(fileScanner.nextLine()).append("\n");
    db = ArrayTable.createArrayTableFromCSV(CSV.toString());
  }

但是，您可以保留原始 ArrayTable 的副本，并在需要时复制它（甚至是创建的字符串来重建它）

此代码创建字符串并将其缓存，因此您可以安全地丢弃输入流并使用readCSV 构建ArrayTable

  private String readCSV=null;
  public final void loadDatabaseToArrayTable() throws java.io.IOException
  {
    if(readCSV==null){

        this.dbInputStream = firstDBInputStream;


        java.util.Scanner fileScanner = new java.util.Scanner(dbInputStream);
        StringBuilder CSV = "";//StringBuilder is more efficient in a loop
        while(fileScanner.hasNextLine())
          CSV.append(fileScanner.nextLine()).append("\n");

        readCSV=CSV.toString();
        fileScanner.close();

    }
    db = ArrayTable.createArrayTableFromCSV(readCSV);
  }

但是，如果您需要新信息，则需要创建一个新流以再次读取