ObjectInputStream.readObject 文件异常结束

Question

我的应用程序流式传输 Twitter 数据并将它们写入文件。

while(true){
        Status status = queue.poll();

        if (status == null) {
            Thread.sleep(100);
        }

        if(status!=null){
            list.add(status);
        }

        if(list.size()==10){
            FileOutputStream fos = null;
            ObjectOutputStream out = null;
            try {
                String uuid = UUID.randomUUID().toString();
                String filename = "C:/path/"+topic+"-"+uuid+".ser";
                fos = new FileOutputStream(filename);
                out = new ObjectOutputStream(fos);
                out.writeObject(list);
                tweetsDownloaded += list.size();
                if(tweetsDownloaded % 100==0)
                    System.out.println(tweetsDownloaded+" tweets downloaded");
            //  System.out.println("File: "+filename+" written.");
                out.close();
            } catch (IOException e) {

                e.printStackTrace();
            }

            list.clear();
    }

我有这段代码可以从文件中获取数据。

while(true){
    File[] files = folder.listFiles();

    if(files != null){
        Arrays.sort(//sorting...);

        //Here we manage each single file, from data-load until the deletion
        for(int i = 0; i<files.length; i++){
            loadTweets(files[i].getAbsolutePath());
            //TODO manageStatuses
            files[i].delete();
            statusList.clear();
        }

    }

}

方法 loadTweets() 执行以下操作：

private static void loadTweets(String filename) {

    FileInputStream fis = null;
    ObjectInputStream in = null;
    try{
        fis = new FileInputStream(filename);
        in = new ObjectInputStream(fis);
        statusList = (List<Status>) in.readObject();
        in.close();
    }
    catch(IOException | ClassNotFoundException ex){
        ex.printStackTrace();
    }


}

不幸的是，我不知道为什么有时会抛出

EOFException

当运行这一行

statusList = (List<Status>) in.readObject();

有人知道我该如何解决这个问题吗？谢谢。

Answer 1

根据您之前提出的问题，我发现您使用 getAbsolutePath() 正确传递了文件

根据我的阅读，可能有几件事，其中之一是文件为空。

解释这个想法，您可能已经编写了文件，但某些原因导致文件内部没有任何内容，这可能会导致 EOFException。该文件实际上存在它只是空的

编辑

尝试将代码附在while(in.available() > 0)

中

看起来像这样

private static void loadTweets(String filename) {

    FileInputStream fis = null;
    ObjectInputStream in = null;
    try{
        fis = new FileInputStream(filename);
        in = new ObjectInputStream(fis);
        while(in.available() > 0) {
            statusList = (List<Status>) in.readObject();
        }
        in.close();
    }
    catch(IOException | ClassNotFoundException ex){
        ex.printStackTrace();
    }
}

Answer 2

找出解决这个问题的必要条件。感谢@VGR 的评论，如果文件创建不到一秒，我想暂停执行线程 0.2 秒。

if(System.currentTimeMillis()-files[i].lastModified()<1000){
        Thread.sleep(200);

这可以防止异常，应用程序现在可以正常工作。

ObjectInputStream.readObject 文件异常结束

End of File Exception on ObjectInputStream.readObject

java

file

eofexception