Comment une fonction Java utilise-t-elle la technologie NIO pour gérer un nombre élevé de requêtes simultanées ?

Java NIO est une technologie efficace pour gérer des requêtes simultanées élevées. Il utilise un mécanisme d'E/S et d'interrogation non bloquant pour implémenter : créer un sélecteur NIO pour écouter les événements ; enregistrer le canal dans le sélecteur et attendre les événements ACCEPT ; boucle et traite les événements ACCEPT, READ, WRITE ; l'événement ACCEPT gère la connexion client et crée l'événement READ qui lit les données et l'événement WRITE réécrit les données.

Les fonctions Java utilisent NIO pour gérer un nombre élevé de requêtes simultanées

Introduction
Les E/S non bloquantes (NIO) sont une technologie efficace en Java pour gérer un grand nombre de requêtes simultanées. Il utilise des opérations asynchrones et des mécanismes d'interrogation pour utiliser efficacement les ressources du système et améliorer le débit du système.

Étapes
1. Créer un sélecteur NIO
Le sélecteur NIO est utilisé pour écouter les événements sur la chaîne enregistrée.

Selector selector = Selector.open();

2. Enregistrez Channel
Enregistrez ServerSocketChannel sur Selector et écoutez l'événement ACCEPT.

ServerSocketChannel serverChannel = ServerSocketChannel.open();
serverChannel.configureBlocking(false);
serverChannel.register(selector, SelectionKey.OP_ACCEPT);

3. Boucle en attente d'événements
Écoutez les événements via la méthode Selector.select().

while (true) {
    selector.select();
    Set<SelectionKey> keys = selector.selectedKeys();
    // 处理事件...
}

4. Gestion de l'événement ACCEPT
Lorsque l'événement ACCEPT se produit, acceptez la connexion et créez un SocketChannel.

if (key.isAcceptable()) {
    ServerSocketChannel channel = (ServerSocketChannel) key.channel();
    SocketChannel clientChannel = channel.accept();
    clientChannel.configureBlocking(false);
    clientChannel.register(selector, SelectionKey.OP_READ);
}

Cas pratique
Ce qui suit est un exemple simple de serveur Java NIO Echo. Il écoute les connexions client et fait écho aux messages reçus.

EchoServer.java

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;

public class EchoServer {

    private Selector selector;
    private ServerSocketChannel serverChannel;
    private int port;

    public EchoServer(int port) {
        this.port = port;
    }

    public void start() throws IOException {
        // 创建 Selector
        selector = Selector.open();

        // 创建 ServerSocketChannel
        serverChannel = ServerSocketChannel.open();
        serverChannel.configureBlocking(false);
        serverChannel.bind(new InetSocketAddress(port));
        serverChannel.register(selector, SelectionKey.OP_ACCEPT);

        // 不断循环等待事件
        while (true) {
            int keysCount = selector.select();
            if (keysCount == 0) {
                continue;
            }
            Set<SelectionKey> keys = selector.selectedKeys();
            for (SelectionKey key : keys) {
                try {
                    if (key.isAcceptable()) {
                        handleAccept(key);
                    } else if (key.isReadable()) {
                        handleRead(key);
                    } else if (key.isWritable()) {
                        handleWrite(key);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                    key.cancel();
                    SocketChannel channel = (SocketChannel) key.channel();
                    channel.close();
                }
            }
            keys.clear();
        }
    }

    private void handleAccept(SelectionKey key) throws IOException {
        ServerSocketChannel channel = (ServerSocketChannel) key.channel();
        SocketChannel clientChannel = channel.accept();
        clientChannel.configureBlocking(false);
        clientChannel.register(selector, SelectionKey.OP_READ);
    }

    private void handleRead(SelectionKey key) throws IOException {
        SocketChannel channel = (SocketChannel) key.channel();
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        int readBytes = channel.read(buffer);
        if (readBytes == -1) {
            channel.close();
            return;
        }
        buffer.flip();
        channel.write(buffer);
    }

    private void handleWrite(SelectionKey key) throws IOException {
        SocketChannel channel = (SocketChannel) key.channel();
        channel.write(ByteBuffer.allocate(1024));
    }

    public static void main(String[] args) throws IOException {
        new EchoServer(9090).start();
    }
}

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!