senddataserver.java

组播发送与接收的简单java源码

/********************************************************************************
 * 输入参数：
 *           
 *	     
 *
 * 输出参数：
 *           
 *           
 *
 * 调用模块：
 *
 *			java.io.*;
 *			java.net.*;
 *			java.util.Data.*;
 *
 * 被调用模块：
 *          
 *
 * 处理：
 *    
 * 1、	创建一个组播组
 * 
 * 2、一台主机作为组播源不断向组播组发送数据。
 *
 * 
 ********************************************************************************/
/******************************************************************************** 
 * 编    号：  200409241418 
 * 编 辑 人：  赵文明
 * 
 *********************************************************************************
 *
 * 注意：包名子必须是这些类文件存储的目录名。比如：我把所有的类文件存在个g:\codetest下面，
 *			分别是receiveClientFrame.java，receivedataClient.java和senddataServer.java，
 * 			运行时采用这样的命令：javac -classpath g:\ receivedataClient.java
 * 			指明包“codetest”所在的目录是“g:\".
 *
 *
 ********************************************************************************/
//package senddataserver;
//package	codetest;
import	java.io.*;
import	java.net.*;
import	java.util.Date;

class	senddataServer
{
	
	public	senddataServer()
	{
		int	port;
		InetAddress	group;
		MulticastSocket	socket;
		
		try
		{
			//设置组播组监听端口为5000
			port	=	5000;
			
			//设置组播组地址为239.255.0.0
			group	=	InetAddress.getByName("239.255.0.0");
			
			//创建并初始化MulticastSocket实例
			socket	=	new	MulticastSocket(port);
			
			//设置套接字的接收数据报的最长时间
			socket.setSoTimeout(1000);
			
			//设置组播数据包的发送范围
			socket.setTimeToLive(3);
			
			//加入组播组，是否可选？
			socket.joinGroup(group);
			
			//初始化所要发送的信息
			String	outMessage	=	"Hello,GXNUNC0403!";
			
			//char[]	data	=	outMessage.toCharArray();
			byte[]	data	=	outMessage.getBytes();
				
			//声明DatagramPacket对象
			DatagramPacket	packet;
			
			//发送数据
			while(true)
			{
				
					//创建和初始化DatagramPacket实例
					packet	=	new	DatagramPacket(data,data.length,group,port);

					//向组播组循环发送组播数据
					socket.send(packet);
			
					System.out.println("Message send:"+outMessage);
			}				//end of while
			
			
		}					//end of try
		
		
		//出错处理
		catch(Exception e)
		{
				System.out.println("Error:"	+	e);	
		}
		
		
	}						//end of public	senddataServer()
	
	//main函数
	public static	void	main(String[]	args)
	{
			senddataServer	svr	=	new	senddataServer();
	}
	
	
}							//end of class	senddataServer