Java - Cliente-Servidor

Socket

Clase Cliente:

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

/**

 *

 *

 */

public class Cliente {

    /**

     * @param args the command line arguments

     */

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

        // TODO code application logic here

        Socket cliente = new Socket("localhost",8080);

        //Variables para la entrada y escritura del cliente

        BufferedReader entrada = new BufferedReader(new InputStreamReader(System.in));

        BufferedReader lecturaCliente = new BufferedReader(new InputStreamReader(cliente.getInputStream()));

        PrintWriter escrituraCliente = new PrintWriter(cliente.getOutputStream(),true);

        DataInputStream in = new DataInputStream(cliente.getInputStream());

        //Creacion de la variable mensajeCliente

        String mensajeCliente = new String();

        //Lectura de lo que contenga la variable

        mensajeCliente = lecturaCliente.readLine();

        System.out.println(mensajeCliente);

        //Condicional para salir o escribir el nombre de alguna otra ciudad

        while(true){

            String mensaje = entrada.readLine();

            escrituraCliente.println(mensaje);

            if(mensaje.equals("salir")){

            break;

            }

            else{

            String mensajeR = in.readUTF();

                System.out.println(mensajeR);

                        System.out.println("Escribe el nombre de otra ciudad si desea seguir conociendo lugares turisticos o 'salir' para terminar conexion");

            }

        }

        //Imprimir el mensaje del cliente y cerrar el cliente al finalizar el programa

        mensajeCliente = lecturaCliente.readLine();

        System.out.println(mensajeCliente);

        cliente.close();

    }

}

Clase Lugares:

import java.io.BufferedReader;

import java.io.DataOutputStream;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.net.Socket;

import java.util.Scanner;

/**

 *

 *

 */

//Clase en la que estaran los diferentes lugares

public class Lugares extends Thread {

    Socket clienteConectado;

    int id;

    public Lugares(Socket clienteConectado, int id) {

        this.clienteConectado = clienteConectado;

        this.id = id;

    }

    //Metodo run que obtiene los diferentes mensajes del cliente

    public void run(){

        BufferedReader lecturaServidor = null;

        DataOutputStream out = null;

        try {

            String[][] datos = LeerArchivo();

            lecturaServidor = new BufferedReader(new InputStreamReader(clienteConectado.getInputStream()));

            String mensajeRecibido = new String();

            out = new DataOutputStream(clienteConectado.getOutputStream());

            PrintWriter escrituraServidor = new PrintWriter(clienteConectado.getOutputStream(),true);

            System.out.println("Esperando mensaje....");

            try {

                escrituraServidor.println("Ingresa el nombre de una ciudad para conocer sus lugares turisticos o 'salir' para terminar sesion");

                while(!(mensajeRecibido = lecturaServidor.readLine()).equals("salir")){

                    System.out.println("Mensaje recibido del cliente "+ clienteConectado.getRemoteSocketAddress() + " :"+ mensajeRecibido );

                    int i = 0;

                    String lugar = null;

                        if(!mensajeRecibido.equalsIgnoreCase("salir")){

                            while(i < datos.length){

                                if (datos[i][0].equalsIgnoreCase(mensajeRecibido)){

                                 lugar = "Lugares Turisticos: " + datos[i][1];

                                 break;

                                }  else {

                                    lugar ="Ciudad no encontrada";

                                }

                                i++;

                            }

                            out.writeUTF(lugar);

                        }

                }

                escrituraServidor.println("Sesion terminada");

                clienteConectado.close();

                System.out.println("Conexion con el cliente: "+ clienteConectado.getRemoteSocketAddress() + " terminada.");

            } catch (IOException e) {

                Logger.getLogger(Lugares.class.getName()).log(Level.SEVERE,null,e);

            }

        } catch (IOException e) {

            Logger.getLogger(Lugares.class.getName()).log(Level.SEVERE,null,e);

        }

        try {

            lecturaServidor.close();

        } catch (IOException e) {

          Logger.getLogger(Lugares.class.getName()).log(Level.SEVERE,null,e);

        }

    }

    //Metodo para leer el archivo que contiene los diferentes lugares

    public static String[][] LeerArchivo() throws FileNotFoundException, IOException{

        File archivo = new File("lugares.txt");

        FileReader fr = new FileReader(archivo);

        BufferedReader br = new BufferedReader(fr);

        String linea;

        int nlinea = 0, i = 0;

        Scanner sc = new Scanner(archivo);

        while(sc.hasNextLine()) {

            sc.nextLine();

            nlinea++;

        }

        String[][] datos = new String[nlinea][2];

        while ((linea = br.readLine())!=null){

            String[] temp = linea.split(";");

            datos[i][0] = temp[0];

            datos[i][1] = temp[1];

            i++;

        }

        fr.close();

        return datos;

    }

}

Clase Servidor

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

/**

 *

 *

 */

public class Servidor {

    /**

     * @param args the command line arguments

     */

    public static void main(String[] args) {

        // Creacion del servidor y conexion con el o los cliente

        try {

            ServerSocket servidor = new ServerSocket(8080);

            System.out.println("Servidor Iniciado");

            int i=1;

            while (true){

                Socket clienteConectado = servidor.accept();

                System.out.println("Cliente conectado con direccion: "+clienteConectado.getRemoteSocketAddress());

                Lugares clienteEntrante = new Lugares(clienteConectado,i);

                Thread hilo = new Thread(clienteEntrante);

                hilo.start();

                i++;

            }

        } catch (Exception e) {

            System.out.println(e.getMessage());

        }

    }

}

RPC

Clase Cliente

import java.util.Scanner;

import java.util.Vector;

import org.apache.xmlrpc.XmlRpcClient;

public class Cliente {

    /**

     * @param args the command line arguments

     */

    public static void main(String[] args) {

        // TODO code application logic here

        try {

            XmlRpcClient client = new XmlRpcClient("http://localhost/");

            Vector params = new Vector();

            Scanner sc = new Scanner(System.in);

            String ent = "" , sal = "";

            System.out.println("Conectado al servidor");

            System.out.println("Escriba un identificador para el cliente");

            String id = sc.nextLine();

            params.addElement(id);

            Object result = client.execute("miServer.Inicio", params);

            System.out.println(result.toString());

            while (!sal.equals("salir")){

                params.clear();

                ent = sc.nextLine();

                params.addElement(id);

                params.addElement(ent);

                result = client.execute("miServer.Buscar", params);

                sal = result.toString();

                System.out.println(sal);

                System.out.println("Escribe el nombre de otra ciudad o 'salir' para terminar conexion");

            }

            System.out.println("Conexion terminada");

        } catch (Exception e) {

            System.out.println("JavaClient: "+ e);

        }

        }

    }

Clase Lugares

import java.io.BufferedReader;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.IOException;

import java.util.Scanner;

public class Lugares  {

    public String Inicio(String id){

        System.out.println("Cliente con id "+ id + " conectado");

        return "Ingresa el nombre de una ciudad para conocer sus lugares turisticos o 'salir' para terminar sesion ";

    }

    public String Buscar(String id, String cEnt)throws IOException{

    String[][] datos = LeerArchivo();

    System.out.println("Mensaje recibido del cliente con ID: "+ id +" : "+cEnt);

    int i = 0;

    String cSal = null;

    if(!cEnt.equalsIgnoreCase("salir")){

        while(i < datos.length){

            if(datos[i][0].equalsIgnoreCase(cEnt)){

                cSal="Lugares turisticos: " + datos[i][1];

                break;

            }  else {

                cSal="Ciudad no encontrada";

            }

            i++;

        }

    }

    else{

        System.out.println("El cliente con ID: "+ id + " finalizo sesion");

        cSal="salir";

    }

    return cSal;

}

public static String[][] LeerArchivo() throws FileNotFoundException, IOException{

    File archivo = new File("lugares.txt");

    FileReader fr = new FileReader(archivo);

    BufferedReader br = new BufferedReader(fr);

    String linea;

    int nlinea = 0, i = 0;

    Scanner sc = new Scanner(archivo);

    while(sc.hasNextLine()) {

        sc.nextLine();

        nlinea++;

    }

    String[][] datos = new String[nlinea][2];

    while ((linea = br.readLine())!=null){

        String[] temp = linea.split(";");

        datos[i][0] = temp[0];

        datos[i][1] = temp[1];

        i++;

    }

    fr.close();

    return datos;

    }

}

Clase Servidor

import org.apache.xmlrpc.WebServer;

public class Servidor {

    /**

     * @param args the command line arguments

     */

    public static void main(String[] args) {

        // TODO code application logic here

        try {

            System.out.println("Iniciando XML-RPC Server...");

            WebServer server = new WebServer(80);

            Lugares lugares = new Lugares();

            server.addHandler("miServer", lugares);

            server.start();

            System.out.println("Inicio exitoso del servidor, queda en espera de peticiones del cliente...");

        } catch (Exception exception) {

            System.out.println("JavaServer " + exception);

        }

    }

}

RMI

Clase Cliente

import java.io.IOException;

import java.util.Scanner;

import java.rmi.registry.Registry;

import java.rmi.registry.LocateRegistry;

public class Cliente {

    /**

     * @param args the command line arguments

     */

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

        // TODO code application logic here

        try {

            Registry miRegistro = LocateRegistry.getRegistry("localhost",1099);

            Interface i = (Interface) miRegistro.lookup("Lugares");

            Scanner sc = new Scanner(System.in);

            System.out.println("Escriba un identificador para el cliente");

            String id = sc.nextLine();

            System.out.println(i.Inicio(id));

            String ent = " " ,sal = " ";

            while (!sal.equals("salir")){

                ent = sc.nextLine();

                sal = i.Buscar(id, ent);

                System.out.println(sal);

                System.out.println("Escriba el nombre de otra ciudad o 'salir' para terminar conexion");

            }

            System.out.println("Conexion finalizada");

        } catch (Exception e) {

            System.out.println(e.getMessage());

            e.printStackTrace();

        }

        }

    }

Clase Interface

import java.rmi.Remote;

public interface Interface extends Remote{

    public String Buscar(String id, String maIN) throws Exception;

    public String Inicio(String id) throws Exception;

}

Clase Lugares

import java.io.BufferedReader;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.IOException;

import java.rmi.server.UnicastRemoteObject;

import java.util.Scanner;

public class Lugares extends UnicastRemoteObject implements Interface  {

    public Lugares() throws Exception{

        super();

    }

    public String Inicio(String id){

        System.out.println("Cliente con id "+ id + " conectado");

        return "Escriba el nombre de la ciudad o 'salir' para finalizar sesion ";

    }

    public String Buscar(String id, String cEnt)throws IOException{

    String[][] datos = LeerArchivo();

    System.out.println("Mensaje recibido del cliente con ID: "+ id +" : "+cEnt);

    int i = 0;

    String cSal = null;

    if(!cEnt.equalsIgnoreCase("salir")){

        while(i < datos.length){

            if(datos[i][0].equalsIgnoreCase(cEnt)){

                cSal="Lugares turisticos: " + datos[i][1];

                break;

            }  else {

                cSal="Ciudad no encontrada";

            }

            i++;

        }

    }

    else{

        System.out.println("El cliente con ID: "+ id + " finalizo sesion");

        cSal="salir";

    }

    return cSal;

}

public static String[][] LeerArchivo() throws FileNotFoundException, IOException{

    File archivo = new File("lugares.txt");

    FileReader fr = new FileReader(archivo);

    BufferedReader br = new BufferedReader(fr);

    String linea;

    int nlinea = 0, i = 0;

    Scanner sc = new Scanner(archivo);

    while(sc.hasNextLine()) {

        sc.nextLine();

        nlinea++;

    }

    String[][] datos = new String[nlinea][2];

    while ((linea = br.readLine())!=null){

        String[] temp = linea.split(";");

        datos[i][0] = temp[0];

        datos[i][1] = temp[1];

        i++;

    }

    fr.close();

    return datos;

    }

}

Clase Servidor

import java.io.IOException;

import java.rmi.registry.LocateRegistry;

import java.rmi.registry.Registry;

public class Servidor {

    /**

     * @param args the command line arguments

     */

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

        // TODO code application logic here

        try {

            Registry registro = LocateRegistry.createRegistry(1099);

            registro.bind("Lugares", new Lugares());

            System.out.println("Servidor funcionando");

        } catch (Exception e) {

            System.out.println(e.getMessage());

        }

    }

}