java使用MulticastSocket实现多点广播

import java.io.ioexception;

import java.net.datagrampacket;

import java.net.inetaddress;

import java.net.multicastsocket;

import java.util.scanner;

//让该类实现runnable接口，该类的实例可作为线程的target

public class test implements runnable {

  // 使用常量作为本程序的多点广播ip地址

  private static final string broadcast_ip = "230.0.0.1" ;

  // 使用常量作为本程序的多点广播目的的端口

  public static final int broadcast_port = 30000 ;

  // 定义每个数据报的最大大小为4k

  private static final int data_len = 4096 ;

  // 定义本程序的multicastsocket实例

  private multicastsocket socket = null ;

  private inetaddress broadcastaddress = null ;

  private scanner scan = null ;

  // 定义接收网络数据的字节数组

  byte [] inbuff = new byte [data_len];

  // 以指定字节数组创建准备接受数据的datagrampacket对象

  private datagrampacket inpacket = new datagrampacket(inbuff, inbuff.length);

  // 定义一个用于发送的datagrampacket对象

  private datagrampacket outpacket = null ;

  public void init() throws ioexception {

  try {

   // 创建用于发送、接收数据的multicastsocket对象

   // 因为该multicastsocket对象需要接收，所以有指定端口

   socket = new multicastsocket(broadcast_port);

   broadcastaddress = inetaddress.getbyname(broadcast_ip);

   // 将该socket加入指定的多点广播地址

   socket.joingroup(broadcastaddress);

   // 设置本multicastsocket发送的数据报被回送到自身

   socket.setloopbackmode( false );

   // 初始化发送用的datagramsocket，它包含一个长度为0的字节数组

   outpacket = new datagrampacket( new byte [ 0 ], 0 , broadcastaddress, broadcast_port);

   // 启动以本实例的run()方法作为线程体的线程

   new thread( this ).start();

   // 创建键盘输入流

   scan = new scanner(system.in);

   // 不断读取键盘输入

   while (scan.hasnextline()) {

   // 将键盘输入的一行字符串转换字节数组

   byte [] buff = scan.nextline().getbytes();

   // 设置发送用的datagrampacket里的字节数据

   outpacket.setdata(buff);

   // 发送数据报

   socket.send(outpacket);

   }

  } finally {

   socket.close();

  }

  }

  public void run() {

  try {

   while ( true ) {

   // 读取socket中的数据，读到的数据放在inpacket所封装的字节数组里。

   socket.receive(inpacket);

   // 打印输出从socket中读取的内容

   system.out.println( "聊天信息：" + new string(inbuff, 0 , inpacket.getlength()));

   }

  }

  // 捕捉异常

  catch (ioexception ex) {

   ex.printstacktrace();

   try {

   if (socket != null ) {

    // 让该socket离开该多点ip广播地址

    socket.leavegroup(broadcastaddress);

    // 关闭该socket对象

    socket.close();

   }

   system.exit( 1 );

   } catch (ioexception e) {

   e.printstacktrace();

   }

  }

  }

  public static void main(string[] args) throws ioexception {

  new test().init();

  }

}