Java网络编程 MulticastSocket类的使用.doc
上传人:qw****27 上传时间:2024-09-12 格式:DOC 页数:7 大小:43KB 金币:15 举报 版权申诉
预览加载中,请您耐心等待几秒...

Java网络编程 MulticastSocket类的使用.doc

Java网络编程MulticastSocket类的使用.doc

预览

在线预览结束,喜欢就下载吧,查找使用更方便

15 金币

下载此文档

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

前面的例子显示了服务器程序线程发送单一的消息(通过流套接字或自寻址套接字)给唯一的客户端程序,这种行为被称为单点传送(unicasting),多数情况都不适合于单点传送,比如,摇滚歌手举办一场音乐会将通过互联网进行播放,画面和声音的质量依赖于传输速度,服务器程序要传送大约10亿字节的数据给客户端程序,使用单点传送,那么每个客户程序都要要复制一份数据,如果,互联网上有10000个客户端要收看这个音乐会,那么服务器程序通过Internet要传送10000G的数据,这必然导致网络阻塞,降低网络的传输速度。如果服务器程序要将同一信息发送给多个客户端,那么服务器程序和客户程序可以利用多点传送(multicasting)方式进行通信。多点传送就是服务程序对专用的多点传送组的IP地址和端口发送一系列自寻址数据包,通过加入操作IP地址被多点传送Socket注册,通过这个点客户程序可以接收发送给组的自寻址包(同样客户程序也可以给这个组发送自寻址包),一旦客户程序读完所有要读的自寻址数据包,那么可以通过离开组操作离开多点传送组。注意:IP地址224.0.0.1到239.255.255.255(包括)均为保留的多点传送组地址。网络API通过MulticastSocket类和MulticastSocket,以及一些辅助类(比如NetworkInterface)支持多点传送,当一个客户程序要加入多点传送组时,就创建一个MulticastSocket对象。MulticastSocket(intport)构造函数允许应用程序指定端口(通过port参数)接收自寻址包,端口必须与服务程序的端口号相匹配,要加入多点传送组,客户程序调用两个joinGroup()方法中的一个,同样要离开传送组,也要调用两个leaveGroup()方法中的一个。由于MulticastSocket扩展了DatagramSocket类,一个MulticastSocket对象就有权访问DatagramSocket方法。List6是MCClient的源代码,这段代码示范了一个客户端加入多点传送组的例子。Listing6:MCClient.java//MCClient.javaimportjava.io.*;importjava.net.*;classMCClient{publicstaticvoidmain(String[]args)throwsIOException{//CreateaMulticastSocketboundtolocalport10000.All//multicastpacketsfromtheserverprogramarereceived//onthatport.MulticastSockets=newMulticastSocket(10000);//ObtainanInetAddressobjectthatcontainsthemulticast//groupaddress231.0.0.1.TheInetAddressobjectisusedby//DatagramPacket.InetAddressgroup=InetAddress.getByName("231.0.0.1");//Jointhemulticastgroupsothatdatagrampacketscanbe//received.s.joinGroup(group);//Readseveraldatagrampacketsfromtheserverprogram.for(inti=0;i<10;i++){//Nolinewillexceed256bytes.byte[]buffer=newbyte[256];//TheDatagramPacketobjectneedsnoaddressing//informationbecausethesocketcontainstheaddress.DatagramPacketdgp=newDatagramPacket(buffer,buffer.length);//Receiveadatagrampacket.s.receive(dgp);//Createasecondbytearraywithalengththatmatches//thelengthofthesentdata.byte[]buffer2=newbyte[dgp.getLength()];//Copythesentdatatothesecondbytearray.System.arraycopy(dgp.getData(),0,buffer2,0,dgp.getLeng