0

estoy empezando con el tema de sockets en java y tengo un ejercicio en el cual me piden que lea un archivo que lo solicite con el cliente y el servidor me muestre su conetenido.

public class Servidor extends Thread {

static final int port = 49000;
Socket skCliente;

public Servidor(Socket sCliente) {
    skCliente = sCliente;
}

public static void main(String[]args){
    try {

      ServerSocket skServidor = new ServerSocket(port);
      System.out.println("Servidor escuchando en el puerto " + port);

      while(true){
        Socket skCliente = skServidor.accept();
        System.out.println("¡¡¡Cliente Conectado!!!");
        new Servidor(skCliente).start();

      }



    } catch (Exception e) {
        System.out.println("Error de conexión");
    }
}

@Override
public void run() {
    try {  
    OutputStream aux = skCliente.getOutputStream();
    DataOutputStream flujo_salida = new DataOutputStream(aux);

    InputStream auxi = skCliente.getInputStream();
    DataInputStream flujo_entrada = new DataInputStream(auxi);

    flujo_salida.writeUTF("¡¡¡Conexión satisfactoria!!!");//Escribe en el Stream para que lo lea el cliente
    String comando;
    boolean correcto = false;

        do {    

                    flujo_salida.writeUTF("Introduce nombre del archivo: ");
                    comando=flujo_entrada.readUTF();
                    if(comando.equals("dam")){
                        File archivo = new File ("C:\\Users\\Dani\\Desktop\\dam.txt");
                        FileReader fr = new FileReader (archivo);
                        BufferedReader br = new BufferedReader(fr);
                        String linea = br.readLine();
                        flujo_salida.writeUTF("true");
                        flujo_salida.writeUTF(linea);
                        correcto = true;





                    }else{
                        flujo_salida.writeUTF("false");
                        correcto = false;




            }

        } while (correcto == false);
    flujo_entrada.close();
    flujo_salida.close();

    System.out.println("Cliente desconectado");
    skCliente.close();

    } catch (Exception e) {
        System.out.println(e.getMessage());
    }
}

}

Y este el cliente:

public class Cliente {


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

    final String ip = "localhost";
    final int port = 49000;
    String resultado = "false";

    Scanner sc = new Scanner(System.in);
    Socket sCliente = new Socket(ip, port);
    //System.out.println("Me he conectado al servidor");

    InputStream aux = sCliente.getInputStream();
    DataInputStream flujo_entrada = new DataInputStream(aux);

    OutputStream auxi = sCliente.getOutputStream();
    DataOutputStream flujo_salida = new DataOutputStream(auxi);

    System.out.println(flujo_entrada.readUTF());
    System.out.print(flujo_entrada.readUTF());

    String archivo = sc.nextLine();
    flujo_salida.writeUTF(archivo);
    resultado = flujo_entrada.readUTF();

    do{
        if(resultado.equals("false")){


       System.out.println("No existe el archivo");
            System.out.print("Introduzca el nombre del archivo: ");
            archivo = sc.nextLine();
            flujo_salida.writeUTF(archivo); }


        if(resultado.equals("true")){
            System.out.println("Lectura del archivo solicitado: ");
            System.out.println(flujo_entrada.readUTF());
            System.out.println(flujo_entrada.readUTF());
        }
    }while (resultado.equals("false")); 
    sCliente.close();
}

}

El problema viene que cuando introduzco dam me muestra correctamente el contenido y cuando introduzco palabra incorrecta me pide que ingrese de nuevo pero al ingresar dam de nuevo me dice que es incorrecto y que vuelva a ingresar palabra.

1 respuesta 1

0

Al terminar tu iteración, cuando el comando de entrada es incorrecto, tu servidor está escribiendo "Introduzca el nombre del archivo: " al momento que el cliente recibe el resultado, por lo tanto siempre recibe algo distinto al String false o true.

El código para ambos debería quedar así:

Para el servidor

import java.io.*;
import java.net.*;

public class Servidor extends Thread {

    static final int port = 49000;
    Socket skCliente;

    public Servidor(Socket sCliente) {
        skCliente = sCliente;
    }

    public static void main(String[]args){
        try {
            ServerSocket skServidor = new ServerSocket(port);
            System.out.println("Servidor escuchando en el puerto " + port);

            while(true){
                Socket skCliente = skServidor.accept();
                System.out.println("¡¡¡Cliente Conectado!!!");
                new Servidor(skCliente).start();
            }
        } catch (Exception e) {
            System.out.println("Error de conexión");
        }
    }

    @Override
    public void run() {
        try {  
             OutputStream aux = skCliente.getOutputStream();
             DataOutputStream flujo_salida = new DataOutputStream(aux);

             InputStream auxi = skCliente.getInputStream();
             DataInputStream flujo_entrada = new DataInputStream(auxi);

             flujo_salida.writeUTF("¡¡¡Conexión satisfactoria!!!");//Escribe en el Stream para que lo lea el cliente
             String comando;
             boolean correcto = false;
             flujo_salida.writeUTF("Introduce nombre del archivo: ");
             do {    
                 comando=flujo_entrada.readUTF();//Lectura de comando
                 if(comando.equals("dam")){
                     File archivo = new File ("dam.txt");
                     FileReader fr = new FileReader (archivo);
                     BufferedReader br = new BufferedReader(fr);
                     String linea = br.readLine();
                     flujo_salida.writeUTF("true");
                     flujo_salida.writeUTF(linea);
                     correcto = true;
                 }else{ 
                     flujo_salida.writeUTF("false");
                     correcto = false;
                 }
             } while (correcto == false);
             flujo_entrada.close();
             flujo_salida.close();
             System.out.println("Cliente desconectado");
             skCliente.close();
        } catch (Exception e) {
        System.out.println(e.getMessage());
    }
}

Y el cliente

import java.io.*;
import java.net.*;
import java.util.*;

public class Cliente {

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

        final String ip = "localhost";
        final int port = 49000;
        String resultado = "false";

        Scanner sc = new Scanner(System.in);
        Socket sCliente = new Socket(ip, port);
        //System.out.println("Me he conectado al servidor");

        InputStream aux = sCliente.getInputStream();
        DataInputStream flujo_entrada = new DataInputStream(aux);

        OutputStream auxi = sCliente.getOutputStream();
        DataOutputStream flujo_salida = new DataOutputStream(auxi);

        System.out.println(flujo_entrada.readUTF());//Confirmacion
        System.out.print(flujo_entrada.readUTF());//Primera petición

        String archivo = sc.nextLine();
        flujo_salida.writeUTF(archivo);//Comando
        //resultado = flujo_entrada.readUTF();

        do{
            resultado = flujo_entrada.readUTF();
            if(resultado.equals("false")){
                System.out.println("No existe el archivo");
                System.out.print("Introduzca el nombre del archivo: ");
                archivo = sc.nextLine();
                flujo_salida.writeUTF(archivo); 
            }
            if(resultado.equals("true")){
                System.out.println("Lectura del archivo solicitado: ");
                System.out.println(flujo_entrada.readUTF());
                System.out.println(flujo_entrada.readUTF());
            }
        }while (resultado.equals("false")); 
        sCliente.close();
    }
}
1
  • Muchas gracias, me has sido de gran ayuda Commented el 19 feb. 2018 a las 21:29

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.