Duda con cliente/servidor tcp en java

[3francisjmm]

A ver si por favor alguien me puede ayudar con este problema que tengo con cliente/servidor tcp en java.

La clase cliente que tengo es asi y no la puedo mpdificar:

Código:

class SimpleTCPClient { 
    
    public static void main(String argv[]) throws Exception { 
        String sentence; 
        String modifiedSentence; 
        BufferedReader inFromUser = new BufferedReader( new InputStreamReader(System.in)); 
        Socket clientSocket = new Socket("localhost", 8080); 
        DataOutputStream outToServer = new DataOutputStream( clientSocket.getOutputStream()); 
        BufferedReader inFromServer = new BufferedReader( new InputStreamReader(clientSocket.getInputStream())); 
        sentence = inFromUser.readLine(); 
        outToServer.writeBytes(sentence + '\n'); 
        modifiedSentence = inFromServer.readLine(); 
        System.out.println("FROM SERVER: " + modifiedSentence); 
        clientSocket.close(); 
    } // main 
} // SimpleTCPClient class

El servidor lo forman dos clases, una multihilo que hace uso de la siguiente clase para atender los procesos de cliente:

Código:

public class WorkerRunnable implements Runnable{ 
    protected Socket clientSocket = null; 
    protected String serverText = null; 
    public WorkerRunnable(Socket clientSocket,String serverText) 
    { 
        this.clientSocket = clientSocket; 
        this.serverText = serverText; } 
        // WorkerRunnable 
        
    public void run() { 
        try { 
            InputStream input = clientSocket.getInputStream(); 
            OutputStream output = clientSocket.getOutputStream(); 
            long time = System.currentTimeMillis(); 
            output.write(("HTTP/1.1 200 OK\n\nWorkerRunnable: " + this.serverText + " - " + time + " ").getBytes()); 
            output.close(); input.close(); System.out.println("Request processed: " + time); 
        } catch (IOException e) { e.printStackTrace(); 
                //report exception somewhere 
            } 
    } // run 
} // WorkerRunnable

Pues tengo que modificar esta clase para que su comportamiento sea complementario al del cliente, que lea la cadena de texto enviada por el cliente, y como respuesta reenvíe la cadena leída precedida de la palabra ECHO.

Esta que pongo es la que funciona para ver retardos si como cliente uso el navegador web.

Alguien me puede ayudar por favor?

Muchisimas gracias.

[3francisjmm]

Decir que entre otras opciones, esta no me da errores, pero tampoco me funciona:

Código:

public class WorkerRunnable implements Runnable{ 
    protected Socket clientSocket = null; 
    protected String serverText = null; 
    public WorkerRunnable(Socket clientSocket,String serverText) 
    { 
        this.clientSocket = clientSocket; 
        this.serverText = serverText; 
    }// WorkerRunnable 
        
    public void run() {
        String mensaje;
        try { 
            
            ObjectInputStream input = new ObjectInputStream(clientSocket.getInputStream()); 
            ObjectOutputStream output = new ObjectOutputStream(clientSocket.getOutputStream()); 
            while(true){
                if((mensaje= (String)input.readObject()) != null){
                    String respuesta ="ECHO: "+ mensaje;
                    output.writeObject(respuesta);
                    System.out.println(mensaje);
                }
                    Thread.sleep(100);
                }
            //System.out.println("Rrespuestaaa respuesta);     
            //output.close(); input.close(); 
        } catch (Exception e) { e.printStackTrace(); 
                //report exception somewhere 
            } 
    } // run 
} // WorkerRunnable

Me conecta pero no puedo mostrar lo que escribo por pantalla...Algun consejo/ayuda por favor??

Gracias!

[Profesor_Falken]

Buenas,

Porque no pones tambien el codigo del main del server? Si ese codigo no podemos ejecutar tu ejemplo.

Bueno... en cualquier caso algo como esto deberia servirte:

Código Java:

public class WorkerRunnable implements Runnable {
 
    protected Socket clientSocket = null;
 
    public WorkerRunnable(Socket clientSocket) {
        this.clientSocket = clientSocket;
    }// WorkerRunnable 
 
    @Override
    public void run() {
        String mensaje;
        try {
            BufferedReader input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            DataOutputStream output = new DataOutputStream(clientSocket.getOutputStream());
            while (true) {
                mensaje = input.readLine();
                output.writeBytes("ECHO: " + mensaje + "\n\r");
                output.flush();
            }
        } catch (Exception e) {
            e.printStackTrace();
            //report exception somewhere 
        }
    } // run 
} // WorkerRunnable
 

Un saludo

[chuidiang]

Hola:

El cliente no lo puedes modificar. Fíjate que usa DataOutputStream para escribir, con un \n al final y usa BufferedReader para leer, con un readLine(). Un readLine() se queda bloqueado hasta que encuentre una línea completa con un \n al final.

En tu primera versión de servidor usas InputStream y OuptutStream, pero no lees nada (el input lo cierras sin leer) y en el envío no envías un \n, que es lo que espera el cliente con el readLine().

En tu segunda versión, usas ObjectInputStream y ObjectOutputStream. Esas clases son muy específicas de java y sirven para enviar objetos java con un protocolo específico de java y requieren que al otro lado del socket haya esas mismas clases. Cuando envías un String con estas clases, no estás enviando un texto, sino una clase String de java con todos sus atributos y cosas. Olvida completamente esta versión.

O bien usas la primera versión, pero poniendo \n al final de cada línea que envíes, o bien usa los mismos objetos que usa el cliente (BufferedReader y DataOutputStream con \n al final). Para usar DataOuputStream con \n, casi es mejor usar PrintStream, que tiene método println() que ya añade el \n al final, pero puedes usar el que quieras.

Otro detalle para que tengas en cuenta. Si envías algo y cierras el socket inmediatamente después (es lo que estás haciendo), puede que no le des tiempo al otro lado a leerlo (depende de como implemente los sockets el sistema operativo). Para evitar esto, en el socket llama a la opción setsoLinger (ponle a on y un tiempo máximo para dar tiempo al otro lado a leer).

Se bueno.

[3francisjmm]

Muchisimas gracias por los consejos!! Me han servido mucho, habia cosas que no tenia ni idea. Ya lo tengo solucionado. Menudo descubrimiento de foro, GRACIAS!!!!