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

class MulticastSocketClientDemo{
	public static void main (String [] args) throws IOException{
		//建立一個組播套接字并將本地機器加入到組播組中
		InetAddress group = InetAddress.getByName("228.5.6.7");
		MulticastSocket s = new MulticastSocket(6789);
		s.joinGroup(group);
	
		//從服務器端讀取數據包
		for (int i = 0; i < 10; i++){
			byte [] buffer = new byte [256];
			//創建接收數據包緩沖區并接收從服務器發送來的組播包
			DatagramPacket dgp = new DatagramPacket (
				buffer,buffer.length);
			s.receive (dgp);
			//將接收到的數據包保存在數組中，并顯示該數組中的內容
			byte [] buffer2 = new byte [dgp.getLength ()];
			System.arraycopy (dgp.getData (),0,
				buffer2,0,dgp.getLength ());
			System.out.println (new String (buffer2));
		}
		//離開組播組
		s.leaveGroup (group);
		//關閉組播套接字
		s.close ();
	}
}