各种流的使用方法。

标签：

//读取键盘录入将数据转成大写显示在控制台.
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));//源：键盘输入
//目的：把数据写到文件中，还想自动刷新。
PrintWriter out = new PrintWriter(new FileWriter("out.txt"),true);//设置true后自动刷新
String line = null;
while((line=bufr.readLine())!=null){
	if("over".equals(line))
		break;
	out.println(line.toUpperCase());//转大写输出
}
	//注意：System.in，System.out这两个标准的输入输出流，在jvm启动时已经存在了。随时可以使用。当jvm结束了，这两个流就结束了。但是，当使用了显示的close方法关闭时，这两个流在提前结束了。
out.close();
bufr.close();

import java.io.*;
import java.util.*;
class  SplitFileDemo{
	private static final String CFG = ".properties";
	private static final String SP = ".part";
	public static void main(String[] args) throws IOException{
		File file = new File("c:\\0.bmp");
		File dir = new File("c:\\partfiles");
		meger(dir);
	}
	//数据的合并。
	public static void meger(File dir)throws IOException{
		if(!(dir.exists() && dir.isDirectory()))
			throw new RuntimeException("指定的目录不存在，或者不是正确的目录");
		File[] files = dir.listFiles(new SuffixFilter(CFG));
		if(files.length==0)
			throw new RuntimeException("扩展名.proerpties的文件不存在");
		//获取到配置文件
		File config = files[0];
		//获取配置文件的信息。
		Properties prop = new Properties();
		FileInputStream fis = new FileInputStream(config);
		prop.load(fis);
		String fileName = prop.getProperty("filename");
		int partcount = Integer.parseInt(prop.getProperty("partcount"));
		//--------------------------
		File[] partFiles = dir.listFiles(new SuffixFilter(SP));
		if(partFiles.length!=partcount)
			throw new RuntimeException("缺少碎片文件");
		//---------------------
		ArrayList<FileInputStream> al = new ArrayList<FileInputStream>();
		for(int x=0; x<partcount; x++){
			al.add(new FileInputStream(new File(dir,x+SP)));
		}
		Enumeration<FileInputStream> en = Collections.enumeration(al);
		SequenceInputStream sis = new SequenceInputStream(en);
		File file = new File(dir,fileName);
		FileOutputStream fos = new FileOutputStream(file);
		byte[] buf = new byte[1024];
		int len = 0;
		while((len=sis.read(buf))!=-1){
			fos.write(buf,0,len);
		}
		fos.close();
		sis.close();
	}
	//带有配置信息的数据切割。
	public static void splitFile(File file)throws IOException{
		//用一个读取流和文件关联。
		FileInputStream fis = new FileInputStream(file);
		//创建目的地。因为有多个。所以先创建引用。
		FileOutputStream fos = null;
		//指定碎片的位置。
		File dir = new File("c:\\partfiles");
		if(!dir.exists())
			dir.mkdir();
		//碎片文件大小引用。
		File f = null;
		byte[] buf = new byte[1024*1024];
		//因为切割完的文件通常都有规律的。为了简单标记规律使用计数器。
		int count = 0;
		int len = 0;
		while((len=fis.read(buf))!=-1){
			f = new File(dir,(count++)+".part");
			fos = new FileOutputStream(f);
			fos.write(buf,0,len);
			fos.close();
		}
		//碎片文件生成后，还需要定义配置文件记录生成的碎片文件个数。以及被切割文件的名称。
		//定义简单的键值信息，可是用Properties。
		String filename = file.getName();
		Properties prop = new Properties();
		prop.setProperty("filename",filename);
		prop.setProperty("partcount",count+"");
		File config = new File(dir,count+".properties");
		fos = new FileOutputStream(config);
		prop.store(fos,"");
		fos.close();
		fis.close();
	}
}
class SuffixFilter implements FileFilter{
	private String suffix;
	SuffixFilter(String suffix){
		this.suffix  = suffix;
	}
	public boolean accept(File file){
		return  file.getName().endsWith(suffix);
	}
}

class RandomAccessFileDemo{
	public static void main(String[] args) throws IOException{
		write();
		read();
		randomWrite();
	}
	//随机写入数据，可以实现已有数据的修改。
	public static void randomWrite()throws IOException{
		RandomAccessFile raf = new RandomAccessFile("random.txt","rw");
		raf.seek(8*4);
		System.out.println("pos :"+raf.getFilePointer());
		raf.write("王武".getBytes());
		raf.writeInt(102);
		raf.close();
	}
	public static void read()throws IOException{
		RandomAccessFile raf = new RandomAccessFile("random.txt","r");//只读模式。
		//指定指针的位置。
		raf.seek(8*1);//实现随机读取文件中的数据。注意：数据最好有规律。
		System.out.println("pos1 :"+raf.getFilePointer());
		byte[] buf = new byte[4];
		raf.read(buf);
		String name = new String(buf);
		int age = raf.readInt();
		System.out.println(name+"::"+age);
		System.out.println("pos2 :"+raf.getFilePointer());
		raf.close();
	}
	public static void write()throws IOException{
		//rw：当这个文件不存在，会创建该文件。当文件已存在，不会创建。所以不会像输出流一样覆盖。
		RandomAccessFile raf = new RandomAccessFile("random.txt","rw");//rw读写模式
		//往文件中写入人的基本信息，姓名，年龄。
		raf.write("张三".getBytes());
		raf.writeInt(97);
		raf.close();
	}
}

public static void main(String[] args) throws IOException{
	PipedInputStream pipin = new PipedInputStream();
	PipedOutputStream pipout = new PipedOutputStream();
	pipin.connect(pipout);
	new Thread(new Input(pipin)).start();
	new Thread(new Output(pipout)).start();
}

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"));
		Object obj = ois.readObject();//读取一个对象。
		System.out.println(obj.toString());
	}
	public static void writeObj()throws IOException{
		ObjectOutputStream oos = new ObjectOutputStream(new FileOutputStream("obj.txt"));
		oos.writeObject(new Person("lisi",25)); //写入一个对象。
		oos.close();
	}
}
class Person implements Serializable{
	private static final long serialVersionUID = 42L;
	private transient String name;//用transient修饰后name将不会进行序列化
	public int age;
	Person(String name,int age){
		this.name = name;
		this.age = age;
	}
	public String toString(){
		return name+"::"+age;
	}
}
-----------------------------------------------------------------------------------------------
DataOutputStream、DataInputStream：专门用于操作基本数据类型数据的对象。
DataOutputStream dos =  new DataOutputStream(new FileOutputStream("data.txt"));
	dos.writeInt(256);
	dos.close();


	DataInputStream dis = new DataInputStream(new FileInputStream("data.txt"));
	int num = dis.readInt();
	System.out.println(num);
	dis.close();

	ByteArrayInputStream bis = new ByteArrayInputStream("abcdef".getBytes());
	//创建目的：
	ByteArrayOutputStream bos = new ByteArrayOutputStream();
	int ch = 0;
	while((ch=bis.read())!=-1){
		bos.write(ch);
	}
	System.out.println(bos.toString());

各种流的使用方法。

标签：

原文地址：http://blog.csdn.net/qiang3570/article/details/44259435