Cet article utilise Java 10.0.1 installé sur WIN10.

en premier

La dernière fois j'ai fait un chemin de transfert BIO, aujourd'hui je vais continuer à implémenter NIO.

À propos de NIO

Qu'est-ce que NIO

En termes simples, il ne bloque pas les demandes d'E / S. Vous pouvez améliorer le traitement des E / S (BIO) existant.

Mauvais points de BIO

Tout d'abord, la demande du côté client comprend deux parties, une demande de connexion et une demande d'E / S. Les demandes de connexion sont toujours effectuées, mais des demandes d'E / S sont effectuées de temps en temps. Par conséquent, la méthode de préparation d'un thread de traitement indépendamment d'une demande, qu'il y ait ou non un traitement d'E / S tel que BIO gaspille les performances du serveur.

Bons points de NIO

NIO n'a qu'un seul thread de traitement pour chaque demande du côté client. S'il y a une demande d'E / S, demandez à un autre thread de traiter les E / S.

la mise en oeuvre

*** SocketChannel *** et *** ServerSocketChannel *** sont fournis à partir du langage Java, donc cette fois je vais essayer d'implémenter TCP / IP + NIO en utilisant ces derniers. (L'API officielle est ici: SocketChannel, [ServerSocketChannel](https: // docs .oracle.com / javase / jp / 8 / docs / api / java / nio / channels / ServerSocketChannel.html) Fichiers côté serveur

** Contenu de ChannelServer.java **

Génère ServerSocketChannel ** et écoute l'accès côté client *

public class ChannelServer {

    public static void main(String[] args) throws IOException {
        // I/Préparer un pool de threads pour traiter les requêtes O
        ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 10, 1000, TimeUnit.MILLISECONDS, 
                new ArrayBlockingQueue<Runnable>(100));

        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(1234));

        while (true) {
            SocketChannel socketChannel = serverSocketChannel.accept();

            if (socketChannel != null) {
                //Validez la demande dans le pool de threads
                executor.submit(new ChannelServerThread(socketChannel));
            }
        }
    }
}

** Contenu de ChannelServer.java **

*** Fil de discussion pour traiter la demande ***


public class ChannelServerThread implements Runnable {

    private SocketChannel socketChannel;
    private String remoteName;

    public ChannelServerThread(SocketChannel socketChannel) throws IOException {
        this.socketChannel = socketChannel;
        this.remoteName = socketChannel.getRemoteAddress().toString();
        System.out.println("client:" + remoteName + " access successfully!");
    }

    // I/Gérer la demande O
    @Override
    public void run() {
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        ByteBuffer sizeBuffer = ByteBuffer.allocate(4);
        StringBuilder sb = new StringBuilder();
        byte b[];
        //Lire les données et la longueur de socketChannel et sortie vers la sortie standard
        while(true) {
            try {
                sizeBuffer.clear();
                int read = socketChannel.read(sizeBuffer);
                if (read != -1) {
                    sb.setLength(0);
                    sizeBuffer.flip();
                    int size = sizeBuffer.getInt();
                    int readCount = 0;
                    b = new byte[1024];
                    while (readCount < size) {
                        buffer.clear();
                        read = socketChannel.read(buffer);
                        if (read != -1) {
                            readCount += read;
                            buffer.flip();
                            int index = 0 ;
                            while(buffer.hasRemaining()) {
                                b[index++] = buffer.get();
                                if (index >= b.length) {
                                    index = 0;
                                    sb.append(new String(b,"UTF-8"));
                                }
                            }
                            if (index > 0) {
                                sb.append(new String(b,"UTF-8"));
                            }
                        }
                    }
                    System.out.println(remoteName +  ":" + sb.toString());
                }
            } catch (Exception e) {
                System.out.println(remoteName + "access colsed");
                try {
                    socketChannel.close();
                } catch (IOException ex) {
                }
                break;
            }
        }
    }
}

** Fichiers côté client **

*** Créez un socketChannel pour accéder au serveur et au port spécifiés ***

public class ChannelClient {

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

        SocketChannel socketChannel = SocketChannel.open();
        socketChannel.connect(new InetSocketAddress(1234));
        while (true) {
            Scanner sc = new Scanner(System.in);
            String next = sc.next();
            sendMessage(socketChannel, next);
        }
    }

    //Préparer un conteneur pour Channel to IPO
    public static void sendMessage(SocketChannel socketChannel, String mes) throws IOException {
        if (mes == null || mes.isEmpty()) {
            return;
        }
        byte[] bytes = mes.getBytes("UTF-8");
        int size = bytes.length;
        ByteBuffer buffer = ByteBuffer.allocate(size);
        ByteBuffer sizeBuffer = ByteBuffer.allocate(4);

        sizeBuffer.putInt(size);
        buffer.put(bytes);

        buffer.flip();
        sizeBuffer.flip();
        ByteBuffer dest[] = {sizeBuffer,buffer};
        while (sizeBuffer.hasRemaining() || buffer.hasRemaining()) {
            socketChannel.write(dest);
        }
    }
}

Authentification des résultats

*** Démarrage du serveur et attente d'une connexion: ***

serveur

PS C:\Users\ma\Documents\work\socket\nio_tcp> java ChannelServer

*** Lancez respectivement les clients 1 et 2 et entrez quelque chose: ***

** Client 1 **


PS C:\Users\ma\Documents\work\socket\nio_tcp> java ChannelClient
iamfirstuser!
byebyefirstone!
Exception in thread "main"
PS C:\Users\ma\Documents\work\socket\nio_tcp>

** Client 2 **

java ChannelClient
iamseconduser
byebyesecondone!
Exception in thread "main"
PS C:\Users\ma\Documents\work\socket\nio_tcp>