ObjectInputStream и ObjectOutputStream

Question

Я написал EchoServer, который отвечает строкой ack, если данные были отправлены соответственно.

Мой клиент выглядит так ... Для получения ответа от сервера «echoSocket» помещает полученные данные в мой ObjectIputStream. Только если я комментирую эти части из клиент работает

 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(); 

     } 

ли кто-нибудь знает, почему он не будет посылать мои строки?

Спасибо, Marius

Answer 1

Использование объектных потоков над гнездами на самом деле не рекомендуется идея. Вы можете рассмотреть полный веб-сервис или RMI.

Это может работать лучше, если вы читаете в буфер и убедитесь, что у вас есть все дело до того, как попытаться десериализовать потоки объектов.

Answer 2

Похоже, клиент пытается прочитать подтверждение, прежде чем он написал сообщение.

Answer 3

Почему бы не использовать библиотеку hessian?

Он работает как шарм: http://karussell.wordpress.com/2009/04/10/hessian-web-service-protocol-hello-world-example/

Или попробуйте весной удаленного взаимодействия (который не является, что легкий)

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

Answer 4

Разделить «отправка» и «прием» кода в отдельные потоки, нить писателя может записываться в сокет, в то время как ваш другой поток блокируется при вызове readObject().

Если это будет длительный клиент, я бы также рекомендовал использовать DataInputStream и DataOutputStream более низкого уровня вместо ObjectInputStream/ObjectOutputStream, чтобы предотвратить удержание на возможно большой IdentityHashmap объектов.