Java套接字编程（下）

　DGSClient由创建一个绑定任意本地（客户端）端口好的DatagramSocket对象开始，然后装入带有文本信息的数组buffer和描述服务器主机IP地址的InetAddress子类对象的引用，接下来，DGSClient创建了一个DatagramPacket对象，该对象加入了带文本信息的缓冲器的引用，InetAddress子类对象的引用，以及服务端口号10000, DatagramPacket的自寻址数据包通过方法sent()发送给服务器程序，于是一个包含服务程序响应的新的DatagramPacket对象被创建，receive()得到响应的自寻址数据包，然后自寻址数据包的getData()方法返回该自寻址数据包的一个引用，最后关闭 DatagramSocket。

　　DGSServer服务程序补充了DGSClient的不足，List5是DGSServer的源代码：

Listing 5: DGSServer.java // DGSServer.java import java.io.*; import java.net.*; class DGSServer { 　public static void main (String [] args) throws IOException 　{ 　　System.out.println ("Server starting ...\n"); 　　// Create a datagram socket bound to port 10000. Datagram 　　// packets sent from client programs arrive at this port. 　　DatagramSocket s = new DatagramSocket (10000); 　　// Create a byte array to hold data contents of datagram 　　// packet. 　　byte [] data = new byte [100]; 　　// Create a DatagramPacket object that encapsulates a reference 　　// to the byte array and destination address information. The 　　// DatagramPacket object is not initialized to an address 　　// because it obtains that address from the client program. 　　DatagramPacket dgp = new DatagramPacket (data, data.length); 　　// Enter an infinite loop. Press Ctrl+C to terminate program. 　　while (true) 　　{ 　　　// Receive a datagram packet from the client program. 　　　s.receive (dgp); 　　　// Display contents of datagram packet. 　　　System.out.println (new String (data)); 　　　// Echo datagram packet back to client program. 　　s.send (dgp); 　} } }

　　DGSServer创建了一个绑定端口10000的自寻址套接字，然后创建一个字节数组容纳自寻址信息，并创建自寻址包，下一步，DGSServer进入一个无限循环中以接收自寻址数据包、显示内容并将响应返回客户端，自寻址套接没有关闭，因为循环是无限的。

　　在编译DGSServer 和DGSClient的源代码后，由输入java DGSServer开始运行DGSServer，然后在同一主机上输入Java DGSClient开始运行DGSClient，如果DGSServer与DGSClient运行于不同主机，在输入时注意要在命令行加上服务程序的主机名或IP地址，如：java DGSClient www.yesky.com

多点传送和MulticastSocket类

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

　　如果服务器程序要将同一信息发送给多个客户端，那么服务器程序和客户程序可以利用多点传送（multicasting）方式进行通信。多点传送就是服务程序对专用的多点传送组的IP地址和端口发送一系列自寻址数据包，通过加入操作IP地址被多点传送Socket注册，通过这个点客户程序可以接收发送给组的自寻址包（同样客户程序也可以给这个组发送自寻址包），一旦客户程序读完所有要读的自寻址数据包，那么可以通过离开组操作离开多点传送组。

　　注意：IP地址224.0.0.1 到 239.255.255.255（包括）均为保留的多点传送组地址。

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

　　由于MulticastSocket扩展了DatagramSocket类，一个MulticastSocket对象就有权访问DatagramSocket方法。

　　List6是MCClient的源代码，这段代码示范了一个客户端加入多点传送组的例子。

Listing 6: MCClient.java // MCClient.java import java.io.*; import java.net.*; class MCClient { 　public static void main (String [] args) throws IOException 　{ 　　// Create a MulticastSocket bound to local port 10000. All 　　// multicast packets from the server program are received 　　// on that port. 　　MulticastSocket s = new MulticastSocket (10000); 　　// Obtain an InetAddress object that contains the multicast 　　// group address 231.0.0.1. The InetAddress object is used by 　　// DatagramPacket. 　　InetAddress group = InetAddress.getByName ("231.0.0.1"); 　　// Join the multicast group so that datagram packets can be 　　// received. 　　s.joinGroup (group); 　　// Read several datagram packets from the server program. 　　for (int i = 0; i < 10; i++) 　　{ 　　　// No line will exceed 256 bytes. 　　　byte [] buffer = new byte [256]; 　　　// The DatagramPacket object needs no addressing 　　　// information because the socket contains the address. 　　　DatagramPacket dgp = new DatagramPacket (buffer, 　　　　　　buffer.length); 　　　// Receive a datagram packet. 　　　s.receive (dgp); 　　　// Create a second byte array with a length that matches 　　　// the length of the sent data. 　　　byte [] buffer2 = new byte [dgp.getLength ()]; 　　　// Copy the sent data to the second byte array. 　　　System.arraycopy (dgp.getData (), 　　　　　　　　0, 　　　　　　　　buffer2, 　　　　　　　　0, 　　　　　　　　dgp.getLength ()); 　　　// Print the contents of the second byte array. (Try 　　　// printing the contents of buffer. You will soon see why 　　　// buffer2 is used.) 　　　System.out.println (new String (buffer2)); 　　} 　　// Leave the multicast group. 　　s.leaveGroup (group); 　　// Close the socket. 　　s.close (); 　} }