ServerMulticast.java

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.NetworkInterface;
import java.net.InetSocketAddress;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.Scanner;

public class ServerMulticast implements Runnable {

	
    private MulticastSocket receiveSocket;
    private ArrayList<String> nomes;

    public ServerMulticast() throws IOException {
        this.receiveSocket = new MulticastSocket(4322);
        this.nomes = new ArrayList<>();
    }

    @Override
    public void run() {
        try {

            InetAddress grupo = InetAddress.getByName("230.0.0.0");
            InetSocketAddress socketAddress = new InetSocketAddress(grupo, 4322);
            NetworkInterface networkInterface = NetworkInterface.getByInetAddress(grupo);

            receiveSocket.joinGroup(socketAddress, networkInterface);

            System.out.println("[Servidor] Thread de recebimento de nomes iniciada na porta 4322.");

            while (true) {
                byte[] buffer = new byte[1024];
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

                receiveSocket.receive(packet);

                String nome = new String(packet.getData(), 0, packet.getLength());
                nomes.add(nome);
                System.out.println("[Servidor] Nome recebido: " + nome);
                System.out.println("[Servidor] Lista de nomes: " + nomes);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                InetAddress grupo = InetAddress.getByName("230.0.0.0");
                InetSocketAddress socketAddress = new InetSocketAddress(grupo, 4322);
                NetworkInterface networkInterface = NetworkInterface.getByInetAddress(grupo);
                receiveSocket.leaveGroup(socketAddress, networkInterface);
                receiveSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

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

        ServerMulticast server = new ServerMulticast();
        Thread thread = new Thread(server);
        thread.start();

        Scanner sc = new Scanner(System.in);
        MulticastSocket sendSocket = new MulticastSocket();
        InetAddress grupo = InetAddress.getByName("230.0.0.0");

        while (true) {
            System.out.println("\nEscolha o tópico para enviar a mensagem:");
            System.out.println("1 - Avisos Gerais (Porta 4321)");
            System.out.println("2 - Atividades Extracurriculares (Porta 4322)");
            System.out.print("Opção: ");
            int opcao = Integer.parseInt(sc.nextLine());

            if (opcao < 1 || opcao > 2) {
                System.out.println("Opção inválida!");
                continue;
            }

            int porta = (opcao == 1) ? 4321 : 4323;
            String nomeTopico = (opcao == 1) ? "Avisos Gerais" : "Atividades Extracurriculares";

            System.out.print("[Servidor] Digite a mensagem (ou 'encerrar' para sair): ");
            String mensagem = sc.nextLine();

            if (mensagem.equalsIgnoreCase("encerrar")) {
                mensagem = "Servidor Encerrado!";
                String mensagemFormatada = formatarMensagem(nomeTopico, mensagem);
                byte[] envio = mensagemFormatada.getBytes();
                DatagramPacket pacote = new DatagramPacket(envio, envio.length, grupo, porta);
                sendSocket.send(pacote);
                break;
            }

            String mensagemFormatada = formatarMensagem(nomeTopico, mensagem);

            byte[] envio = mensagemFormatada.getBytes();
            DatagramPacket pacote = new DatagramPacket(envio, envio.length, grupo, porta);
            sendSocket.send(pacote);

            System.out.println("Mensagem enviada para o tópico: " + nomeTopico);
        }

        System.out.println("[Servidor] Multicast encerrado.");
        sendSocket.close();
    }

    private static String formatarMensagem(String nomeTopico, String body) {
        String dataHora = new SimpleDateFormat("dd/MM/yyyy - HH:mm").format(new Date());

        return String.format("[%s] %s: %s", dataHora, nomeTopico, body);
    }

	public static void limparConsole() {
        System.out.print("\033[H\033[2J");
        System.out.flush();
    }
}