multicastdatagramreceivedemo.java

java程序设计教程的源码

//【例11-12】  组播接收程序（客户端）。
//程序清单11-12:  MulticastDatagramReceiveDemo.java
package datagram;

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

public class MulticastDatagramReceiveDemo {
	public static final int PORT = 5558;

	public static void main(String[] args) throws IOException {
		new MulticastDatagramReceiveDemo();
	}

	public MulticastDatagramReceiveDemo() throws IOException {
		// 以指定端口PORT，创建MulticastSocket组播套接字的实例
		MulticastSocket multicastSocket = new MulticastSocket(PORT);
		// D类IP地址为组播地址，其IP地址范围是：224.0.0.0~239.255.255.255
		// 以指定的D类IP地址225.8.8.8创建地址实例
		InetAddress multicastIP = InetAddress.getByName("225.8.8.8");
		multicastSocket.joinGroup(multicastIP);// 将D类地址加入组播地址组
		DatagramPacket packet; // 声明一个接收数据包引用
		System.out.println("客户端接收进程已启动...");
		// 循环地接收数据包
		for (int i = 0; i < 8; i++) {
			byte[] buf = new byte[200]; // 创建字节数组buf以保存接收到的数据包
			packet = new DatagramPacket(buf, buf.length);// 创建接收数据包
			multicastSocket.receive(packet);// 用组播套接字的实例方法接收数据包
			// 提取接收的数据包中的数据并在屏幕输出
			System.out.println("客户端接收进程收到来自"
					+ packet.getAddress().getHostAddress() + "组播服务器的数据包中的数据: "
					+ new String(packet.getData()));
		}
		multicastSocket.leaveGroup(multicastIP);// D类地址离开组播地址组
		multicastSocket.close();// 关闭组播套接字
	}
}