/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package multicastserversample;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.HashSet;
import java.util.Set;

/**
 *
 */
public class Receiver
{
    public void receive() throws IOException
    {
        MulticastSocket socket = new MulticastSocket(10101);
        InetAddress mcastAddress = InetAddress.getByName("ff35:40:fdb4:353a:c83f:10::10");
        socket.joinGroup(mcastAddress);

        Set set = new HashSet();

        byte[] data = new byte[256];
        DatagramPacket packet = new DatagramPacket(data, data.length);
        while(true)
        {
            socket.receive(packet);
            InetAddress address = packet.getAddress();
            String ipv6 = address.getHostAddress();
            int length = packet.getLength();
            String str = new String(data, 0, length);

            set.add(ipv6);
            System.out.println(set.size());
            System.out.println(str);
        }
    }
}