Client/Server-Modell Java

Question

Ich habe eine Server-Klasse, die einen Client an einem bestimmten Server-Socket-Port verbindet und einen Thread mit einer Serviceklasse startet. Konkret habe ich 3 Serviceklassen, also möchte ich 3 verschiedene Ports haben. Dies funktioniert jedoch nicht so, wie ich es erwartet hatte. Dies ist mein Code für den Server:

import java.net.ServerSocket; 
import java.net.Socket; 
import java.io.IOException; 

public class WebsiteServer { 

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

     ServerSocket serversocket = new ServerSocket(22401); 
     ServerSocket serversocket2 = new ServerSocket(22402); 
     Thread thread; 
     Thread thread2; 
     Socket socket; 
     Socket socket2; 
     NewUserService newuserservice; 
     ExistingUserService existinguserservice; 

     System.out.println("Waiting for clients to connect."); 

     while (true) { 

      socket = serversocket.accept(); 
      socket2 = serversocket2.accept(); 

      if(socket.isConnected()) { 

       System.out.println("NewUserClient has connected."); 
       newuserservice = new NewUserService(socket); 
       thread = new Thread(newuserservice); 
       thread.start(); 
      } 

      if(socket2.isConnected()) { 

       System.out.println("ExistingUserClient has connected."); 
       existinguserservice = new ExistingUserService(socket2); 
       thread2 = new Thread(existinguserservice); 
       thread2.start(); 
      } 
     } 
    } 
} 

Es funktioniert gut, wenn ich nur einen Port verwenden, zB:

import java.net.ServerSocket; 
import java.net.Socket; 
import java.io.IOException; 

public class WebsiteServer { 

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

     ServerSocket serversocket = new ServerSocket(22401); 
     ServerSocket serversocket2 = new ServerSocket(22402); 
     Thread thread; 
     Thread thread2; 
     Socket socket; 
     Socket socket2; 
     NewUserService newuserservice; 
     ExistingUserService existinguserservice; 

     System.out.println("Waiting for clients to connect."); 

     while (true) { 

      socket = serversocket.accept(); 
      //socket2 = serversocket2.accept(); 

      if(socket.isConnected()) { 

       System.out.println("NewUserClient has connected."); 
       newuserservice = new NewUserService(socket); 
       thread = new Thread(newuserservice); 
       thread.start(); 
      } 

//   if(socket2.isConnected()) { 
//     
//    System.out.println("ExistingUserClient has connected."); 
//    existinguserservice = new ExistingUserService(socket2); 
//    thread2 = new Thread(existinguserservice); 
//    thread2.start(); 
//   } 
     } 
    } 
} 

Jede mögliche Hilfe würde geschätzt.

Answer 1

Die accept-Methode blockiert, bis eine Verbindung hergestellt wird. Also, Sie sitzen blockiert eine .accept(), obwohl der andere Server Aktivität haben kann. Eine einfache Lösung wäre, einen Überwachungsthread pro Server zu erstellen.

Answer 2

accept() ist eine Blockierungsmethode. Mit anderen Worten, die zweite accept() wartet auf eine andere Verbindung. Untik eine zweite Verbindung wird akzeptiert, Ihr Code wird blockiert

Answer 3

Sie müssen die accept() Methode in einem separaten Thread aufrufen. accept() blockiert den Thread, bis jemand dem Server beitritt. Dies könnte 1 ms oder 1 Jahr sein.

Ich schlage vor, Sie ein AcceptListener erstellen aufgerufen werden, wenn jemand

public interface AcceptListener{ 
    public void socketAccepted(Socket s); 
} 

Und eine Handler-Klasse

public class MyServerSocket extends Thread{ 
    private AcceptListener l; 
    private boolean run = true; 
    private ServerSocket s; 
    public MyServerSocket(AcceptListener l, int port){ 
     this.l = l; 
     this.s = new ServerSocket(port); 
     this.start(); 
    } 
    public void run(){ 
     while(run){ 
      l.socketAccepted(s.accept()); 
     } 
    } 
} 

verbindet werden Sie müssen Fehler und so weiter behandeln und die Überschreibungen machen in Sie Unterklasse (es) von AcceptListener.