run() -Methode wartet nicht auf Dateneingabe

Question

Ich versuche eine Anwendung zu machen, in die Sie zwei Zahlen eingeben, die Zahlen werden analysiert und über TCP-Protokoll an den Server gesendet und dann hinzugefügt, zurückgegeben und zurückgesetzt zu einem TextField. Das Problem ist, dass die Methode run() nicht auf die Eingabe der Zahlen wartet, im Gegensatz zu BufferedReader-Streams. Ich arbeite derzeit mit DataInputStream und DataOutPutStream.

Hier ist der Code unten!

public class Server implements Runnable { 
     public Server(){ 

    } 

    @Override 
    public void run() { 
     while (true) { 
      try (ServerSocket serverSocket = new ServerSocket(1000); 
        Socket sSocket = serverSocket.accept(); 
    DataInputStream in = new DataInputStream(sSocket.getInputStream()); 
    DataOutputStream out = new DataOutputStream(sSocket.getOutputStream())) 
      { 
       System.out.println("Client connected."); 
       Integer s1 = in.read(); 
       Integer s2 = in.read(); 
       Integer result = s1 + s2; 
       out.write(result); 



      } 
      catch(IOException e) 
      { 
       System.out.println(e.getMessage()); 
      } 
     } 
    } 

} 

und die Client-Klasse:

bs.addActionListener(new ActionListener() { 
     public void actionPerformed(ActionEvent ke) { 

      n1 = Integer.parseInt(tf1.getText()); 
      n2 = Integer.parseInt(tf2.getText()); 
      tf1.setText(String.valueOf(n1)); 
      tf2.setText(String.valueOf(n2)); 


        } 
    }); 

     } 
     @Override 
     public void run() { 
      try(Socket clientSocket = new Socket("localhost", 1000); 
     DataInputStream in = new DataInputStream(clientSocket.getInputStream()); 
     DataOutputStream out = new DataOutputStream(clientSocket.getOutputStream())) 

      { 
    out.write(n1); 
    out.write(n2); 
    Integer rezultat = in.read(); 
    tf3.setText(String.valueOf(result)); 

      } catch (IOException ex) { 
       System.out.println(ex.getMessage()); 
      } 

     } 
    } 

Und ich fange sowohl über die Hauptklasse und Themen. Vielen Dank im Voraus! : D

Answer 1

nur Ihr Code ein paar Änderungen braucht, dies zu beheben: zunächst in dem Haupt, ersetzen

Thread clientThread = new Thread(new Klijent()); 
    clientThread.start(); 

mit

Thread serverThread = new Thread(new Server()); 
    serverThread.start(); 
    new Klijent(); 

Sie werden die Server im Hintergrund möchten, und Führen Sie den Code nicht im Ereignishandler für die Schaltfläche aus - der Server sollte als separates Programm ausgeführt werden können.

Zweitens im Klijent Konstruktor entfernen

Server s = new Server(); 

vom Konstruktor, da es nun in main geschehen ist, und ersetzen

  s.run(); 

mit

  run(); 

zu nennen die Ausführungsmethode des Clients anstelle des Servers.

---

Wenn die Zuweisung sagt ein Client-Thread zu verwenden, um die Anforderung zu machen, könnte man auch einen zweiten Thread in Ihrer Schaltfläche Ereignishandler hinzu:

public void actionPerformed(ActionEvent ke) { 
     n1 = ... 
     n2 = ... 
     new Thread(Klijent.this).start(); // instead of this.run(); 
    }