java中的组播编程

编辑一个java组播应用程序的过程如下

1. 创建一个用于发送和接收的MulticastSocket组播套接字对象
2. 创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象
3. 使用组播套接字joinGroup(),将其加入到一个组播
4. 使用组播套接字的send()方法，将组播数据包对象放入其中，发送组播数据包.
   或者
   使用组播套接字的receive（）方法，将组播数据包对象放入其中，接收组播数据包
5. 解码组播数据包提取信息，并依据得到的信息作出响应String s = new String(dp.getData(), 0, dp.getLength());
6. 重复过程4和5，即在while循环中实现。
7. 使用组播套接字的leaveGroup()方法，离开组播组；关闭组播套接字

 

接收组播数据包程序：

public class MulticastReceived {

	public static void main(String[] args) throws Exception {
		InetAddress group = InetAddress.getByName("224.0.0.4"); // 组播地址
		int port = 4006; // 端口
		MulticastSocket msr = null;
		try {
			msr = new MulticastSocket(port); // 1.创建一个用于发送和接收的MulticastSocket组播套接字对象
			msr.joinGroup(group); // 3.使用组播套接字joinGroup(),将其加入到一个组播
			byte[] buffer = new byte[8192];
			System.out.println("接收数据包启动！（启动时间：）" + new java.util.Date() + ")");
			while (true) {
				DatagramPacket dp = new DatagramPacket(buffer, buffer.length); // 2.创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象
				msr.receive(dp); // 4.使用组播套接字的receive（）方法，将组播数据包对象放入其中，接收组播数据包
				String s = new String(dp.getData(), 0, dp.getLength()); // 5.解码组播数据包提取信息，并依据得到的信息作出响应
				System.out.println(s);
			}
		} catch (IOException e) {
			e.printStackTrace();

		} finally {
			if (msr != null) {
				try {
					msr.leaveGroup(group); // 7.使用组播套接字的leaveGroup()方法，离开组播组
					msr.close(); // 关闭组播套接字
				} catch (IOException e) {
				}
			}
		}
	}
}

 

发送组播数据包程序：

public class MulticastSender {

	public static void main(String[] args) throws Exception {
		InetAddress group = InetAddress.getByName("224.0.0.1"); // 组播地址
		int port = 4000; // 端口
		MulticastSocket mss = null;
		try {
			mss = new MulticastSocket(port); // 1.创建一个用于发送和接收的MulticastSocket组播套接字对象
			mss.joinGroup(group); // 3.使用组播套接字joinGroup(),将其加入到一个组播
			byte[] buffer = new byte[8192];
			System.out.println("接收数据包启动！（启动时间：）" + new java.util.Date() + ")");
			while (true) {
				String message = "Hello" + new java.util.Date();
				byte[] buffer2 = message.getBytes(); // 2.创建一个指定缓冲区大小及组播地址和端口的DatagramPacket组播数据包对象

				DatagramPacket dp = new DatagramPacket(buffer, buffer.length, group, port);
				// msr.receive(dp); //接收组播数据包

				mss.send(dp); // 4.使用组播套接字的send()方法，将组播数据包对象放入其中，发送组播数据包
				// String s = new String(dp.getData(), 0, dp.getLength()); //5.解码组播数据包提取信息，并依据得到的信息作出响应
				System.out.println("发送数据包给" + group + ":" + port);
				Thread.sleep(1000);
			}
		} catch (IOException e) {
			e.printStackTrace();

		} finally {
			if (mss != null) {
				try {
					mss.leaveGroup(group); // 7.使用组播套接字的leaveGroup()方法，离开组播组
					mss.close(); // 关闭组播套接字
				} catch (IOException e) {
				}
			}
		}
	}
}

 

评论

3 楼 arthaslery 2015-12-09  

4.还有一点是要在最上面加上
import java.io.*;
import java.net.*;

2 楼 arthaslery 2015-12-09  

博主的程序改一改以后是很好用的
1.发送数据包的buffer2要改成buffer，然后删掉上面的buffer定义
2.组播地址224.0.0.4和224.0.0.1要改成相同的
3.发送端的socket端口不重要，但是接收端的socket端口和发送端的packet目标端口必须相同，也就是说要把4006和4000改成一样的

1 楼 戴改改 2015-05-03  

发送的地址和 接受的地址不一样啊。。
一个.4一个.1；
我自己实验 用230.0.0.1 在两台机器上就没法接受了
只有在224才行。。。