对象序列化问题 / IO流问题

Question

/**
 * 用户实体
 * 
 * @author kreadk
 * 
 */
public class User implements Serializable {
private String name;
private int age; public User() {
} public User(String name, int age) {
super();
this.name = name;
this.age = age;
} @Override
public String toString() {
return this.name + " , " + this.age;
} //set、get方法省略。。
}
－－－－－－－－－－－－－－－－－－
import java.io.EOFException;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.HashSet;
import java.util.Set;/**
 * 数据操作。保存、查询等
 * @author kreadk
 *
 */
public class UserDao {
/**
 * 文件路径
 */
private static final String FILE_PATH = "users.dat"; public void saveUser1(User user) {
ObjectOutputStream oos1 = null;
try {
// 带有true参数的FileOutputStream
oos1 = new ObjectOutputStream(new FileOutputStream(FILE_PATH, true));
oos1.writeObject(user);
oos1.flush();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
oos1.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} public void saveUser2(Set<User> users) {
ObjectOutputStream oos1 = null;
try {
// ???
oos1 = new ObjectOutputStream(new FileOutputStream(FILE_PATH));
for (User user : users) {
oos1.writeObject(user);
}
oos1.flush();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
oos1.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} //查询出所有用户
public void findAllUser() {
ObjectInputStream ois = null;
try {
ois = new ObjectInputStream(new FileInputStream(FILE_PATH));
while (true) {
User user = (User) ois.readObject();
System.out.println(user);
}
} catch (EOFException e) {
//
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
ois.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} public static void main(String[] args) {
UserDao dao = new UserDao(); User u1 = new User("LILI", 19);
User u2 = new User("LUCY", 15);
User u3 = new User("HEHE", 17); Set users = new HashSet();
users.add(u1);
users.add(u2);
users.add(u3); System.out.println("方法1：----------------------------------");
dao.saveUser1(u1);
dao.saveUser1(u2);
dao.saveUser1(u3);
dao.findAllUser(); System.out.println("方法2：----------------------------------");
dao.saveUser2(users);
dao.findAllUser();
}
}控制台输出：
方法1：----------------------------------
LILI , 19
java.io.StreamCorruptedException
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1332)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:348)
at temp.UserDao.findAllUser(UserDao.java:58)
at temp.UserDao.main(UserDao.java:90)
方法2：----------------------------------
HEHE , 17
LUCY , 15
LILI , 19
希望有人解释这个异常的原因。
同样几个对象，一次写入和分多次（append）写入文件2种情况，读取时为何不同？

Answer 1

估计跟你写得方式不同，分多次写入，你每写一次就刷新缓存一次，而一次写入，你是将所有对象放入内存，再一次性得写入文件（writeObject代表写入内存,close才是写入硬盘），可能跟这个有关

Answer 2

为了你这个问题，代码试了又试，查了又查，终于搞明白了。
首先帮你分析一下，出了问题，怎么办，看一下，抛出异常，怎么搜？？
既然抛出了StreamCorruptedException，所以你得那它去google一把，不出所料。你的问题的答案就出来了。
ObjectInputStream因为调用getInputStream方法就会读取标示头信息。用缺省的serializetion的实现时,一个 ObjectOutputStream的构造和一个ObjectInputStream的构造必须一一对应.ObjectOutputStream的构造函数会向输出流中写入一个标识头,而ObjectInputStream会首先读入这个标识头.因此,多次以追加方式向一个文件中写入object时,该文件将会包含多个标识头.所以用ObjectInputStream来deserialize这个ObjectOutputStream时,将产生 StreamCorruptedException.。
这下明白了吧。收工。

Answer 3

invalid type code: AC
对于第一种情况：可能是由于不同对象的写入操作造成的错误 导致类型码无效
第一种情况是分别用三个不同对象来进行writeObject的
试用一个对象oos1 = new ObjectOutputStream(new FileOutputStream(FILE_PATH, true));
oos1.writeObject(user1);
oos1.writeObject(user2);
oos1.writeObject(user3);
oos1.flush();测试下来是没问题的 这个在ObjectOutputStream类的javadoc中有介绍

Answer 4

使用缺省的serializetion的实现时,一个ObjectOutputStream的构造和一个ObjectInputStream的构造必须一一对应.
ObjectOutputStream的构造函数会向输出流中写入一个标识头,而ObjectInputStream会首先读入这个标识头.
因此,多次以追加方式向一个文件中写入object时,该文件将会包含多个标识头.
所以用ObjectInputStream来deserialize这个 ObjectOutputStream时,将产生StreamCorruptedException.一种解决方法是可以构造一个 ObjectOutputStream的子类,并覆盖writeStreamHeader()方法.
被覆盖后的writeStreamHeader()方法应判断是否为首次向文件中写入object,
否则调用super.writeStreamHeader();
若否,即以追加方式写入object时, 则应调用ObjectOutputStream.reset()方法.

Answer 5

//虽然花费了我一个早上,但值啊
import java.io.EOFException;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.HashSet;
import java.util.Set;/**
 * 数据操作。保存、查询等
 * 
 * @author kreadk
 * 
 */
public class UserDao {
/**
 * 文件路径
 */
private static final String FILE_PATH = "users.dat"; // public ObjectOutputStream outSteam;
public UserDao()  { } public void saveUser1(User user) throws IOException {
ObjectOutputStream outSteam = null;
try {
// 带有true参数的FileOutputStream
outSteam = new ObjectOutputStream(new FileOutputStream(FILE_PATH,
true)) {
// 如是果要附加对象到文件后
// 必须重新定义这个方法
// 如果不是追加方式这样写后果自负啊
protected void writeStreamHeader() throws IOException {
}
}; outSteam.writeObject(user); outSteam.flush(); } catch (Exception e) {
e.printStackTrace();
} finally {
try {
outSteam.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} public void saveUser2(Set<User> users) {
ObjectOutputStream outSteam = null;
try {
// ???
outSteam = new ObjectOutputStream(new FileOutputStream(FILE_PATH,
true)) {
// 如是果要附加对象到文件后
// 必须重新定义这个方法
// 如果不是追加方式这样写后果自负啊
protected void writeStreamHeader() throws IOException {
}
}; for (User user : users) {
outSteam.writeObject(user);
}
outSteam.flush();
} catch (Exception e) {
e.printStackTrace();
}  finally {
 try {
 outSteam.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
} // 查询出所有用户
public void findAllUser() {
ObjectInputStream ois = null; try {
FileInputStream tempSteam = new FileInputStream(FILE_PATH);
ois = new ObjectInputStream(tempSteam);
Object obj;
while (tempSteam.available() > 0) {// 你原来的这里可是死循环啊
obj = ois.readObject();
if (obj instanceof User) {// 建议加上这句
User user = (User) obj;
System.out.println(user);
}
}
} catch (EOFException e) {
//
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
ois.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} public static void main(String[] args) throws Exception {
UserDao dao = new UserDao(); User u1 = new User("LILI", 19);
User u2 = new User("LUCY", 15);
User u3 = new User("HEHE", 17);

Set<User> users = new HashSet<User>();// Set users = new
// HashSet();换成前面的
/*****************假设我的机子上还没有FILE_PATH***********************************/
ObjectOutputStream outStream= new ObjectOutputStream(new FileOutputStream(FILE_PATH ));//无论是否存在再创建个
//写的这里有点不合适,你可以写在其他地方(最好事先判断一下文件是否存在,不存在再创建

/****************************************************/
// 下面这样写的前提必须是FILE_PATH必须存在(就是空文件也可以,只要他存在),要不会抛出invalid stream header
// ObjectOutputStream outSteam = new ObjectOutputStream(new FileOutputStream(FILE_PATH,true)) {
// // 如是果要附加对象到文件后
// // 必须重新定义这个方法
// // 如果不是追加方式这样写后果自负啊
// protected void writeStreamHeader() throws IOException {
// }
// };
users.add(u1);
users.add(u2);
users.add(u3);
System.out.println("方法1：----------------------------------");
dao.saveUser1(u1);
dao.saveUser1(u2);
dao.saveUser1(u3);
dao.findAllUser(); System.out.println("方法2：----------------------------------");
dao.saveUser2(users);
dao.findAllUser(); }
}
方法1：----------------------------------
LILI , 19
LUCY , 15
HEHE , 17
方法2：----------------------------------
LILI , 19
LUCY , 15
HEHE , 17
LUCY , 15
LILI , 19
HEHE , 17

Answer 6

 Object obj;
            while (tempSteam.available() > 0) {// 你原来的这里可是死循环啊
                obj = ois.readObject();我的代码不会发生死循环的，读完啦就会捕捉到EOF异常，结束。。

Answer 7

    原来死循环可以这样退啊,学习了(当时看见那个EOFException没多想),呵呵