sdis1819-t4g03

package multicastchannels;

import server.Server;

import threads.messageManagement;

import java.io.IOException;

import java.net.*;

import java.util.Arrays;

public class ControlChannel implements Runnable {

    private String INET_ADDR;

    private int PORT;

    private InetAddress address;

    public ControlChannel(String adr, int args) {

        this.INET_ADDR = adr;

        this.PORT = args;

    }

    public void sendMessage(byte[] message) throws IOException {

        DatagramSocket socket = new DatagramSocket();

        InetAddress group = InetAddress.getByName(INET_ADDR);

        DatagramPacket packet = new DatagramPacket(message, message.length, group, PORT);

        socket.send(packet);

        socket.close();

    }

    public void receiveMessage(String ip, int port) throws IOException {

        byte[] buffer = new byte[1024];

        MulticastSocket socket = new MulticastSocket(PORT);

        InetAddress group = InetAddress.getByName(INET_ADDR);

        socket.joinGroup(group);

        System.out.println("Waiting for multicast message...");

        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        socket.receive(packet);

        String msg = new String(packet.getData(), packet.getOffset(), packet.getLength());

        System.out.println("Multicast  message received " + msg);

        byte[] bufferCopy = Arrays.copyOf(buffer, packet.getLength());

        Server.getThreadLauncher().execute(new messageManagement(bufferCopy));

        socket.leaveGroup(group);

        socket.close();

    }

    @Override

    public void run() {

        try {

            receiveMessage(INET_ADDR, PORT);

        } catch (IOException ex) {

            ex.printStackTrace();

        }

    }

}