Java基于UDP的多点广播数据报源码.docx

多点广播原理：若要使用多点广播时，则需要让一个数据报标有一组目标主机地址，当数据报发出后，整个组的所有主机都能收到该数据报。IP多点广播（或多点发送）实现了将单一信息发送到多个接收者的广播，其思想是设置一组特殊网络地址作为多点广播地址，每一个多点广播地址都被看做一个组，当客户端需要发送、接收广播信息时，加入到该组即可。定义Weather类package com.han; import .*; public class Weather extends Thread String weather =节目预告： 八点有大型晚会，请收听; int port =9898; /定义端口号 InetAddress iaddress;/没法初始化，这里只能声明。因为初始化new对象时要抛出异常所以在成员变量区域是语法通不过的。 MulticastSocket socket; /DatagramSocket只允许数据报发送给指定的目标地址，而MulticastSocket可以将数据报以广播方式发送到数量不等的多个客户端。 /在构造方法中初始化成员变量 Weather() try iaddress=InetAddress.getByName();/初始ip socket=new MulticastSocket(port); /根据端口号创建广播socket socket.setTimeToLive(1); /设置socket生存周期 socket.joinGroup(iaddress); /将该地址加入广播地址组 catch(Exception e) e.printStackTrace(); Override /最简单的方法也就是建立一个线程来运行 public void run() while(true) byte data=weather.getBytes(); /获取weather字节流 /构造数据报包，用来将长度为length偏移量为offset的包发送到指定主机上的指定端口号。length参数必须小于等于data.length。 DatagramPacket packet=new DatagramPacket(data,data.length,iaddress,port); System.out.println(new String(data); try socket.send(packet); /发送数据包 sleep(3000);/线程休眠3秒 catch (Exception e) / TODO Auto-generated catch block e.printStackTrace(); public static void main(String args) Weather w=new Weather(); w.start(); 定义Receive类java package com.han; import java.awt.BorderLayout; import java.awt.Color; import java.awt.event.*; import java.io.IOException; import .DatagramPacket; import .InetAddress; import .MulticastSocket; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; public class Receive extends JFrame implements Runnable, ActionListener private static final long serialVersionUID = 3362377947503474102L; int port=9898; /指定端口号 InetAddress group; /初始多播地址组 MulticastSocket socket; /创建socket接收和发送数据包 DatagramPacket packet; /定义数据包 JButton ince=new JButton(开始接收); /接收按钮 JButton stop=new JButton(停止接收); /停止按钮 JTextArea inceAr=new JTextArea(10,20); JTextArea inced=new JTextArea(10,20); Thread thread; /创建新线程 boolean b = false; byte buf=new byte30;. /在构造方法中设置具体参数特性，也就是初始化 public Receive() super(广播数据报); thread=new Thread(this); ince.addActionListener(this); /绑定按钮事件 stop.addActionListener(this); inceAr.setForeground(Color.blue); JPanel north=new JPanel(); north.add(ince); north.add(stop); add(north,BorderLayout.NORTH); JPanel center=new JPanel(); JScrollPane sp=new JScrollPane(inceAr); JScrollPane sp2=new JScrollPane(inced); inceAr.setLineWrap(true); inceAr.setEditable(false); inced.setLineWrap(true); inced.setEditable(false); center.add(sp); center.add(sp2); add(center,BorderLayout.CENTER); pack(); /JFrame inherited from Window validate(); setVisible(true); setDefaultCloseOperation(EXIT_ON_CLOSE); try socket=new MulticastSocket(port); group=InetAddress.getByName(); socket.joinGroup(group); packet=new DatagramPacket(buf,buf.length); catch (IOException e) / TODO Auto-generated catch block e.printStackTrace(); Override public void run() while(true) try socket.receive(packet); /socket接收数据包 catch (IOException e) / TODO Auto-generated catch block e.printStackTrace(); String message=new String(packet.getData(),0,packet.getLength();/取出数据包中的内容 / System.out.println(message.length(); inceAr.setText(正在接受的内容： n+message); inced.append(message+n); if(b=true) break; /自定义按钮点击事件 public void actionPerformed(ActionEvent e) Object object=e.getSource(); if(object=ince) /If this thread is already on the state run, do nothing. if(!thread.isAlive() thread=new Thread(this); thread.start(); ince.setBackground(Color.red); stop.setBackground(Color.yellow); b=false; if(object=stop) ince.setBackgroun