import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.Serializable;
@SuppressWarnings("serial")
//一個(gè)類(lèi)要想實(shí)現(xiàn)序列化則必須實(shí)現(xiàn)Serializable接口
class Person implements Serializable {
private String name;
private int age;
public Person(String name, int age) {
this.name = name;
this.age = age;
}
public String toString() {
return "Name:" + this.name + ", Age:" + this.age;
}
}
public class Demo {
public static void main(String[] args) {
String path = File.separator + "home" + File.separator + "siu" +
File.separator + "work" + File.separator + "demo.txt";
Person p1 = new Person("zhangsan",12);
Person p2 = new Person("lisi",14);
//此處創(chuàng)建文件寫(xiě)入流的引用是要給ObjectOutputStream的構(gòu)造函數(shù)玩兒
FileOutputStream fos = null;
ObjectOutputStream oos = null;
try {
fos = new FileOutputStream(path);
oos = new ObjectOutputStream(fos);
//這里可以寫(xiě)入對(duì)象，也可以寫(xiě)入其他類(lèi)型數(shù)據(jù)
oos.writeObject(p1);
oos.writeObject(p2);
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
oos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
public class Demo {
public static void main(String[] args) {
String path = File.separator + "home" + File.separator + "siu" +
File.separator + "work" + File.separator + "demo.txt";
//好吧，這里代碼寫(xiě)得著實(shí)有點(diǎn)長(zhǎng)了，還要拋異常什么的
//如果你也看的煩，那就在主方法上拋吧，構(gòu)造方法里用匿名對(duì)象就好了
//什么？別告訴我你不知道匿名對(duì)象
FileInputStream fis = null;
ObjectInputStream ois = null;
try {
fis = new FileInputStream(path);
ois = new ObjectInputStream(fis);
//這里返回的其實(shí)是一個(gè)Object類(lèi)對(duì)象
//因?yàn)槲覀円阎莻€(gè)Person類(lèi)對(duì)象
//所以，就地把它給向下轉(zhuǎn)型了
Person p = (Person)ois.readObject();
System.out.println(p);
//拋死你，煩煩煩～?。?！
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} finally {
try {
//還是要記得關(guān)閉下流
ois.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
//實(shí)現(xiàn)Runnable接口，實(shí)現(xiàn)一個(gè)讀的線程
class Read implements Runnable {
private PipedInputStream in;
//將需要讀的管道流傳入到構(gòu)造函數(shù)中
public Read(PipedInputStream in) {
this.in = in;
}
//實(shí)現(xiàn)讀這一線程
public void run() {
try {
byte[] buf = new byte[1024];
int temp = 0;
//循環(huán)讀取
//read是一個(gè)阻塞方法，需要拋異常
//此處把打印流的代碼也加入進(jìn)來(lái)
//是因?yàn)槿绻麤](méi)有讀取到數(shù)據(jù)，那么打印的代碼也無(wú)效
while((temp = in.read(buf)) != -1) {
String str = new String(buf,0,temp);
System.out.println(str);
}
} catch (IOException e) {
//其實(shí)這里應(yīng)拋出一個(gè)自定義異常的
//暫時(shí)我還沒(méi)弄清楚
e.printStackTrace();
} finally {
try {
//我已經(jīng)拋火了，這只是為了提醒自己異常很重要
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
//這里實(shí)現(xiàn)一個(gè)寫(xiě)的類(lèi)
class Write implements Runnable {
private PipedOutputStream out;
//將管道輸入流傳進(jìn)來(lái)
public Write(PipedOutputStream out) {
this.out = out;
}
public void run() {
try {
//這里開(kāi)始寫(xiě)出數(shù)據(jù)
out.write("管道輸出".getBytes());
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
//其實(shí)應(yīng)該可以把這個(gè)關(guān)閉方法寫(xiě)到上面那個(gè)try里邊
//但是這樣感覺(jué)怪怪的，邏輯不大對(duì)
out.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
public class Demo {
public static void main(String[] args) {
PipedInputStream in = new PipedInputStream();
PipedOutputStream out = new PipedOutputStream();
try {
//連接管道
in.connect(out);
//創(chuàng)建對(duì)象，開(kāi)啟線程
//此處同樣放進(jìn)try...catch里面
//因?yàn)槿绻麤](méi)有鏈接管道，下面操作無(wú)意義
Read r = new Read(in);
Write w = new Write(out);
//把已經(jīng)實(shí)現(xiàn)好run方法的對(duì)象放入線程中執(zhí)行
new Thread(r).start();
new Thread(w).start();
} catch (IOException e) {
e.printStackTrace();
}
}
}

import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
public class Demo {
public static void main(String[] args) {
String path = File.separator + "home" + File.separator + "siu" +
File.separator + "work" + File.separator + "demo.txt";
DataOutputStream d = null;
try {
//此處需要傳入一個(gè)OutputStream類(lèi)的對(duì)象
d = new DataOutputStream(new FileOutputStream(path));
//開(kāi)始寫(xiě)入基本數(shù)據(jù)類(lèi)型
d.writeInt(12);
d.writeBoolean(true);
d.writeDouble(12.2223);
d.writeChar(97);
//刷新流
d.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
d.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
public class Demo {
public static void main(String[] args) {
String path = File.separator + "home" + File.separator + "siu" +
File.separator + "work" + File.separator + "demo.txt";
DataInputStream d = null;
try {
d = new DataInputStream(new FileInputStream(path));
//按存儲(chǔ)順序讀取基本數(shù)據(jù)類(lèi)型
System.out.println(d.readInt());
System.out.println(d.readBoolean());
System.out.println(d.readDouble());
System.out.println(d.readChar());
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
d.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}