csdn:blog.csdn.net/Kibaco

微信公众号: 杨正友

学习目标

java传统io如何使用

非阻塞 nio 是怎么回事

okio 的优势与使用

java传统io: 流

从文件读数据到内存里面,方便操作网络数据和本地文件,操作更加灵活了,所有的操作都是利用String来代替

熟悉java io 的基本操作

就是 24_io.txt 如果没有 就会帮忙创建,如果有就不会创建,这个就是用java io做的一个基本操作

try {

// 输出流的管子

final FileOutputStream fileOutputStream = new FileOutputStream("./24_io/24_io.txt");

fileOutputStream.write('a');

fileOutputStream.write('b');

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

复制代码

不是直接操作文件,而是直接操作流,通过一根管子,插到这个文件上,然后对这个流进行操作,这样可以对不同的外部对象使用统一的操作形式,不管是往一个文件还是网络还是其他形式,我都是创造一个String的格式,然后往这个String 去写 或者 去存 然后去读 这个String,相当于在程序内部和外界之间搭建了一个桥梁 ,我虽然把处理单件事件变复杂了,比如:我一辈子都处理文件,或者一辈子处理网络 ,把这个变复杂了,但是整体上有一个一致性,所以扩展性变更好了,由于这个扩展性,他做的事情也变多了,不止是可以读写文件,还可以和网络交互,而且还有其他形式可以和网络操作,也可以通过其他扩展的String来操作

java 文件的 读取操作

资源的持有会消耗内存,所以我们在不需要这些资源的时候我们需要释放这些资源,所谓的释放就是把文件关闭,把文件的关闭本质就是把流给舍弃调,java 7 以下我们需要在 finally处理如下:

InputStream sFileInputStream = null;

try {

sFileInputStream = new FileInputStream("./24_io/24_io.txt");

System.out.println((char) sFileInputStream.read());

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

if (sFileInputStream != null) {

try {

sFileInputStream.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

复制代码

java 7 以及以上 在 try () 处理即可,自动关流

try (InputStream sFileInputStream = new FileInputStream("./24_io/24_io.txt")) {

System.out.println((char) sFileInputStream.read());

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

复制代码

所有的流都实现了 Closeable,所有的 Closeable 如果在try 里面做初始化 都会被自动关闭

public abstract class InputStream implements Closeable {}

复制代码

怎么和文件进行互操作,怎么把文件转换成字符?

try (InputStream sFileInputStream = new FileInputStream("./24_io/24_io.txt")) {

Reader inputStreamReader = new InputStreamReader(sFileInputStream);

final BufferedReader bufferedInputStream = new BufferedReader(inputStreamReader);

System.out.println(bufferedInputStream.readLine());

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

复制代码

readLine的本身的意义不是一行读,他会额外读一些内容到自己内部,它本身的意思是增加缓冲,他会额外读一些内容到缓冲

从BufferReader 源码可以看出:

private static int defaultCharbufferSize = 8192

复制代码

默认可以读 8192 个字节,为了提高性能,我们必须设置一个默认值

Buffer 写数据 其实是在缓冲里面放数据,所以写完之后记得及时 flush 将目标东西刷新到目标区

try (OutputStream sFileInputStream = new FileOutputStream("./24_io/24_io.txt")) {

final BufferedOutputStream inputStream = new BufferedOutputStream(sFileInputStream);

inputStream.write('a');

inputStream.write('b');

inputStream.write('M');

inputStream.flush();

} catch (Exception e) {

e.printStackTrace();

}

复制代码

如: outPutStream 没有 flush 不会写成功的,那么为什么Buffer不能自动刷新呢?

因为缓冲是为了做效率, 和文件操作性能会比较低,所以尽量减少这样的操作,把频率降低,把多次io给合起来,这样才能提高性能呢.Buffer 会导致输出不同步这是必然的事情

同样在 try 里面 做数据包装操作,也会自动刷新缓存到目标区

try (OutputStream sFileInputStream = new FileOutputStream("./24_io/24_io.txt"); final BufferedOutputStream inputStream = new BufferedOutputStream(sFileInputStream)) {

inputStream.write('a');

inputStream.write('b');

inputStream.write('M');

} catch (Exception e) {

e.printStackTrace();

}

复制代码

文件复制

java没有文件复制的功能的,那么怎么做文件复制呢,我们要做的是把文件数据一个一个搬

try (InputStream fileInputStream = new FileInputStream("./24_io/24_io.txt");

OutputStream outputstream = new FileOutputStream("./24_io/text_copy.txt")) {

final byte[] bytes = new byte[1024];

int read = 0;

while ((read = fileInputStream.read(bytes)) != -1) {

outputstream.write(bytes, 0, read);

}

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

复制代码

如果想提高性能 我们可以加 Buffer

这就是 Java 的 I/O 原理,核心就是:内存与外界的交互,你可以用 inputStream 和 outPutStream 做对接

Socket 和 ServerSocket 之间的网络交互

和文件交互是 java i/o 里面 和 网络进行交互的,就像和文件交互 用 File

比如: 我做个服务器

try {

final ServerSocket serverSocket = new ServerSocket(8080);

final Socket socket = serverSocket.accept();

final BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

final BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

while (true) {

final String data = reader.readLine();

writer.write("你给我输入了: " + data);

writer.flush();

}

} catch (IOException e) {

e.printStackTrace();

}

复制代码

nio 与传统 io的区别

传统io用的是插管道的方式



nio 的 Channel 是双向的,传统io是单向的

try {

final RandomAccessFile file = new RandomAccessFile("./24_io/24_io.txt", "r");

final FileChannel channel = file.getChannel();

final ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

channel.read(byteBuffer);

byteBuffer.flip();

System.out.println(Charset.defaultCharset().decode(byteBuffer));

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

复制代码

nio 也用到了缓冲 buffer nio 可以被操作的,nio的Buffer是强制使用的,不好用

try {

final ServerSocketChannel channel = ServerSocketChannel.open();

channel.bind(new InetSocketAddress(8080));

final SocketChannel socketChannel = channel.accept();

final ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

while (socketChannel.read(byteBuffer) != -1) {

byteBuffer.flip();

socketChannel.write(byteBuffer);

byteBuffer.clear();

}

} catch (IOException e) {

e.printStackTrace();

}

复制代码

nio 有非阻塞的支持,只能网络才能使用

try {

final ServerSocketChannel channel = ServerSocketChannel.open();

channel.bind(new InetSocketAddress(8080));

channel.configureBlocking(false);

final SocketChannel socketChannel = channel.accept();

final ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

while (socketChannel.read(byteBuffer) != -1) {

byteBuffer.flip();

socketChannel.write(byteBuffer);

byteBuffer.clear();

}

} catch (IOException e) {

e.printStackTrace();

}

复制代码

为什么 非阻塞式 nio 设置 configureBlocking 开关 会报NullException?

Exception in thread "main" java.lang.NullPointerException

复制代码

因为 channel.accept() 没有拿到数据,socketChannel 为 null,还没有发起请求就设置 false了

okio

okio 作为一个外部对象作为输入输出,okio是独立形式存在的.

try (BufferedSource source = Okio.buffer(Okio.source(new File("./24_io/24_io.txt")) )) {

final Buffer buffer = new Buffer();

source.read(buffer, 1024);

System.out.println(buffer.readUtf8());

} catch (Exception e) {

e.printStackTrace();

}

复制代码

okio 和 传统 io 作交互

final Buffer buffer = new Buffer();

try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(buffer.outputStream()));

BufferedReader bufferReader = new BufferedReader(new InputStreamReader(buffer.inputStream()))) {

writer.write("哈哈哈哈");

writer.flush();

System.out.println("read: " + bufferReader.readLine());

} catch (IOException e) {

e.printStackTrace();

}

复制代码