java网络编程 multicastsocket类的使用new

《java网络编程 multicastsocket类的使用new》由会员上传分享，免费在线阅读，更多相关内容在学术论文-天天文库。

1、前面的例子显示了服务器程序线程发送单一的消息（通过流套接字或自寻址套接字）给唯一的客户端程序，这种行为被称为单点传送（unicasting），多数情况都不适合于单点传送，比如，摇滚歌手举办一场音乐会将通过互联网进行播放，画面和声音的质量依赖于传输速度，服务器程序要传送大约10亿字节的数据给客户端程序，使用单点传送，那么每个客户程序都要要复制一份数据，如果，互联网上有10000个客户端要收看这个音乐会，那么服务器程序通过Internet要传送10000G的数据，这必然导致网络阻塞，降低网络的传输速度。如果服务器程序要将同一信息发送给多个客

2、户端，那么服务器程序和客户程序可以利用多点传送（multicasting）方式进行通信。多点传送就是服务程序对专用的多点传送组的IP地址和端口发送一系列自寻址数据包，通过加入操作IP地址被多点传送Socket注册，通过这个点客户程序可以接收发送给组的自寻址包（同样客户程序也可以给这个组发送自寻址包），一旦客户程序读完所有要读的自寻址数据包，那么可以通过离开组操作离开多点传送组。注意：IP地址224.0.0.1到239.255.255.255（包括）均为保留的多点传送组地址。网络API通过MulticastSocket类和Multicas

3、tSocket，以及一些辅助类（比如NetworkInterface）支持多点传送，当一个客户程序要加入多点传送组时，就创建一个MulticastSocket对象。MulticastSocket(intport)构造函数允许应用程序指定端口（通过port参数）接收自寻址包，端口必须与服务程序的端口号相匹配，要加入多点传送组，客户程序调用两个joinGroup()方法中的一个，同样要离开传送组，也要调用两个leaveGroup()方法中的一个。由于MulticastSocket扩展了DatagramSocket类，一个MulticastS

4、ocket对象就有权访问DatagramSocket方法。List6是MCClient的源代码，这段代码示范了一个客户端加入多点传送组的例子。Listing6:MCClient.java//MCClient.javaimportjava.io.*;importjava.net.*;classMCClient{　publicstaticvoidmain(String[]args)throwsIOException　{　　//CreateaMulticastSocketboundtolocalport10000.All　　//multica

5、stpacketsfromtheserverprogramarereceived　　//onthatport.　　MulticastSockets=newMulticastSocket(10000);　　//ObtainanInetAddressobjectthatcontainsthemulticast　　//groupaddress231.0.0.1.TheInetAddressobjectisusedby　　//DatagramPacket.　　InetAddressgroup=InetAddress.getByName("231

6、.0.0.1");　　//Jointhemulticastgroupsothatdatagrampacketscanbe　　//received.　　s.joinGroup(group);　　//Readseveraldatagrampacketsfromtheserverprogram.　　for(inti=0;i<10;i++)　　{　　　//Nolinewillexceed256bytes.　　　byte[]buffer=newbyte[256];　　　//TheDatagramPacketobjectneedsnoaddress

7、ing　　　//informationbecausethesocketcontainstheaddress.　　　DatagramPacketdgp=newDatagramPacket(buffer,　　　　　　buffer.length);　　　//Receiveadatagrampacket.　　　s.receive(dgp);　　　//Createasecondbytearraywithalengththatmatches　　　//thelengthofthesentdata.　　　byte[]buffer2=newbyte[dg

8、p.getLength()];　　　//Copythesentdatatothesecondbytearray.　　　System.arraycopy(dgp.getData(),　　　　　　　　0,