ObjectInputStream et ObjectOutputStream

Question

J'ai écrit un EchoServer qui répond avec la chaîne ACK si les données ont été envoyées en conséquence.

Mon client ressemble à ceci ... Afin de recevoir la réponse ack du serveur, "echoSocket" place les données reçues dans mon ObjectInputStream. Seulement si je commente ces pièces sur le client fonctionne

 echoSocket = new Socket(server_name, tcp_port); 
     System.out.println(" *** Connected to " + server_name + " ***"); 
     System.out.println("Press Enter to send your message."); 

     out = new ObjectOutputStream(echoSocket.getOutputStream()); 
     in = new ObjectInputStream(echoSocket.getInputStream()); 

     out.flush(); 

     String message = System.console().readLine(); 

     while(!message.equals("quit")) { 


      // problem     
      if (in.readObject().equals(ack)) 
       System.out.println("ACKed"); 
      in.close(); 
      // problem ends 
      out.flush(); 

      out.writeObject(message); 
      System.out.println("Sending: " + message);  
      message = System.console().readLine(); 
      out.flush(); 

     } 

Est-ce que quelqu'un sait pourquoi il n'enverra pas mes cordes?

Merci, Marius

Answer 1

Utilisation des flux d'objets sur des sockets est pas vraiment une idée recommandée. Vous pourriez envisager un service Web complet, ou RMI.

Cela peut fonctionner mieux si vous lisez dans un tampon et assurez-vous que vous disposez de toute l'activité avant d'essayer de désérialiser avec les flux d'objets.

Answer 2

Il semble que le client essaie de lire l'accusé de réception avant d'avoir écrit le message.

Answer 3

Pourquoi ne pas utiliser la bibliothèque Hessian?

Il fonctionne comme un charme: http://karussell.wordpress.com/2009/04/10/hessian-web-service-protocol-hello-world-example/

Ou essayez Remoting ressort (qui est pas léger)

http://static.springsource.org/spring/docs/2.5.x/reference/remoting.html

Answer 4

de Split le "envoi" et le code "recevoir" dans des threads séparés, le thread d'écriture peut écrire sur le socket pendant que votre autre thread est bloqué sur l'appel à readObject().

Si cela doit être un client de longue durée, je recommande également d'utiliser DataInputStream et DataOutputStream de niveau inférieur à la place de ObjectInputStream/ObjectOutputStream, pour empêcher le stockage d'une IdentityHashmap éventuellement importante des objets.