Java get ObjectInputStream ObjectOutputStream à partir d'un socket

Question

J'ai une application qui est basée sur l'interaction serveur-clients multiples.C'est le thread que j'utilise dans la classe serveur pour créer un nouveau thread où j'accepte tous les nouveaux sockets:

Thread acceptingThread = new Thread(new Runnable() { 

     @Override 
     public void run() { 
      while (true) { 
       try { 
        Socket s = serverSocket.accept(); 
        listaSocket.add(s); 
        listaOis.add(new ObjectInputStream(s.getInputStream())); 
        listaOos.add(new ObjectOutputStream(s.getOutputStream())); 
        System.out.println("Client connected"); 
       } catch (IOException ex) { 
        Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex); 
       } 
      } 

     } 

    }); 
    acceptingThread.start(); 




private ServerSocket serverSocket; 
private ArrayList<Socket> listaSocket; 
private ArrayList<ObjectInputStream> listaOis; 
private ArrayList<ObjectOutputStream> listaOos; 

les lignes qui bloquent les programmes sont les suivants:

    listaOis.add(new ObjectInputStream(s.getInputStream())); 
        listaOos.add(new ObjectOutputStream(s.getOutputStream())); 

Answer 1

Votre code bloque dans cette ligne particulière:

    listaOis.add(new ObjectInputStream(s.getInputStream())); 

Prenez note du comportement de ce constructeur ObjectInputStream. À partir du Javadoc:

Crée un ObjectInputStream qui lit à partir du InputStream spécifié. Un en-tête de flux de sérialisation est lu dans le flux et vérifié. Ce constructeur bloquera jusqu'à ce que l'ObjectOutputStream correspondant ait écrit et vidé l'en-tête.

Obtenir le InputStream de la connexion entrante signifie que les données sérialisé doit être envoyé par la connexion. Cela signifie que vous devez procéder comme suit avant que le constructeur ne procède:

1. Connectez-vous du côté client. Je suppose que vous faites déjà cela puisque vous pouvez passer à travers socket.accept()
2. Ouvrez un OutputStream en utilisant la nouvelle connexion.
3. Enveloppez le OutputStream avec un ObjectOutputStream.
4. Envoyez des données via le ObjectOutputStream (c'est-à-dire, écrivez des données sérialisables et affleurez-les).