Java NIO API? I/O ??? ???? ?? ?? API?, ?? ?? I/O?? ? ?? ??? ???? ?????. ??: ??????? ?? ?? ?? ???? ???? ??? ?????. ??: ??????? I/O ?? ?? ??? ???? ???? ?????. ???: ?? ??? ???? ?? ??? ?? ? ??? ???? ???? ? ?????.

Java I/O ????? NIO API: ??? ??

Introduction

NIO(Non-Blocking I/O) API? I/O ??? ???? ?? Java? ?? ?? API???. ?? ??? ???? ???? ??? ? ?? ?? I/O?? ? ?? ??? ???? ?????.

NIO API? ?? ??

NIO API? ??? ?? ?? ?? ??? ?????.

• ??(??): ??????? ?? ?? ?? ?? ???? ???? ? ???? ??? ?????.
• ??: ??????? I/O ?? ?? ??? ???? ???? ?????.
• ???: ?? ? ??? ? ??? ???? ?? ?? ??? ???? ? ?????.

NIO ?? ??

NIO? ??? ??? ??? ???? ???.

1. ??? ??? ???? ???? ??????.
2. ???? ?? ?? ???? ?????(?: ?? ?? ?? ?? ??).
3. ???? ??? ??? ???? ???? ??? ??? ? ??? ?????.
4. ?? ??? ??? ???? ???? ?????? ???? ????.
5. ??????? ???? ??? ? ?? ????? ?? ??? ?????.

?? ??

??? NIO API? ???? ??? ??? ???? ????.

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.ArrayList;
import java.util.List;

public class NIOServer {

    private static final int PORT = 8080;
    private static List<SocketChannel> connectedSockets = new ArrayList<>();

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

        // 創(chuàng)建服務(wù)器套接字通道
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

        // 將服務(wù)器通道綁定到端口
        serverSocketChannel.bind(new InetSocketAddress(PORT));

        // 設(shè)置非阻塞模式
        serverSocketChannel.configureBlocking(false);

        // 獲取選擇器
        Selector selector = Selector.open();

        // 將服務(wù)器通道注冊到選擇器，感興趣的可接受事件
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        // 事件循環(huán)
        while (true) {

            // 阻塞，直到至少有一個通道準(zhǔn)備好
            int readyChannels = selector.select();

            // 如果沒有準(zhǔn)備好的通道，則繼續(xù)
            if (readyChannels == 0) {
                continue;
            }

            // 處理準(zhǔn)備好的通道
            for (SelectionKey key : selector.selectedKeys()) {

                // 可接受事件
                if (key.isAcceptable()) {

                    // 接受傳入的連接
                    SocketChannel socketChannel = serverSocketChannel.accept();

                    // 設(shè)置非阻塞模式
                    socketChannel.configureBlocking(false);

                    // 將套接字通道注冊到選擇器，感興趣的可讀事件
                    socketChannel.register(selector, SelectionKey.OP_READ);

                    // 添加到已連接套接字列表
                    connectedSockets.add(socketChannel);
                }

                // 可讀事件
                else if (key.isReadable()) {

                    SocketChannel socketChannel = (SocketChannel) key.channel();

                    // 讀取數(shù)據(jù)
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    int bytesRead = socketChannel.read(buffer);

                    // 如果讀取到EOF，則關(guān)閉套接字
                    if (bytesRead == -1) {
                        socketChannel.close();
                        connectedSockets.remove(socketChannel);
                    }

                    // 處理讀取到的數(shù)據(jù)
                    // ...

                }
            }

            // 清除已處理的鍵
            selector.selectedKeys().clear();
        }
    }
}

? ??? ??? ?? 8080? ???? ????? ??? ?????. ?????? ???? ??? ?? ??? ?????. ??? ???? ???? ??? ??? ???? ???? ?? ? ??? ? ??? ?????.

? ??? Java I/O ???? NIO API? ??? ??????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!