Dieser Artikel verwendet Java 10.0.1, das auf WIN10 installiert ist.

zunaechst

Das letzte Mal ich habe einen BIO-Übertragungspfad erstellt werde ich heute NIO weiter implementieren.

Über NIO

Was ist NIO?

Einfach ausgedrückt, blockiert es keine E / A-Anforderungen. Sie können die vorhandene E / A-Verarbeitung (BIO) verbessern.

Schlechte Punkte von BIO

Erstens sind für die Anforderung von der Client-Seite zwei Teile enthalten, eine Verbindungsanforderung und eine E / A-Anforderung. Verbindungsanfragen werden immer gestellt, aber E / A-Anfragen werden von Zeit zu Zeit gestellt. Daher verschwendet das Verfahren zum Vorbereiten eines Verarbeitungsthreads unabhängig von einer Anforderung, unabhängig davon, ob eine E / A-Verarbeitung wie BIO vorliegt oder nicht, die Leistung des Servers.

Gute Punkte von NIO

NIO hat nur einen Verarbeitungsthread für jede Anforderung von der Clientseite. Wenn eine E / A-Anforderung vorliegt, fragen Sie einen anderen Thread nach der E / A-Verarbeitung.

Implementierung

*** SocketChannel *** und *** ServerSocketChannel *** werden aus der Java-Sprache bereitgestellt, daher werde ich dieses Mal versuchen, TCP / IP + NIO mit diesen zu implementieren. (Die offizielle API finden Sie hier: SocketChannel, [ServerSocketChannel](https: // docs .oracle.com / javase / jp / 8 / docs / api / java / nio / channel / ServerSocketChannel.html) Serverseitige Dateien

** Inhalt von ChannelServer.java **

Erzeugt ServerSocketChannel ** und wartet auf clientseitigen Zugriff *

public class ChannelServer {

    public static void main(String[] args) throws IOException {
        // I/Bereiten Sie einen Thread-Pool vor, um O-Anforderungen zu verarbeiten
        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) {
                //Übertragen Sie die Anforderung in den Thread-Pool
                executor.submit(new ChannelServerThread(socketChannel));
            }
        }
    }
}

** Inhalt von ChannelServer.java **

*** Thread zur Bearbeitung der Anfrage ***


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/O-Anfrage bearbeiten
    @Override
    public void run() {
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        ByteBuffer sizeBuffer = ByteBuffer.allocate(4);
        StringBuilder sb = new StringBuilder();
        byte b[];
        //Lesen Sie Daten und Länge von socketChannel und geben Sie sie in die Standardausgabe aus
        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;
            }
        }
    }
}

** Clientseitige Dateien **

*** Erstellen Sie einen SocketChannel, um auf den angegebenen Server und Port zuzugreifen. ***

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);
        }
    }

    //Bereiten Sie einen Container für Channel to IPO vor
    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);
        }
    }
}

Ergebnisauthentifizierung

*** Starten des Servers und Warten auf eine Verbindung: ***

Server

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

*** Starten Sie die Clients 1 und 2 und geben Sie Folgendes ein: ***

** Kunde 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>