Java序列化流

1、什么是序列化流

序列化就是把Java对象“流化”，序列化后的Java对象可以保存到本地文件系统，或者通过Socket传输到其他的服务器。

Java中对象序列化有以下特点：

　　1）类实现java.io.Serializable接口；
　　2）瞬态或静态的字段无法序列化；

2、使用场景

在一些需要把数据存储到磁盘或者数据缓存的情况下可以使用到序列化

如：

1）web服务器关闭时把会话信息保存到服务器磁盘上；
2）web服务关闭时，把一些待处理的数据保存到服务器磁盘上；
3）mybatis、hibernate整合ehcache、redis、memcached等缓存服务缓存数据库数据，这个是一个比较重要的使用场景

记得以前做项目，有一些需要调用第三方接口给用户充流量、充话费的需求，为了较好的用户体验，使用了异步充值，即用户信息提交后把充值请求保存到消息队列，然后就返回响应给用户，后台有独立线程到消息队列查找请求调用接口完成充值。
为了避免在服务器重启时充值队列丢失，就在服务关闭前把消息队列通过序列化输出流保存到磁盘，在服务启动时从磁盘读取数据反序列化为充值请求对象保存到消息队列，这样充值线程开启时就可以继续给这些用户充值了。

3、ObjectInputStream类

把实现了java.io.Serializable接口的类对象（非静态成员和非瞬时成员数据）从硬盘文件或二进制数据读取到输入流。

FileInputStream fis = new FileInputStream("t.tmp");
ObjectInputStream ois = new ObjectInputStream(fis);

int i = ois.readInt();
String today = (String) ois.readObject();
Date date = (Date) ois.readObject();

ois.close();

4、ObjectOutputStream类

将基本数据类型和实现了java.io.Serializable接口的类对象（非静态成员和非瞬时成员数据）写入到OutputStream流，从而实现对象的持久存储和网络传输。

FileOutputStream fos = new FileOutputStream("t.tmp");
ObjectOutputStream oos = new ObjectOutputStream(fos);

oos.writeInt(12345);
oos.writeObject("Today");
oos.writeObject(new Date());

oos.close();

5、基础案例

public class Person implements Serializable {

    private static final long serialVersionUID = -641073459191474480L;

    private String name;
    private int age;
    private int weight;
    private int height;

    public Person() {
        super();
    }

    public Person(String name, int age, int weight, int height) {
        super();
        this.name = name;
        this.age = age;
        this.weight = weight;
        this.height = height;
    }

    // getter & setter

    @Override
    public String toString() {
        return "Person [name=" + name + ", age=" + age + ", weight=" + weight + ", height=" + height + "]";
    }
}

public class TestSerializable {

    // 对象序列化
    private static void writeObject() throws Exception {

        ObjectOutputStream oos = new ObjectOutputStream(new FileOutputStream("D:\person.obj"));

        Person p1 = new Person("admin1", 20, 170, 60);
        Person p2 = new Person("admin2", 21, 171, 61);

        oos.writeObject(p1);
        oos.writeObject(p2);

        oos.close();
    }

    // 对象反序列化
    private static void readObject() throws Exception {

        ObjectInputStream ois = new ObjectInputStream(new FileInputStream("D:\person.obj"));

        Person p1 = (Person) ois.readObject();
        Person p2 = (Person) ois.readObject();

        System.out.println(p1);
        System.out.println(p2);

        ois.close();
    }

    public static void main(String[] args) throws Exception {

        // 对象序列化
        writeObject();

        // 对象反序列化
        readObject();

    }
}