JAVA IO流相关代码（Serializable接口，管道流PipedInputStream类，RandomAccessFile类相关代码）

Posted 2022-02-06 小乖乖的臭坏坏

Serializable接口

**Serializable接口的作用：**1、存储对象在存储介质中，以便在下次使用的时候，可以很快捷的重建一个副本；2、便于数据传输，尤其是在远程调用的时候。
Person.java

import java.io.*;
class Person implements Serializable

	
	public static final long serialVersionUID = 42L;

	private String name;
	transient int age;//在持久化对象时，对于一些特殊的数据成员（如用户的密码，银行卡号等），我们不想用序列化机制来保存它。为了在一个特定对象的一个成员变量上关闭序列化，可以在这个成员变量前加上关键字transient。
	static String country = "cn";
	Person(String name,int age,String country)
	
		this.name = name;
		this.age = age;
		this.country = country;
	
	public String toString()
	
		return name+":"+age+":"+country;
	

ObjectStreamDemo.java

import java.io.*;

class ObjectStreamDemo 

	public static void main(String[] args) throws Exception
	
		//writeObj();
		readObj();
	
	public static void readObj()throws Exception
	
		ObjectInputStream ois = new ObjectInputStream(new FileInputStream("obj.txt"));

		Person p = (Person)ois.readObject();

		System.out.println(p);
		ois.close();
	

	public static void writeObj()throws IOException
	
		ObjectOutputStream oos = 
			new ObjectOutputStream(new FileOutputStream("obj.txt"));

		oos.writeObject(new Person("lisi0",399,"kr"));

		oos.close();
	

管道流示例代码

import java.io.*;

class Read implements Runnable

	private PipedInputStream in;
	Read(PipedInputStream in)
	
		this.in = in;
	
	public void run()
	
		try
		
			byte[] buf = new byte[1024];

			System.out.println("读取前。。没有数据阻塞");
			int len = in.read(buf);
			System.out.println("读到数据。。阻塞结束");



			String s= new String(buf,0,len);

			System.out.println(s);

			in.close();

		
		catch (IOException e)
		
			throw new RuntimeException("管道读取流失败");
		
	


class Write implements Runnable

	private PipedOutputStream out;
	Write(PipedOutputStream out)
	
		this.out = out;
	
	public void run()
	
		try
		
			System.out.println("开始写入数据，等待6秒后。");
			Thread.sleep(6000);
			out.write("piped lai la".getBytes());
			out.close();
		
		catch (Exception e)
		
			throw new RuntimeException("管道输出流失败");
		
	


class  PipedStreamDemo

	public static void main(String[] args) throws IOException
	

		PipedInputStream in = new PipedInputStream();
		PipedOutputStream out = new PipedOutputStream();
		in.connect(out);

		Read r = new Read(in);
		Write w = new Write(out);
		new Thread(r).start();
		new Thread(w).start();


	

RandomAccessFile类示例代码：

该类不是算是IO体系中子类。
而是直接继承自Object。

但是它是IO包中成员。因为它具备读和写功能。
内部封装了一个数组，而且通过指针对数组的元素进行操作。
可以通过getFilePointer获取指针位置，
同时可以通过seek改变指针的位置。

其实完成读写的原理就是内部封装了字节输入流和输出流。

通过构造函数可以看出，该类只能操作文件。
而且操作文件还有模式：只读r，，读写rw等。

如果模式为只读 r。不会创建文件。会去读取一个已存在文件，如果该文件不存在，则会出现异常。
如果模式rw。操作的文件不存在，会自动创建。如果存则不会覆盖。

class RandomAccessFileDemo 

	public static void main(String[] args) throws IOException
	
		//writeFile_2();
		//readFile();

		//System.out.println(Integer.toBinaryString(258));

	

	public static void readFile()throws IOException
	
		RandomAccessFile raf = new RandomAccessFile("ran.txt","r");
		
		//调整对象中指针。
		//raf.seek(8*1);

		//跳过指定的字节数
		raf.skipBytes(8);

		byte[] buf = new byte[4];

		raf.read(buf);

		String name = new String(buf);

		int age = raf.readInt();


		System.out.println("name="+name);
		System.out.println("age="+age);

		raf.close();


	

	public static void writeFile_2()throws IOException
	
		RandomAccessFile raf = new RandomAccessFile("ran.txt","rw");
		raf.seek(8*0);
		raf.write("周期".getBytes());
		raf.writeInt(103);

		raf.close();
	

	public static void writeFile()throws IOException
	
		RandomAccessFile raf = new RandomAccessFile("ran.txt","rw");

		raf.write("李四".getBytes());
		raf.writeInt(97);
		raf.write("王五".getBytes());
		raf.writeInt(99);

		raf.close();
	

参考：
毕向东Java