|
Home ► Lab Exercise ► Network Lab Exercise Programs► Java Multicasting Program▼
Java Multicasting Program: |
/*** SimpleMulticastSource.java ***/
import java.io.*;
import java.net.*;
public class SimpleMulticastSource
{
public static void main(String[] args)
{
try
{
DatagramSocket s = new DatagramSocket(); // Create socket
byte[] line = new byte[100];
System.out.print("Enter text to send: ");
int len = System.in.read(line);
InetAddress dest = InetAddress.getByName("224.0.0.1");
DatagramPacket pkt = new DatagramPacket(line, len, dest, 16900);
s.send(pkt);
s.close();
}
catch (Exception err)
{
System.err.println(err);
}
}
}
*** SimpleMulticastDestination.java ***/
import java.io.*;
import java.net.*;
public class SimpleMulticastDestination
{
public static void main(String[] args)
{
try
{
MulticastSocket ms = new MulticastSocket(16900); // Create socket
ms.joinGroup(InetAddress.getByName("224.0.0.1"));
String msg;
do
{
byte[] line = new byte[100];
DatagramPacket pkt = new DatagramPacket(line, line.length);
ms.receive(pkt);
msg = new String(pkt.getData());
System.out.println("From "+pkt.getAddress()+":"+msg.trim());
}
while ( !msg.trim().equals("close") );
ms.close(); // Close connection
}
catch (Exception err)
{
System.err.println(err);
}
}
}
SAMPLE INPUT OUTPUT:
Enter text to send: HAI
Press any key to continue . . .
|
|
|