当前页面: 开发资料首页 → Java 专题 → 用数据报进行广播通讯

用数据报进行广播通讯

摘要: 用数据报进行广播通讯

用数据报进行广播通讯

　　DatagramSocket只允许数据报发送一个目的地址，java.net包中提供了一个类MulticastSocket，允许数据报以广播方式发送到该端口的所有客户。MulticastSocket用在客户端，监听服务器广播来的数据。

　　我们对上面的程序作一些修改，利用MulticastSocket实现广播通信。新程序完成的功能是使同时运行的多个客户程序能够接收到服务器发送来的相同的信息，显示在各自的屏幕上。

1. 客户方程序:MulticastClient.java

　　import java.io.*;
　　import java.net.*;
　　import java.util.*;
　　public class MulticastClient {
　　　　public static void main(String args[]) throws IOException
　　　　{
　　　　　MulticastSocket socket=new MulticastSocket(4446);
　　　　　//创建4446端口的广播套接字
　　　　　InetAddress address=InetAddress.getByName("230.0.0.1");
　　　　　//得到230.0.0.1的地址信息
　　　　　socket.joinGroup(address);
　　　　　//使用joinGroup()将广播套接字绑定到地址上
　　　　　DatagramPacket packet;

　　　　　for(int i=0;i<5;i++) {
　　　　　　　byte[] buf=new byte[256];
　　　　　　　//创建缓冲区
　　　　　　　packet=new DatagramPacket(buf,buf.length);
　　　　　　　//创建接收数据报
　　　　　　　socket.receive(packet); //接收
　　　　　　　String received=new String(packet.getData());
　　　　　　　//由接收到的数据报得到字节数组，
　　　　　　　//并由此构造一个String对象
　　　　　　　System.out.println("Quote of theMoment:"+received);
　　　　　　　//打印得到的字符串
　　　　　} //循环5次
　　　　　socket.leaveGroup(address);
　　　　　//把广播套接字从地址上解除绑定
　　　　　socket.close(); //关闭广播套接字
　　　}
　}

　2. 服务器方程序:MulticastServer.java

　　public class MulticastServer{
　　　　public static void main(String args[]) throws java.io.IOException
　　　　{
　　　　　　new MulticastServerThread().start();
　　　　　　//启动一个服务器线程
　　　　}
　　}

　3. 程序MulticastServerThread.java

　　import java.io.*;
　　import java.net.*;
　　import java.util.*;
　　public class MulticastServerThread extends QuoteServerThread
　　//从QuoteServerThread继承得到新的服务器线程类MulticastServerThread
　　{
　　　　Private long FIVE_SECOND=5000; //定义常量，5秒钟
　　　　public MulticastServerThread(String name) throws IOException
　　　　{
　　　　　　super("MulticastServerThread");
　　　　　　//调用父类，也就是QuoteServerThread的构造函数
　　　　}

　　　　public void run() //重写父类的线程主体
　　　　{
　　　　　while(moreQuotes) {
　　　　　//根据标志变量判断是否继续循环
　　　　　　try{
　　　　　　　　byte[] buf=new byte[256];
　　　　　　　　//创建缓冲区
　　　　　　　　String dString=null;
　　　　　　　　if(in==null) dString=new Date().toString();
　　　　　　　　//如果初始化的时候打开文件失败了，
　　　　　　　　//则使用日期作为要传送的字符串
　　　　　　　　else dString=getNextQuote();
　　　　　　　　//否则调用成员函数从文件中读出字符串
　　　　　　　　buf=dString.getByte();
　　　　　　　　//把String转换成字节数组，以便传送send it
　　　　　　　　InetAddress group=InetAddress.getByName("230.0.0.1");
　　　　　　　　//得到230.0.0.1的地址信息
　　　　　　　　DatagramPacket packet=new DatagramPacket(buf,buf.length,group,4446);
　　　　　　　　//根据缓冲区，广播地址，和端口号创建DatagramPacket对象
　　　　　　　　socket.send(packet); //发送该Packet
　　　　　　　　try{
　　　　　　　　　　sleep((long)(Math.random()*FIVE_SECONDS));
　　　　　　　　　　//随机等待一段时间，0～5秒之间
　　　　　　　　}catch(InterruptedException e) { } //异常处理
　　　　　　}catch(IOException e){ //异常处理
　　　　　　　　e.printStackTrace( ); //打印错误栈

　　　　　　　　moreQuotes=false; //置结束循环标志
　　　　　　}
　　　　}
　　　　socket.close( ); //关闭广播套接口
　　　}
　}

　　至此，Java网络编程这一章已经讲解完毕。读者通过学习，应该对网络编程有了一个清晰的认识，可能对某些概念还不是十分的清楚，还是需要更多的实践来进一步掌握。编程语言的学习不同于一般的学习，及其强调实践的重要性。读者应该对URL网络编程，Socket中的TCP，UDP编程进行大量的练习才能更好的掌握本章中所提到的一些概念，才能真正学到Java网络编程的精髓！

　　最后几个小节所举的例子，读者务必要亲自试验一下，如果遇到问题，想办法解决之。最好能根据自己的意图加以改进。这样才能更好的理解这几个程序，理解其中所包含的编程思想。