[JAVA] Swift Network.framework Study 2019 1207 "Server TCP" Teil 3 Verbesserte Verwendung der Empfangsmethode

Study

Network.framework Studie: Serverseite

Umgebung

Client：Java、NetBeans Server：Swift、Xcode

Client Source Java

Mehrfach gesendet.

package example.java.network;

import java.io.PrintWriter;
import java.net.Socket;

public class ExampleClientSocket {
    public static void main(String[] args) {
        try(Socket socket = new Socket("localhost", 7777);
            PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);) {
            for(int i = 0; i < 5; i++) {
                printWriter.println("Example Send Data");
                Thread.sleep(5000);
            }
        }
        catch(Exception e) {
            System.out.println(e);
        }
    }
}

Server Source Swift

Verwenden Sie NWLister Empfangen Sie die Verarbeitungsregistrierung und starten Sie die Ausführung in NWConnection nach dem Verbindungsaufbau Verwenden Sie die Empfangsmethode, mit der die Anzahl der empfangenen Bytes angegeben werden kann. Aus einem empfangenen Datenwert haben wir die maximale Länge für einige Minuten ermittelt. Im folgenden Beispiel sind es 5 Bytes. Selbst wenn Sie 5 Bytes oder mehr senden, scheint der Empfang nach dem 6. Byte nicht kontinuierlich aufgerufen zu werden. Sie müssen den Empfang selbst anrufen. Rufen Sie die Empfangsmethode auf, bis der Empfang abgeschlossen ist. Rufen Sie die Empfangsmethode auf, wenn die empfangenen Abschlussdaten nicht Null sind und das Abschlussflag falsch ist.

main.swift

import Foundation
import Network

var networkServer = NetworkServer()

networkServer.startListener()

while networkServer.running {
    sleep(1)
}

NetworkServer.swift

import Foundation
import Network

class NetworkServer {
    public var running = true

    func startListener() {
        let myQueue = DispatchQueue(label: "ExampleNetwork")

        do {
            let nWListener = try NWListener(using: .tcp, on: 7777)
            nWListener.newConnectionHandler = { (newConnection) in
                print("New Connection!!")
                newConnection.start(queue: myQueue)
                self.receive(nWConnection: newConnection)
            }
            nWListener.start(queue: myQueue)
            print("start")
        }
        catch {
            print(error)
        }
    }
    
    func receive(nWConnection:NWConnection) {
        nWConnection.receive(minimumIncompleteLength: 1, maximumLength: 5, completion: { (data, context, flag, error) in
            print("receiveMessage")
            if let data = data {
                let receiveData = [UInt8](data)
                print(receiveData)
                print(flag)
                if(flag == false) {
                    self.receive(nWConnection: nWConnection)
                }
            }
            else {
                print("receiveMessage data nil")
            }
        })
    }
    
}