import java.io.*;
import java.net.*;
class multSocketServer {
  public static void main(String[] args) throws IOException {
    System.out.println("啟動服務(wù)器...\n");
    //創(chuàng)建一個不綁定到任何端口上的多播組套接字
    //由于MulticastSocket是DatagramSocket的子類,故也可以用DatagramSocket類來代替。		
    MulticastSocket ms = new MulticastSocket();
    InetAddress group = InetAddress.getByName("224.0.0.1");
    //創(chuàng)建字節(jié)數(shù)組
    byte[] buf1 = new byte[0];
    DatagramPacket dgp = new DatagramPacket(buf1, 0, group, 12345);
    // 發(fā)送3000個字符串到這個端口
    for (int i = 0; i < 30000; i++) {
      byte[] buf2 = ("String line " + i).getBytes();      
      dgp.setData(buf2);//設(shè)置數(shù)據(jù)包內(nèi)容      
      dgp.setLength(buf2.length); //設(shè)置數(shù)據(jù)包的緩沖長度     
      ms.send(dgp);//將數(shù)據(jù)包發(fā)送到整個多播組上
    }    
    ms.close();//關(guān)閉套接字
  }
}