La technologie NIO gère les opérations d'E/S non bloquantes et utilise des mécanismes basés sur les événements pour traiter les E/S de manière asynchrone afin d'améliorer l'efficacité dans les scénarios de requêtes simultanées élevées. Gérez les opérations d'E/S en définissant les canaux, en créant des sélecteurs, en enregistrant les canaux auprès des sélecteurs, en écoutant les événements et en gérant les étapes des événements. Le cas pratique montre un programme Echo non bloquant c?té serveur qui utilise NIO pour accepter et répondre de manière asynchrone aux demandes de connexion client.

La technologie NIO dans les fonctions Java gère les opérations d'E/S non bloquantes

NIO (E/S non bloquantes) est un moyen efficace de gérer des requêtes simultanées élevées dans les grandes applications réseau, il utilise le mode non bloquant via des événements. mécanisme pour gérer les E/S de manière asynchrone. L'API NIO est fournie en Java pour décrire les événements, les canaux et les tampons NIO.

1. Définir le canal NIO

Un canal dans NIO représente un fichier ouvert ou une connexion réseau. Il existe quatre principaux types de canaux?:

import java.nio.channels.*;

// 文件通道
FileChannel fileChannel = FileChannel.open(Paths.get("file.txt"), StandardOpenOption.READ);

// 套接字通道
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

// 套接字通道
SocketChannel socketChannel = SocketChannel.open();

// 套接字通道
DatagramChannel datagramChannel = DatagramChannel.open();

2. Créer des sélecteurs

Les sélecteurs sont utilisés pour surveiller les événements sur plusieurs canaux. Ils peuvent gérer simultanément un grand nombre de connexions provenant de différents canaux, gérant ainsi efficacement les opérations d’E/S.

import java.nio.channels.Selector;

Selector selector = Selector.open();

3. Enregistrez la cha?ne

Enregistrez la cha?ne dans le sélecteur pour surveiller les événements qui vous intéressent, tels que les opérations de lecture/écriture.

serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

4. écoute des événements

Utilisez la méthode select() pour surveiller les événements dans le sélecteur jusqu'à ce qu'un événement se produise. Cette méthode se bloque jusqu'à ce qu'au moins un canal soit prêt à être traité. select() 方法監(jiān)視 Selector 中的事件，直到有事件發(fā)生。該方法會阻塞，直到至少有一個通道準備好處理。

int numKeys = selector.select();

5. 處理事件

通過檢查 SelectionKey

for (SelectionKey key : selector.selectedKeys()) {
    if (key.isAcceptable()) {
        // 監(jiān)聽新的連接請求
    } else if (key.isReadable()) {
        // 讀取數(shù)據(jù)
    } else if (key.isWritable()) {
        // 寫入數(shù)據(jù)
    }
}

5. Gestion des événements

Gérez les événements qui se produisent en cochant SelectionKey, qui fournit des détails sur le canal et le type sur lequel l'événement s'est produit.

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.util.Iterator;
import java.util.Set;

public class NonBlockingEchoServer {

    public static void main(String[] args) throws IOException {
        // 創(chuàng)建一個 ServerSocketChannel
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(8080));
        serverSocketChannel.configureBlocking(false);

        // 創(chuàng)建一個 Selector
        Selector selector = Selector.open();

        // 注冊 ServerSocketChannel 到 Selector，監(jiān)視 ACCEPT 事件
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            // 監(jiān)聽事件
            selector.select();

            // 獲取選擇的 SelectionKey 集合
            Set<SelectionKey> selectedKeys = selector.selectedKeys();

            // 遍歷選擇的 SelectionKey
            Iterator<SelectionKey> iterator = selectedKeys.iterator();
            while (iterator.hasNext()) {
                SelectionKey key = iterator.next();

                if (key.isAcceptable()) {
                    // 新的連接請求
                    SocketChannel socketChannel = serverSocketChannel.accept();
                    socketChannel.configureBlocking(false);
                    socketChannel.register(selector, SelectionKey.OP_READ);
                } else if (key.isReadable()) {
                    // 讀取數(shù)據(jù)
                    SocketChannel socketChannel = (SocketChannel) key.channel();
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    int readBytes = socketChannel.read(buffer);
                    if (readBytes > 0) {
                        // 響應客戶端消息
                        buffer.flip();
                        socketChannel.write(buffer);
                    }
                }

                // 從集合中刪除處理過的 SelectionKey
                iterator.remove();
            }
        }
    }
}

??Cas pratique?: programme Echo non bloquant c?té serveur??????Cet exemple crée un serveur qui utilise NIO pour accepter et répondre de manière asynchrone aux connexions client. ??rrreee

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!