Chat en Java para 5 clientes

[educacanis]

Hola soy un poco nueva en ésto. Tenemos que implementar un chat en Java para 5 clientes. Por ahora lo que he conseguido es que el servidor hable con el cliente todo lo que quiera. Tengo un server_main en el que cada vez que se conecta un cliente se crea un Server_Thread que es el que "habla" con el cliente. Es decir por cada Cliente que instancio se instancia un Server_Thread.

Lo que no sé es cómo conseguir que el mensaje que manda un cliente se envíe al resto. Supongo que tengo que tener un arraylist de Server_Thread? la verdad que he intentado mogollón de cosas y no sé por donde cogerlo. Os dejo las clases.

Hay un lanzador del Server que lo único que hace es instanciar un Server_Main y arrancarlo y un Lanzador de Cliente que instancia el cliente.
y luego

SERVER_MAIN

Código Java:

import java.net.*;
import java.util.ArrayList;
import java.io.*;
 
 
//Clase con los atributos, constructores del Socket, server, etc.
public class Server_Main {
    protected Socket clientSocket;
    private ServerSocket serverSocket = null;
    private int port = 5000;
    
    public static ArrayList<Server_Thread> clientes = new ArrayList<Server_Thread>(); ;
 
    public Server_Main() {
 
    }
 
    public Server_Main(int port) {
        this.port = port;
    }
 
    public void strart() throws IOException {
        System.out.println("inicio del socket");
        this.serverSocket = new ServerSocket(port);
        LazadorClientesEnThread();
    }
 
    public int strart1() {
        System.out.println("inicio del socket");
        try {
            this.serverSocket = new ServerSocket(port);
            LazadorClientesEnThread();
            return 1;
        } catch (SocketException e) {
            return 0;
        } catch (IOException e) {
            System.err.println("Could not listen on port:" + port);
            System.exit(1);
        }
        return -1;
    }
 
    public void LazadorClientesEnThread() {
        try {
            while (true) {
                System.out.println("llega una nueva conexion");
                Server_Thread temp = new Server_Thread(serverSocket.accept());
                clientes.add(temp);
                temp.start();
            }
        } catch (IOException e) {
            System.err.println("Accept failed.");
            System.exit(1);
        }
    }
 
    public void STOP() throws IOException {
        System.out.println("Fin del socket");
        try {
            serverSocket.close();
        } catch (IOException e) {
            System.err.println("Could not listen on port:" + port);
            System.exit(1);
        }
    }
}
 

Continuo en otro post

[educacanis]

SERVER_THREAD

Código Java:

import java.net.*;
import java.io.*;
 
public class Server_Thread extends Thread {
    protected Socket clientSocket;
 
    public Server_Thread(Socket clientSoc) {
        clientSocket = clientSoc;
    }
 
    public void run() {
        System.out.println("Iniciando hilo......");
 
        try {
            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),
                    true);
            BufferedReader in = new BufferedReader(new InputStreamReader(
                    clientSocket.getInputStream()));
 
            String inputLine;
            String nombreReceptor;
 
            //recoge lo que ha recibido y lo devuelvo al mismo hilo
            while ((inputLine = in.readLine()) != null) {   
                
                
                //nombreReceptor = 
                System.out.println("Server: " + inputLine);
                // para hacer ECHO, le envio lo que he recibido
                out.println("ECHO:"+ clientSocket.getPort() + inputLine);
 
                if (inputLine.equals("Bye."))
                    break;
            }
 
            out.close();
            in.close();
            clientSocket.close();
 
        } catch (IOException e) {
            System.err.println("Problem with Communication Server");
            System.exit(1);
        }
    }
}
 

CLIENTE

Código Java:

import java.io.*;
import java.net.*;
import java.util.Scanner;
 
public class Cliente implements Runnable {
    private static Scanner teclado = new Scanner(System.in);
 
    private String serverHostname = new String("127.0.0.1");
    private int port = 5000;
    private String nombre = "clienteSinNombre";
 
    public Cliente(String serverHostname, int port, String nombre) {
        super();
        this.serverHostname = serverHostname;
        this.port = port;
        this.nombre = nombre;
    }
 
    public Cliente() {
    }
 
    public void run() {
        String nombreReceptor = "";
 
        System.out.println("Intentando conexión del cliente " + nombre
                + " al servidor" + serverHostname + " en puerto " + port);
 
        Socket echoSocket = null;
        PrintWriter out = null;
        BufferedReader in = null;
 
        try {
            echoSocket = new Socket(serverHostname, 5000);
 
            out = new PrintWriter(echoSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(
                    echoSocket.getInputStream()));
 
        } catch (UnknownHostException e) {
            System.err.println("No conozco el servidor: " + serverHostname);
            System.exit(1);
        } catch (IOException e) {
            System.err.println("No consigo entrar " + "al servidor "
                    + serverHostname);
            System.exit(1);
        }
 
        String userInput = "";
        
        System.out.println("¿Con quien te quieres comunicar?");
        nombreReceptor = teclado.next();
 
        try {
            do{
                // recoge el mensaje que escribe el cliente
                System.out.println("Escribe:");
                userInput = teclado.nextLine();
                out.println(nombreReceptor + "@" + userInput); // lo envía al servidor
 
                // end loop
                if (userInput.equals("Bye."))
                    break;
 
                System.out.println("echo: " + in.readLine());
            }while (true);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
        out.close();
        try {
            in.close();
            // stdIn.close();
            echoSocket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
}
 

Solo tiene que funcionar en CONSOLE de Eclipse no tiene que tener interfaz