Chat en Java para 5 clientes

[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