都是从网上搜取的资料，经过自己整合，测试成功。

使用java 的UDP进行广播，要分两步走，首先要加入到广播组地址，其次要建立套接字传输信息

关于广播，涉及到MulticastSocket，他用于接收广播的信息，前提是要将它加入到广播组，组播的地址是保留的D类地址从224.0.0.0—239.255.255.255，而且一些地址有特定的用处如，224.0.0.0—244.0.0.255只能用于局域网中路由器是不会转发的，并且224.0.0.1是所有主机的地址，224.0.0.2所有路由器的地址，224.0.0.5所有ospf路由器的地址，224.0.13事PIMv2路由器的地址；239.0.0.0—239.255.255.255是私有地址（如192.168.x..x）；224.0.1.0—238.255.255.255可以用与Internet上的。这里我们就选取230.0.0.1作为我们的广播地址。

此软件类似于飞鸽，用于局域网通信，每个客户端上线都要寻找局域网其他主机并把自己的信息和所有主机交换，以此模式更新。。。

class lanSend {

 /**
  * @param args
  * @throws Exception 
  */
    
 //广播地址
 private static final String BROADCAST_IP = "230.0.0.1";//广播IP
    private static final int BROADCAST_INT_PORT = 40005;   // 不同的port对应不同的socket发送端和接收端

    MulticastSocket broadSocket ;//用于接收广播信息

    InetAddress broadAddress ;//广播地址

     DatagramSocket sender ;//数据流套接字 相当于码头，用于发送信息
 public lanSend() {
  try {

  //初始化
   broadSocket=new MulticastSocket(BROADCAST_INT_PORT); 
   broadAddress = InetAddress.getByName(BROADCAST_IP);
   sender = new DatagramSocket();
  } catch (Exception e) {
   // TODO: handle exception
   System.out.println("*****lanSend初始化失败*****"+e.toString());
  }
 }
 
 void join() { 
  try{
   broadSocket.joinGroup(broadAddress); //加入到组播地址，这样就能接收到组播信息
   new Thread(new GetPacket()).start(); //新建一个线程，用于循环侦听端口信息
  }catch (Exception e) {
   // TODO: handle exception
   System.out.println("*****加入组播失败*****");
  }
  
 }

 //广播发送查找在线用户
 void sendGetUserMsg() {
        byte[] b=new byte[1024];
        DatagramPacket packet;  //数据包，相当于集装箱，封装信息
        try{
         b = ("find@"+lanDemo.msg).getBytes();  
         packet = new DatagramPacket(b, b.length, broadAddress, BROADCAST_INT_PORT); //广播信息到指定端口
         sender.send(packet);
         System.out.println("*****已发送请求*****");       
        }catch (Exception e) {
   System.out.println("*****查找出错*****");
  }
    }

 //当局域网内的在线机子收到广播信息时响应并向发送广播的ip地址主机发送返还信息，达到交换信息的目的
 void returnUserMsg(String ip){
  byte[] b=new byte[1024];
  DatagramPacket packet;
  try {
   b=("retn@"+lanDemo.msg).getBytes();
   packet = new DatagramPacket(b,b.length,InetAddress.getByName(ip),BROADCAST_INT_PORT);
   sender.send(packet);
   System.out.print("发送信息成功！");
  } catch (Exception e) {
   // TODO: handle exception
   System.out.println("*****发送返还信息失败*****");
  }
 }

 //当局域网某机子下线是需要广播发送下线通知
 void offLine(){
  byte[] b=new byte[1024];
  DatagramPacket packet;
  try {
   b=("offl@"+lanDemo.msg).getBytes();
   packet = new DatagramPacket(b,b.length,broadAddress,BROADCAST_INT_PORT);
   sender.send(packet);
   System.out.println("*****已离线*****");
  } catch (Exception e) {
   // TODO: handle exception
   System.out.println("*****离线异常*****");
  }
 }
  
 class GetPacket implements Runnable {  //新建的线程，用于侦听
  public void run() {
      DatagramPacket inPacket;
      
   String[] message;
   while(true){
    try {
     inPacket=new DatagramPacket(new byte[1024], 1024);
          broadSocket.receive(inPacket);     //接收广播信息并将信息封装到inPacket中
           message=new String(inPacket.getData(),0,inPacket.getLength()).split("@");  //获取信息，并切割头部，判断是何种信息（find--上线，retn--回答，offl--下线）
         

     if(message[1].equals(lanDemo.ip))continue;  //忽略自身
     if(message[0].equals("find")){   //如果是请求信息
      System.out.println("新上线主机："+" ip："+message[1]+" 主机："+message[2]);
      returnUserMsg(message[1]);
     }
     else if(message[0].equals("retn")){    //如果是返回信息
      System.out.println("找到新主机："+" ip："+message[1]+" 主机："+message[2]);
     }
     else if(message[0].equals("offl")){    //如果是离线信息
      System.out.println("主机下线："+" ip："+message[1]+" 主机："+message[2]);
     }
    
      } catch (Exception e) {
     // TODO: handle exception
     System.out.println("线程出错 "+e);
    }
   }
  }
 }
}

public class lanDemo{  

//全局变量

 public static String msg;   

 public static String ip;
 public static String hostName;
 public static void main(String[] args){   //程序入口点
    lanSend lSend;
  try {
   InetAddress addr = InetAddress.getLocalHost();
   ip=addr.getHostAddress().toString();
   hostName = addr.getHostName().toString();
    msg= ip+"@"+hostName;
    lSend=new lanSend();
    lSend.join();     //加入组播，并创建线程侦听
    lSend.sendGetUserMsg();    //广播信息，寻找上线主机交换信息
    Thread.sleep(3000);  //程序睡眠3秒
    lSend.offLine(); //广播下线通知
  } catch (Exception e) {
   System.out.println("*****获取本地用户信息出错*****");
  }
 }
 
}

至此就基本完成了 上线，下线，广播功能，只是个demo，仅供参考。

转自：http://blog.csdn.net/killtl/article/details/7296244

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package client;

/**
 *
 * @author Administrator
 */
import java.net.*;
import java.awt.*; 
import java.awt.event.*;

public class Receive extends Frame implements Runnable,ActionListener
{ 
  int port;                                        
  InetAddress group=null;                          
  MulticastSocket socket=null;                     
  Button 开始接收,停止接收;   
  TextArea 显示正在接收内容,显示已接收的内容;  
  Thread thread;                                   
  boolean 停止=false;
  public Receive()
   { 
     super("定时接收信息");
     thread=new Thread(this);
     开始接收=new Button("开始接收");
     停止接收=new Button("停止接收");
     停止接收.addActionListener(this); 
     开始接收.addActionListener(this); 
     显示正在接收内容=new TextArea(10,10);
     显示正在接收内容.setForeground(Color.blue); 
     显示已接收的内容=new TextArea(10,10);
     Panel north=new Panel();
     north.add(开始接收);
     north.add(停止接收);
     add(north,BorderLayout.NORTH);
     Panel center=new Panel();
     center.setLayout(new GridLayout(1,2)); 
     center.add(显示正在接收内容);
     center.add(显示已接收的内容);
     add(center,BorderLayout.CENTER);
     validate();
     port=5000;                                       
     try{
         group=InetAddress.getByName("239.255.0.0");  
         socket=new MulticastSocket(port);            
         socket.joinGroup(group);           
                                            
       }
    catch(Exception e)
       {
       } 
   setBounds(100,50,360,380);   
   setVisible(true);
   addWindowListener(new WindowAdapter()
                     { public void windowClosing(WindowEvent e)
                       { System.exit(0);
      	               }
      	             });
                            
   }
  public void actionPerformed(ActionEvent e)
   {
    if(e.getSource()==开始接收)
      {
        开始接收.setBackground(Color.blue);
        停止接收.setBackground(Color.gray);
        if(!(thread.isAlive()))
           {
             thread=new Thread(this);
           }
        try
           {
             thread.start(); 
             停止=false;        
           }
        catch(Exception ee)
           {
           }
      }
    if(e.getSource()==停止接收)
      {
        开始接收.setBackground(Color.gray);
        停止接收.setBackground(Color.blue);
        thread.interrupt(); 
        停止=true; 
      }
   }

  public void run()
  {
   
    while(true)   
    {  
       byte data[]=new byte[8192];
       DatagramPacket packet=null;
       packet=new DatagramPacket(data,data.length,group,port);  
       try
           {  
             socket.receive(packet);
             String message=new String(packet.getData(),0,packet.getLength());
             显示正在接收内容.setText("正在接收的内容:\n"+message);
             显示已接收的内容.append(message+"\n");
           }
      catch(Exception e)
           {
           }
      if(停止==true)
           {
             break;
           } 
    } 
  }
 
 public static void main(String args[])
 { 
    new Receive();
 }
} 

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package server;

/**
 *
 * @author Administrator
 */
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.Timer;
 
public class BroadCastWord extends Frame implements ActionListener
{   
   int port;                                        
   InetAddress group=null;                          
   MulticastSocket socket=null;                     
   Timer time=null;                                 
   FileDialog open=null;                            
   Button select,开始广播,停止广播;
   File file=null;                                  
   String FileDir=null,fileName=null;
   FileReader in=null;                              
   BufferedReader bufferIn=null;
   int   token=0;                                   
   TextArea 显示正在播放内容,显示已播放的内容;       
  public BroadCastWord()
  {
   super("单词广播系统");
   select=new Button("选择要广播的文件");
   开始广播=new Button("开始广播");
   开始广播.setEnabled(false);
   停止广播=new Button("停止广播");
   select.addActionListener(this); 
   开始广播.addActionListener(this); 
   停止广播.addActionListener(this); 
   time=new Timer(2000,this);                       
   open=new FileDialog(this,"选择要广播的文件",FileDialog.LOAD);  
   显示正在播放内容=new TextArea(10,10);
   显示正在播放内容.setForeground(Color.blue); 
   显示已播放的内容=new TextArea(10,10);
   Panel north=new Panel();
   north.add(select);
   north.add(开始广播);
   north.add(停止广播);
   add(north,BorderLayout.NORTH);
   Panel center=new Panel();
   center.setLayout(new GridLayout(1,2)); 
   center.add(显示正在播放内容);
   center.add(显示已播放的内容);
   add(center,BorderLayout.CENTER);
   validate();
   try 
      {
       port=5000;                                   
       group=InetAddress.getByName("239.255.0.0");  
       socket=new MulticastSocket(port);            
       socket.setTimeToLive(1);                     
       socket.joinGroup(group);                     
                                                   
      } 
  catch(Exception e)
       {
         System.out.println("Error: "+ e);          
       }
  setBounds(100,50,360,380);   
  setVisible(true);
  addWindowListener(new WindowAdapter()
                     { public void windowClosing(WindowEvent e)
                       { System.exit(0);
      	               }
      	             });
 }
 public void actionPerformed(ActionEvent e)
 {
   if(e.getSource()==select)
     {
      显示已播放的内容.setText(null);
      open.setVisible(true);
      fileName=open.getFile();
      FileDir=open.getDirectory(); 
      if(fileName!=null)
       { 
         time.stop();                                                
         file=new File(FileDir,fileName);
         try
            {
               file=new File(FileDir,fileName);
               in=new FileReader(file);                      
               bufferIn=new BufferedReader(in);
               开始广播.setEnabled(true);  
            }
         catch(IOException ee)
            {
            }
       }
     }
   else if(e.getSource()==开始广播)
     {
        time.start();
     }
   else if(e.getSource()==time)
     {
       String s=null;
        try
            {  
              if(token==-1)
                 {
                   file=new File(FileDir,fileName);
                   in=new FileReader(file);                      
                   bufferIn=new BufferedReader(in);
                 }
              s=bufferIn.readLine();
              if(s!=null)
                {
                  token=0;
                  显示正在播放内容.setText("正在广播的内容:\n"+s);
                  显示已播放的内容.append(s+"\n");
                  DatagramPacket packet=null;                               
                  byte data[]=s.getBytes(); 
                  packet=new DatagramPacket(data,data.length,group,port); 
                  socket.send(packet);                                      
                }
              else
                {
                  token=-1;
                }
            }
        catch(IOException ee)
            {
            }
     }
   else if(e.getSource()==停止广播)
     {
       time.stop();
     }
 }
                                         
 public static void main(String[] args) 
   {
      BroadCastWord broad=new BroadCastWord();
   }
}