Netty学习笔记（自用）

2024-02-08 15:25:28

BIO(同步阻塞式IO)：

一个连接一个线程，可以使用线程池调优。

连接成功时，线程只能等待用户动作，无法做其他事情，而如果没有数据可以读则会堵塞在READ操作，造成资源浪费。

package BIO;

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class BIOServer {

    public static void main(String[] args) throws IOException {
        //创建一个线程池
        ExecutorService es=Executors.newCachedThreadPool();
        //创建ServcerSocket
        ServerSocket ss=new ServerSocket(6666);
        System.out.print("FW STARTING");
        while (true){
            //监听等待客户端连接
            final Socket socket = ss.accept();
            System.out.println("GET ONE CONNECT");
            //创建一个线程与之通讯
            es.execute(new Runnable() {
                public void run() {
                    try {
                        handler(socket);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            });

        }
    }
    public static void handler(Socket s) throws IOException{
        byte[] bytes = new byte[1024];
        //通过socket 获取输入流
        InputStream inputStream=s.getInputStream();
        while(true){
            int read = inputStream.read(bytes);
            if(read != -1){
                System.out.println(new String(bytes,0,read));
            }else{
                break;
            }
        }
        System.out.println("CLOSE");
        s.close();
    }
}

NIO（同步非阻塞式IO），全称 java non-blocking IO，java1.4后统称 New IO，面向缓冲区

更多NIO知识见我上篇博客

三大核心：channel 、buffer、selector

IntBuffer intBuffer = IntBuffer.allocate(5);
for(int a=0;a<intBuffer.capacity();i++){
      intBuffer.put(i*2);
}
intBuffer.flip();
while(intBuffer.hasRemarning()){
      System.out.print(intBuffer.get())
}