Java NIO详解（学习资料）

Java NIO 详解

前言

本篇主要讲解 Java 中的 IO 机制和网络通讯中处理高并发的 NIO

分为两块：

第一块讲解多线程下的 IO 机制

第二块讲解如何在 IO 机制下优化 CPU 资源的浪费（New IO）

Echo 服务器

单线程下的 socket 机制就不用我介绍了，不懂得可以去查阅下资料

那么多线程下，如果进行套接字的使用呢？

在这里我写了一个简单的服务器

用到了线程池的技术来创建线程（具体代码作用我已经加了注释）：

public class MyServer {

private static ExecutorService executorService = Executors.newCachedThreadPool();

//创建一个线程池

private static class HandleMsg implements Runnable{ //一旦有新的客户端请

求，创建这个线程进行处理

Socket client; //创建一个客户端

public HandleMsg(Socket client){ //构造传参绑定

this.client = client;

bufferedReader = new BufferedReader(new

InputStreamReader(client.getInputStream())); //获取客户端的输入流

printWriter = new PrintWriter(client.getOutputStream(),true);

//获取客户端的输出流，true 是随时刷新

String inputLine = null;

long a = System.currentTimeMillis();

while ((inputLine = bufferedReader.readLine())!=null){

printWriter.println(inputLine);

}

long b = System.currentTimeMillis();

System.out.println("此线程花费了："+(b-a)+"秒！");

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

public static void main(String[] args) throws IOException { //服务端的主线程是

用来循环监听客户端请求

ServerSocket server = new ServerSocket(8686); //创建一个服务端且端口为

8686

Socket client = null;

while (true){ //循环监听

client = server.accept(); //服务端监听到一个客户端请求

System.out.println(client.getRemoteSocketAddress()+"地址的客户端连接成功!");

executorService.submit(new HandleMsg(client)); //将该客户端请求通过线程池

放入 HandlMsg 线程中进行处理

}

上述代码中我们使用一个类编写了一个简单的 echo 服务器

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

Socket client = null;

PrintWriter printWriter = null;

BufferedReader bufferedReader = null;

try {

client = new Socket();

client.connect(new InetSocketAddress("localhost",8686));

printWriter = new PrintWriter(client.getOutputStream(),true);

printWriter.println("hello");

printWriter.flush();