Sockets Multicliente

[tukymix]

Buenos Dias !!!

Tengo este script de un Servidor el cual me gustaria que me ayudaseis a implementar unas cosas....

1º Necesito que guarde en un list todos los clientes que se conecten y cuando se desconecten pues que lo borre de list.
2º Implementar un for o algo el cual recorra todo ese list para mandar a todos los clientes conectados un string.

Alguien podria ayudarme ? Gracias de Antemano

Código Java:

import java.io.*;
import java.net.*;
 
public class MultiEchoServer
{
    private static ServerSocket ServidorSocket;
    private static final int Puerto = 1234;
 
    public static void main(String[] args) throws IOException{
        try{ ServidorSocket = new ServerSocket(Puerto); }
        catch (IOException e){
            System.out.println("\nNo se puede establecer conexion con el puerto!");
            System.exit(1);
        }
 
        do{
            //En espera de un nuevo cliente
            Socket cliente = ServidorSocket.accept();
 
            System.out.println("\nNuevo cliente aceptado.\n");
            
            ClienteEscucha escucha = new ClienteEscucha(cliente);
            escucha.start();
            
        }while (true);
    }
}
 
class ClienteEscucha extends Thread{
    private Socket cliente;
    private BufferedReader entrada;
    private PrintWriter salida;
 
    public ClienteEscucha(Socket socket){
        cliente = socket;
 
        try{
            entrada = new BufferedReader(new InputStreamReader(cliente.getInputStream()));
            salida = new PrintWriter(cliente.getOutputStream(),true);
        }
        catch(IOException e){
            e.printStackTrace();
        }
    }
 
    public void run()
    {
        try{
            String recibido;
            
            do{
                
                recibido = entrada.readLine();
                
                salida.println("ECHO: " + recibido);
 
            }while (!recibido.equals("QUITAR"));
        }
 
        catch(IOException e){
            e.printStackTrace();
        }
        
        finally{
            try{
                if (cliente!=null){
                    System.out.println("Cerrando la conexion...");
                    cliente.close();
                }
            }
            catch(IOException e){
                e.printStackTrace();
            }
        }
    }
}
 

[Profesor_Falken]

Buenas,

Lo que pides no tiene sentido, ya que tu código solo permite un cliente conectado al mismo tiempo. ¿Lo has probado?


Un saludo

[tukymix]

Esque no entiendo mucho, pensaba que lo del Thread es para algo de mas de un cliente, la cosa es que lo pruebo con 2 clientes y me recoge lo que escribo de los 2 clientes, por eso necesito que el server guarde esos clientes que se conecten en un list, para despues recorrer ese list de los clientes conectados y mandarles a todos los clientes un mensaje, la cosa es que me gustaria que alguien me lo adaptase, esque nose como hacerlo, o bien que me haga uno sencillo desde cero, pero con esas funciones, que guarde en un list los clientes que se conecten y despues que en un for recorra ese list de todos los clientes y les mande un mensaje.

[Profesor_Falken]

Buenas,

Tienes razon, no ne habia fijado en que efectivamente haces el while(true).

De cualquier forma me extrana tu problema, ya que lo que te queda por hacer, comparado con lo que ya has hecho, es absolutamente trivial.

Tienes que declarar una lista de ClienteEscucha en el server y cada vez que creas un cliente lo anades a la lista.

Para poder eliminar clientes, deberas pasar el servidor al constructor de ClienteEscucha y cuando este termine de ejecutar el run() hacer una llamada para eliminarlo de la lista.

Para enviar los mensajes bastara un metodo que recorra la lista de ClienteEscucha y llame un metodo de este que escriba un mensaje.


Un saludo

[tukymix]

Aham, ok !!! Y tu podrias, ya sabiendo lo que necesito, podrias aplicarmelo en el script de arriba ? Esque eso es un ejemplo que vi en internet, y como yo nose mucho de java, no me aclaro en aplicar el metodo del for que recorra el list y envie el mensaje. He visto este link: http://stackoverflow.com/questions/1...to-all-sockets y ahi esta como implementar una lista añadiendo clientes dentro del while y ademas en el Script Server de un usuario que respondió, tiene dentro del script esto:

Código Java:

protected void sendMessage(String message) {
            outputWriter.println(message);
        }
 
        private void sendToAnyone(String message) {
 
            for (ConnectionService connection : connections) {
                connection.sendMessage(message);
            }
        }
 

que es lo que me gustaria implementar en mi codigo, porque entiendo que una es la funcion que recorre todo el list en este caso llamado connections, y el otro envia el mensaje con outputWriter, la cosa es que no se, siempre me da errores por un sitio u otro, tu podrias arreglarmelo ? Mira, lo acabo de hacer asi, nose si esta bien o mal, unicamente me da un error en el listaclientes del "private void sendToAnyone(String message)" porque listaclientes esta detro del "public class MultiEchoServer", aqui dejo el script modificado como lo he echo yo, he incluido dentro del while el "listaclientes.add(escucha);", echale un vistazo:

Código Java:

public class MultiEchoServer
{
    private static ServerSocket ServidorSocket;
    private static final int Puerto = 1121;
    private static List<ClienteEscucha> listaclientes = new ArrayList<ClienteEscucha>();
    
    public static void main(String[] args) throws IOException{
        try{ ServidorSocket = new ServerSocket(Puerto); }
        catch (IOException e){
            System.out.println("No se puede establecer conexion con el puerto!\n");
            System.exit(1);
        }
 
        do{
            //En espera de un nuevo cliente
            Socket cliente = ServidorSocket.accept();
            
            System.out.println("Nuevo cliente aceptado.\n");
            
            ClienteEscucha escucha = new ClienteEscucha(cliente);
            escucha.start();
            
            listaclientes.add(escucha);
            
        }while (true);
    }
}
 
class ClienteEscucha extends Thread{
    private Socket cliente;
    private BufferedReader entrada;
    private PrintWriter salida;
    
    public ClienteEscucha(Socket socket){
        cliente = socket;
 
        try{
            entrada = new BufferedReader(new InputStreamReader(cliente.getInputStream()));
            salida = new PrintWriter(cliente.getOutputStream(),true);
        }
        catch(IOException e){
            e.printStackTrace();
        }
    }
 
    public void run()
    {
        try{
            String recibido;
            
            do{
                
                recibido = entrada.readLine();
                
                salida.println(recibido);
 
            }while (!recibido.equals("QUITAR"));
        }
 
        catch(IOException e){
            e.printStackTrace();
        }
        
        finally{
            try{
                if (cliente!=null){
                    System.out.println("Cerrando la conexion del servidor...\n");
                    cliente.close();
                }
            }
            catch(IOException e){
                e.printStackTrace();
            }
        }
    }
    
    protected void sendMessage(String message) {
        salida.println(message);
    }
 
    private void sendToAnyone(String message) {
 
        for (ClienteEscucha connection : listaclientes) {
            connection.sendMessage(message);
        }
    }
}
 

[Profesor_Falken]

Solo te falta aplicar esto:

Para poder eliminar clientes, deberas pasar el servidor al constructor de ClienteEscucha y cuando este termine de ejecutar el run() hacer una llamada para eliminarlo de la lista.

Para enviar los mensajes bastara un metodo que recorra la lista de ClienteEscucha y llame un metodo de este que escriba un mensaje.

Te lo pongo sobre lo tuyo. Revisalo porque lo he puesto aqui directamente y lo mismo hay algo que no compila:

Código Java:

public class MultiEchoServer
{
    private static ServerSocket ServidorSocket;
    private static final int Puerto = 1121;
    private List<ClienteEscucha> listaclientes = new ArrayList<ClienteEscucha>();
    
    public static void main(String[] args) throws IOException{
        MultiEchoServer server = new MultiEchoServer();
        try{ ServidorSocket = new ServerSocket(Puerto); }
        catch (IOException e){
            System.out.println("No se puede establecer conexion con el puerto!\n");
            System.exit(1);
        }
 
        do{
            //En espera de un nuevo cliente
            Socket cliente = ServidorSocket.accept();
            
            System.out.println("Nuevo cliente aceptado.\n");
            
            ClienteEscucha escucha = new ClienteEscucha(cliente, server);
            escucha.start();
            
            server.addClient(escucha );
            
        }while (true);
    }
 
    public void addClient(ClienteEscucha clienteEscucha) {
       listaclientes.add(clienteEscucha);
    }
 
    public void removeClient(ClienteEscucha clienteEscucha) {
       listaclientes.remove(clienteEscucha);
    }
 
    //Este metodo lo llamas cuando quieras enviar un mensaje a todos
    public void sendToAnyone(String message) {
 
        for (ClienteEscucha connection : listaclientes) {
            connection.sendMessage(message);
        }
    }
}
 
class ClienteEscucha extends Thread{
    private Socket cliente;
    private BufferedReader entrada;
    private PrintWriter salida;
    private MultiEchoServer server;
    
    public ClienteEscucha(Socket socket, MultiEchoServer server){
        cliente = socket;
        this.server = server;
 
        try{
            entrada = new BufferedReader(new InputStreamReader(cliente.getInputStream()));
            salida = new PrintWriter(cliente.getOutputStream(),true);
        }
        catch(IOException e){
            e.printStackTrace();
        }
    }
 
    public void run()
    {
        try{
            String recibido;
            
            do{
                
                recibido = entrada.readLine();
                
                salida.println(recibido);
 
            }while (!recibido.equals("QUITAR"));
        }
 
        catch(IOException e){
            e.printStackTrace();
        }
        
        finally{
            try{
                if (cliente!=null){
                    System.out.println("Cerrando la conexion del servidor...\n");
                    cliente.close();
                }
                server.removeClient(this);
            }
            catch(IOException e){
                e.printStackTrace();
            }
        }
    }
    
    protected void sendMessage(String message) {
        salida.println(message);
    }
 
}
 

Creo que esta todo.


Un saludo

[tukymix]

Bueno, creo que ya esta todo echo jejeje, gracias de todas maneras, cualquier duda te mandare mp. Gracias !!

[Profesor_Falken]

Yo no contesto privados.

Lo que quieras comentar lo puedes comentar aquí