使 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 方法，如果您可以读取同一个流两次，这确实是一个指示器，但您会忽略结果。您必须调用该方法来查看是否可以读取流两次，如果不能，请进行其他安排。

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

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);
  }

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