Servidor.java

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


public class Servidor {
    static Scanner sc = new Scanner(System.in);
    private static int PORTA = 5050;  //porta padrao
    private static String IP;
	private static Map<String, PrintStream> clientes = new HashMap<>();

	public static void main(String[] args){

        System.out.println("Digite o IP em que deseja abrir o servidor: ");
        IP = sc.nextLine();


        System.out.println("Digite a porta que deseja abrir: ");
        PORTA = sc.nextInt();

		System.out.println("Servidor iniciado.");
		
		InetAddress endereco;
		try{

			ServerSocket server = new ServerSocket(PORTA);
            endereco = server.getInetAddress();

			while(true){
				Socket cliente = server.accept();
				System.out.println("Um cliente esta tentando se conectar...");
				
				new Thread(new ClienteHandler(cliente)).start();
			}
		} catch(IOException e){
			System.out.println(e + "Erro");
		}
		
	}

	private static class ClienteHandler implements Runnable {
			Socket socket;
			PrintStream saida;
			String nome;
			
			
			public ClienteHandler(Socket socket) {
				this.socket = socket;
			}
				
			@Override
			public void run(){
				try (Scanner entrada = new Scanner(socket.getInputStream())) {
					saida = new PrintStream(socket.getOutputStream());
					
					saida.println("Digite seu nome");
					nome = entrada.nextLine();
					
					System.out.println(nome + " conectou na porta: [" + socket.getInetAddress().getHostAddress() + ":" + socket.getLocalPort() + "]");
					
					synchronized(clientes) {
						clientes.put(nome, saida);
					}
					
					serverSendAll(nome + " entrou no chat");
					
					String msg;
					while(entrada.hasNextLine()){
						msg = entrada.nextLine();
						System.out.println("LOG: " + nome + ": " + msg);
						
						
						
						if("/on".equalsIgnoreCase(msg)){
							online();
						} else if("/help".equalsIgnoreCase(msg)) {
							help();
						} else if("/roll".equalsIgnoreCase(msg)) {
							enviarParaTodos(saida, msg);
							roll();
						} else {
							enviarParaTodos(saida, msg);
						} 
					}
					
				} catch (IOException e){
					
				} finally {
					try {
						socket.close();
					} catch (IOException ex) {
						ex.printStackTrace();
					}
					
					
					synchronized(clientes){
						clientes.remove(nome);
					}
					
					serverSendAll(nome + " Saiu do chat");
					System.out.println(nome + " se desconectou");
				}
			}
			
			private void enviarParaTodos(PrintStream remetente, String msg){
				synchronized(clientes){
					for(PrintStream clienteSaida : clientes.values()){
						
						if(clienteSaida	!= remetente){
							clienteSaida.println(nome + "> " + msg);
						}
						
					}
				}
			}
			
			private void serverSendAll(String msg){
				synchronized(clientes){
					for(PrintStream clienteSaida : clientes.values()){
						clienteSaida.println("Server> " + msg);
					}
				}
			}
			
			private void online(){
				StringBuilder sb = new StringBuilder("--Online-- \n");
				synchronized(clientes){
					for(String nomeCliente: clientes.keySet()){
						sb.append("* ").append(nomeCliente).append("\n");
					}
				}
				
				saida.println(sb.toString());
			}
			
			private void roll(){
				String msg = "";
				int num;
				Random rdm = new Random();
				num = rdm.nextInt(100);
				
				serverSendAll("Numero aleatorio -> " + String.valueOf(num));
			}
			
			private void help(){
				saida.println("/on   - Ver quem esta online \n" +
							  "/help - Ver os comandos\n" +
							  "/roll - Sorteia um numero de 1 ate 100");
			}
			
			
		}
	
	
	
	
}