libjava/classpath/test/java.net/MulticastServer.java

   1 /* Mulitcast Server Socket for testing */
   2
   3 import java.io.*;
   4 import java.net.*;
   5
   6 public class MulticastServer
   7 {
   8
   9 private MulticastSocket s;
  10
  11 public static void
  12 main(String[] argv) throws IOException
  13 {
  14   MulticastServer ms = new MulticastServer(3333);
  15   ms.run();
  16 }
  17
  18 public
  19 MulticastServer(int port) throws IOException
  20 {
  21   s = new MulticastSocket(port);
  22   System.out.println("Server multicast socket created");
  23 }
  24
  25 public void
  26 run()
  27 {
  28   try
  29     {
  30       byte[] buf = new byte[255];
  31
  32       DatagramPacket p = new DatagramPacket(buf, buf.length);
  33       InetAddress addr = InetAddress.getByName("234.0.0.1");
  34
  35       p.setLength(buf.length);
  36
  37       System.out.println("Joining multicast group");
  38       s.joinGroup(addr);
  39       System.out.print("Receiving ...");
  40       s.receive(p);
  41       System.out.println("");
  42       s.leaveGroup(addr);
  43       System.out.println("ServerDatagram: received " + p.getLength() +
  44          " bytes from " + p.getAddress().getHostName() + ":" +
  45          p.getPort());
  46       System.out.println("Data: " + new String(p.getData()));
  47
  48       System.out.println("PASSED multicast server test");
  49     }
  50   catch (IOException e)
  51     {
  52       System.out.println("FAILED: MulticastServer caught an exception: " + e);
  53     }
  54 }
  55
  56 }
  57