java组播技术

《java组播技术》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

·在信息时代，网络技术应用已非常普通。其中非常多应用都依赖于从一个主机向多个主机或从多个主机向多个主机发送同一信息的能力，在Internet上分发的数目可能达数十万台，这些都需要更高的带宽，并且大大超出了单播的能力。一种能最大限度地利用现有带宽的重要技术是IP组播。1．IP组播技术的概念IP组播技术，是一种允许一台或多台主机（组播源）发送单一数据包到多台主机（一次的，同时的）的TCP/IP网络技术,是一点对多点的通信。在网络多媒体广播的应用中，当需要将一个节点的信号传送到多个节点时，无论是采用重复点对点通信方式，还是采用广播方式，都会严重浪费网络带宽，只有组播才是最佳的选择。组播能使一个或多个组播源只把数据包发送给特定的组播组，而只有加入该组播组的主机才能接收到数据包。2．IP组播地址IP组播通信依赖于IP组播地址，在IPv4中他是个D类IP地址，范围从224.0.0.0到239.255.255.255，并被划分为局部链接组播地址、预留组播地址和管理权限组播地址三类。其中，局部链接组播地址范围在224.0.0.0~224.0.0.255，这是为路由协议和其他用途保留的地址，路由器并不转发属于此范围的IP包；预留组播地址为224.0.1.0~238.255.255.255，可用于全球范围（如Internet）或网络协议；管理权限组播地址为239.0.0.0~239.255.255.255，可供组织内部使用，类似于私有IP地址，不能用于Internet，可限制组播范围。3．组播组使用同一个IP组播地址接收组播数据包的所有主机构成了一个主机组，也称为组播组。一个组播组的成员是随时变动的，一台主机能随时加入或离开组播组，组播组成员的数目和所在的地理位置也不受限制，一台主机也能属于几个组播组。此外，不属于某一个组播组的主机也能向该组播组发送数据包。本文使用MulticastSocket类的实例编写组播应用，MulticastSocket类提供连接和离开组播等操作。MultiSender类清单packagerecmail.multiservice;importjava.net.*;importjava.io.IOException;/** *该类封装了MulticastSocket类,完成了MulticastSocket类实例的创建、初始化功能, *并提供了一个发送数据的接口. */publicclassMultiSender{ publicstaticfinalintMultiSender_Port=4099; privateMulticastSocketroad; privateInetAddressia; publicMultiSender(){   try{     //组播地址     ia=InetAddress.getByName("239.66.69.18");     road=newMulticastSocket(MultiSender_Port);     road.joinGroup(ia);   }   catch(UnknownHostExceptionex){    }   catch(IOExceptionex1){   } } publicInetAddressgetInetAddress(){   returnia; } publicMulticastSocketgetRoad(){   returnroad; } publicvoidsend(byte[]b){   DatagramPacketdp=newDatagramPacket(b,0,b.length,                                              ia,MultiSender.MultiSender_Port);   try{     road.send(dp);   }   catch(IOExceptionex){     ex.printStackTrace();   } }}ImageServer类,使用上面的类发送文件数据.packagerecmail.multiservice;importjava.io.*;importjavax.swing.Timer;importjava.awt.event.*;importjava.awt.image.*;importjava.util.*;importjava.io.FileFilter;importjava.io.FilenameFilter;/** *本类利用MultiSender类发送文件数据到一个组播组发送数据. */publicclassImageServer   extendsThreadimplementsActionListener{ Timertimer; BufferedImageimage; ArrayListstreamfragments; intcounter=0; byte[]imagebyte; ArrayListlistener; MultiSendersender; publicImageServer(ArrayListf){   timer=newTimer(50,this);    timer.addActionListener(this);   listener=newArrayList();   streamfragments=f;   sender=newMultiSender();   timer.start(); } publicvoidaddDataSwapListener(DataSwapListenerdsl){   listener.add(dsl); } publicvoidremoveDataSwapListener(DataSwapListenerdsl){   listener.remove(dsl); } privatevoidprocessEvent(){   for(inti=0;i=streamfragments.size())     counter=0; } publicvoidrun(){   while(true){     try{       this.sleep(20);     }     catch(InterruptedExceptionex){      }   } } publicstaticvoidmain(String[]args){   Stringfile[];   ArrayListal=newArrayList();   Stringpath="E:＼＼mzip＼＼";    Filef=newFile(path);   file=f.list();   for(inti=0;i