multicastsocketclientdemo.java

来自「java十大经典案例。打开Java相关文件」· Java 代码 · 共 30 行

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 ();
	}
}