个人做淘宝客网站要备案吗,免费ai写作网站3000字,HS酒店网站建设,百度在西安有分公司吗我对于流的理解是这样的#xff0c;计算机的本质本来就是对输入的数据进行操作#xff0c;然后将结果输出的一种工具#xff0c;数据在各个数据源节点之间进行流动#xff0c;感觉流就是对这种状态的一种抽象#xff0c;一个数据流表示的就是一系列数据序列#xff0c;ja… 我对于流的理解是这样的计算机的本质本来就是对输入的数据进行操作然后将结果输出的一种工具数据在各个数据源节点之间进行流动感觉流就是对这种状态的一种抽象一个数据流表示的就是一系列数据序列java存在现成的类库可以实现数据的主动获取和处理这些操作数据的类库构成了java的I/O体系。 流根据不同的方面可以分成不同的类型根据流向可分为输入流和输出流根据操作的数据单元不同可分为字节流8bit和字符流16bitUnicode编码。 在这里将流分成字节流和字符流来对java中相应的处理类做一下分类I/O一般用于对在文件和网络之间流动的数据做处理以处理以文件为载体的数据作为实例。 介绍一下常用到的流先说一下字节流处理字节流的两个顶级抽象父类是处理输入流的InputStream和处理输出流的OutputStream。当处理文件时可以使用他们的子类 FileInputStream 和 FileOutputStream代码如下
public class StreamTest {public static void main(String[] args) {StreamTest test new StreamTest();
// test.testFileInputStream();
// test.testFileOutputStream();test.testCopyFile();}/*** 使用输入流读取文件中的信息然后打印* author chaizepeng**/public void testFileInputStream() {InputStream inputStream null;File file new File(E:\\test\\input.txt);try {inputStream new FileInputStream(file);//将文件中的数据读入到输入流中byte[] b new byte[1024];inputStream.read(b);//从输入流中读取1024个字节String s new String(b, utf-8);System.out.println(s);} catch (Exception e) {e.printStackTrace();}finally {//使用流操作非常耗资源所以在使用完之后要及时关闭if (inputStream ! null) {try {inputStream.close();} catch (IOException e) {e.printStackTrace();}}}}/*** 使用输出流写出数据到文件中* author chaizepeng**/public void testFileOutputStream() {File file new File(E:\\test\\output.txt);OutputStream outputStream null;try {outputStream new FileOutputStream(file);//将数据流指向指定的文件String s hello world;byte[] bytes s.getBytes(utf-8);outputStream.write(bytes);//将字节数组中的数据写入到输出流指向的文件中outputStream.flush();//刷新输出流保证数据写入成功} catch (Exception e) {e.printStackTrace();}finally {//使用流操作非常耗资源所以在使用完之后要及时关闭if (outputStream ! null) {try {outputStream.close();} catch (IOException e) {e.printStackTrace();}}}}/*** 将 E:\\test\\input.txt 复制到 E:\\test\\copy.txt* author chaizepeng**/public void testCopyFile() {InputStream inputStream null;OutputStream outputStream null;File file new File(E:\\test\\copy.txt);if (!file.exists()) {try {file.createNewFile();} catch (IOException e) {e.printStackTrace();}}try {inputStream new FileInputStream(E:\\test\\input.txt);//将文件中的数据读入到输入流中//想往文件中追加信息时使用另一个构造器即可new FileOutputStream(file,true)outputStream new FileOutputStream(file);//将输出流对准一个文件byte[] b new byte[1024];int len 0;while ((len inputStream.read(b,0,b.length)) ! -1) {//每次读取1024个字节outputStream.write(b,0,len);//将读取到的字节序列写入到输出流对应的文件中知道输入流在文件中获取到的数据列长度为0}outputStream.flush();} catch (Exception e) {e.printStackTrace();}finally {//使用流操作非常耗资源所以在使用完之后要及时关闭try {if (outputStream ! null) {outputStream.close();}if (inputStream ! null) {inputStream.close();} }catch (IOException e) {e.printStackTrace();}}}
}
想将数据从内存中读出并写入到另一块内存中时可以使用子类 ByteArrayInputStream 和 ByteArrayOutputStream 代码如下
public class ByteArrayStreamTest {public static void main(String[] args) {ByteArrayStreamTest test new ByteArrayStreamTest();test.testByteArrayStream();}/*** 用于在内存中输入和输出不必依赖磁盘也就是不用创建File类* 因为处理的是内存中的数据所以也不是非要关闭资源不可*/public void testByteArrayStream() {//ByteArrayInputStream 用于从内存中不是在磁盘上读入数据并创建一个输入流对象byte []b hello world.getBytes();ByteArrayInputStream inputStream new ByteArrayInputStream(b);ByteArrayOutputStream outputStream new ByteArrayOutputStream(1024);byte []temp new byte[4];//创建一个临时的数组用于转移数据int len 0;while ((len inputStream.read(temp,0,temp.length) ) ! -1) {outputStream.write(temp,0,len);//将内存中}System.out.println(outputStream.toString());//在输出流中获取写入到指定内存的数据}
}说一下字符流例如当处理一些中文文件时使用字节流如果遇到突发事件可能会因为编码问题导致文件损坏处理一些中文文件时可以选择字符流处理文本文件时都可使用为了不必要的麻烦最好使用字节流处理一些非文本文件时必须使用字节流。字符流的两个顶级接口是Reader和Writer如果处理文件时可以使用FileReader和FileWriter代码如下
public class CharStreamTest {public static void main(String[] args) {CharStreamTest test new CharStreamTest();test.testReaderTest();}/*** 将E:\\test\\reader.txt 复制到 E:\\test\\writer.txt **/public void testReaderTest() {FileWriter writer null;FileReader reader null;File file new File(E:\\test\\writer.txt);if (!file.exists()) {try {file.createNewFile();} catch (IOException e) {e.printStackTrace();}}try {reader new FileReader(E:\\test\\reader.txt);writer new FileWriter(file);char []b new char[1024];int len 0;while((len reader.read(b, 0, b.length)) ! -1) {writer.write(b, 0, len);}writer.flush();} catch (IOException e) {e.printStackTrace();}finally {//使用流操作非常耗资源所以在使用完之后要及时关闭try {if (writer ! null) {writer.close();}if (reader ! null) {reader.close();} }catch (IOException e) {e.printStackTrace();}}}} 为了提高读入和写出的效率java提供了缓冲流使用缓冲流就相当于在内存中直接获取数据而不需要频繁的去调用外部方法操作磁盘大大提高了效率缓冲流中维护了一个内存数组每次读取数据时都在数组中获取通过一定的机制当数组中没有数据或者数据已经读取完时就会调用一次应用的c或c的方法操作一次磁盘提高了效率。源码分析如下
//通过源码来解释为什么缓冲流效率高//首先看一下不使用缓冲流//FileInputStream中的read方法全都是最后调用native修饰的c或者c的方法//也就是说当使用FileInputStream去读取数据时每读取一次都会去磁盘中获取一次数据//每次都去访问磁盘导致效率底public int read() throws IOException {return read0();}private native int read0() throws IOException;private native int readBytes(byte b[], int off, int len) throws IOException;public int read(byte b[]) throws IOException {return readBytes(b, 0, b.length);}public int read(byte b[], int off, int len) throws IOException {return readBytes(b, off, len);}//BufferedInputStream中的read方法//创建缓冲流对象时维护了一个数组public BufferedInputStream(InputStream in, int size) {buf new byte[size];}//调用的read方法public synchronized int read(byte b[], int off, int len){//删减一些代码read中会调用read1方法int nread read1(b, off n, len - n);//在内存数组中获取数据而不是去磁盘中获取这也就是网上一直所说的不再是读一次获取一次而是一次性读取多个放到内存中大大节省了效率System.arraycopy(getBufIfOpen(), pos, b, off, cnt);}//调用的read1方法private int read1(byte[] b, int off, int len) throws IOException {//删减一些代码read1中会调用InputStream中的read方法getInIfOpen().read(b, off, len);}//调用的read1方法getInIfOpenprivate InputStream getInIfOpen() throws IOException {//而返回的正好是构造缓冲流时传入的字节流in所以说到底最后直接去磁盘获取数据的还是应用的c/c的代码只不过一次获取固定大小长度的字节数据放到缓冲流类中维护的内存数组中InputStream input in;if (input null)throw new IOException(Stream closed);return input;}
针对字节流提供了BufferedInputStream 和 BufferedOutputStream 两个缓冲流用法如下
public class BufferStreamTest {public static void main(String[] args) {BufferStreamTest test new BufferStreamTest();test.testInputBufferedStream();}public void testInputBufferedStream() {BufferedInputStream bufferedInputStream null;BufferedOutputStream bufferedOutputStream null;File file new File(E:\\test\\bufferedoutput.ppt);try {bufferedInputStream new BufferedInputStream(new FileInputStream(E:\\czp\\Learning Materials\\笔记\\io.ppt));bufferedOutputStream new BufferedOutputStream(new FileOutputStream(file));byte[] b new byte[1024];int len;while((len bufferedInputStream.read(b ,0 ,b.length)) ! -1) {bufferedOutputStream.write(b, 0, len);}bufferedOutputStream.flush();} catch (FileNotFoundException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally {try {if (bufferedOutputStream!null) {bufferedOutputStream.close();}if (bufferedInputStream!null) {bufferedInputStream.close();}} catch (Exception e2) {e2.printStackTrace();}}}
}
针对字符流提供了BufferedReader 和 BufferedWriter 用法如下
public class BufferStreamTest {public static void main(String[] args) {BufferStreamTest test new BufferStreamTest();test.testBufferCharStream();}public void testBufferCharStream() {BufferedReader bufferedReader null;BufferedWriter bufferedWriter null;File file new File(E:\\test\\bufferedreader.txt);try {FileReader reader new FileReader(E:\\czp\\Learning Materials\\ceshi.txt);//BufferedReader 的数据源是一个字符输入流bufferedReader new BufferedReader(reader);bufferedWriter new BufferedWriter(new FileWriter(file));String s ;while( (s bufferedReader.readLine()) ! null) {//每次读取一行数据System.out.println(s);bufferedWriter.write(s);bufferedWriter.newLine();//换行bufferedWriter.flush();//刷新缓冲区} } catch (FileNotFoundException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally {//关闭资源try {if (bufferedWriter!null) {bufferedWriter.close();}if (bufferedReader!null) {bufferedReader.close();}} catch (Exception e2) {e2.printStackTrace();}}}
}
有的时候想用字符流进行数据的读写但是呢提供的只有数据的字节流这时便可使用转换流代码如下
public class ConvertStreamTest {public static void main(String[] args) throws IOException {ConvertStreamTest test new ConvertStreamTest();test.testInputStreamReader();test.testOutputStreamWriter();}/*** 字节输入流转换成字符输入流 */public void testInputStreamReader() throws IOException {FileInputStream fileInputStream null;//字节输入流Reader inputStreamReader null;//字符输入流try {//获取一个字节输入流fileInputStream new FileInputStream(E:\\czp\\Learning Materials\\ceshi.txt);//通过转换输入流 InputStreamReader 的构造方法构造一个字符输入流inputStreamReader new InputStreamReader(fileInputStream,utf-8);char []ch new char[2048];inputStreamReader.read(ch);//正常的在流中读取数据System.out.println(new String(ch));} catch (Exception e) {}finally {if (inputStreamReader!null) {inputStreamReader.close();}if (fileInputStream! null) {fileInputStream.close();}}}/*** 字节输出流转换成字符输出流 */public void testOutputStreamWriter() throws IOException {FileOutputStream fileOutputStream null;Writer writer null;try {fileOutputStream new FileOutputStream(E:\\test\\bufferedreader.txt);writer new OutputStreamWriter(fileOutputStream, gbk);writer.write(测试转换流);} catch (Exception e) {}finally {if (writer ! null) {writer.close();}if (fileOutputStream!null) {fileOutputStream.close();}}}
} 使用java也可实现文件的压缩和解压缩使用到的两个类是GZIPInputStream、GZIPOutputStream他们是util包下的类不是io包下。代码如下
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;public class GZIPStreamTest {public static void main(String[] args) throws IOException {GZIPStreamTest test new GZIPStreamTest();test.testZipStream();test.testUnZipStream();}/*** 压缩操作* 将E:\\czp\\Learning Materials\\ceshi.txt 压缩到 E:\\test\\a.zip*/public void testZipStream() throws IOException {FileInputStream fileInputStream null;FileOutputStream fileOutputStream null;GZIPOutputStream gzipOutputStream null;File file new File(E:\\test\\a.zip);try {fileInputStream new FileInputStream(E:\\czp\\Learning Materials\\ceshi.txt);fileOutputStream new FileOutputStream(file);gzipOutputStream new GZIPOutputStream(fileOutputStream);byte []by new byte[1024];int len 0;while((len fileInputStream.read(by, 0, by.length)) ! -1) {gzipOutputStream.write(by, 0, len);gzipOutputStream.flush();}} catch (Exception e) {}finally {if (gzipOutputStream ! null) {gzipOutputStream.close();}if (fileOutputStream ! null) {fileOutputStream.close();}if (fileInputStream ! null) {fileInputStream.close();}}}/*** 解压操作*/public void testUnZipStream() throws IOException {FileInputStream fileInputStream null;FileOutputStream fileOutputStream null;GZIPInputStream gzipInputStream null;File file new File(E:\\test\\b.txt);try {fileInputStream new FileInputStream(E:\\test\\a.zip);gzipInputStream new GZIPInputStream(fileInputStream);fileOutputStream new FileOutputStream(file);byte []by new byte[1024];int len 0;while((len gzipInputStream.read(by, 0, by.length)) ! -1) {fileOutputStream.write(by, 0, len);fileOutputStream.flush();}} catch (Exception e) {}finally {if (fileOutputStream ! null) {fileOutputStream.close();}if (gzipInputStream ! null) {gzipInputStream.close();}if (fileInputStream ! null) {fileInputStream.close();}}}
}以上只是对java中I/O体系中常用的几个类做了简单的介绍真正用的时候可以参考API。
