Browse Source

initial multicastsocket example

master
Sebastian Rieger 6 years ago
parent
commit
a39f87ab00
  1. 25
      VerteilteSysteme-Examples/src/verteiltesysteme/socket/multicast/UDPMulticastConsumer.java
  2. 27
      VerteilteSysteme-Examples/src/verteiltesysteme/socket/multicast/UDPMulticastProducer.java

25
VerteilteSysteme-Examples/src/verteiltesysteme/socket/multicast/UDPMulticastConsumer.java

@ -0,0 +1,25 @@
/* Angelehnt an Kurose/Ross Computernetzwerke (bis 5e Java, ab 6e Python) */
package verteiltesysteme.socket.multicast;
import java.net.*;
class UDPMulticastConsumer {
public static void main(String args[]) throws Exception {
String groupname = "224.1.1.1";
int udpPort = 36040;
@SuppressWarnings("resource")
MulticastSocket mcastSocket = new MulticastSocket(udpPort);
InetAddress IPAddress = InetAddress.getByName(groupname);
mcastSocket.joinGroup(IPAddress);
byte[] receiveData = new byte[1024];
while (true) {
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
mcastSocket.receive(receivePacket);
String sentence = new String(receivePacket.getData(), 0, receivePacket.getLength());
System.out.println(sentence);
}
}
}

27
VerteilteSysteme-Examples/src/verteiltesysteme/socket/multicast/UDPMulticastProducer.java

@ -0,0 +1,27 @@
/* Angelehnt an Kurose/Ross Computernetzwerke (bis 5e Java, ab 6e Python) */
package verteiltesysteme.socket.multicast;
import java.io.*;
import java.net.*;
class UDPMulticastProducer {
public static void main(String args[]) throws Exception {
String groupname = "224.1.1.1";
int udpPort = 36040;
BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));
MulticastSocket mcastSocket = new MulticastSocket(udpPort);
InetAddress IPAddress = InetAddress.getByName(groupname);
mcastSocket.joinGroup(IPAddress);
byte[] sendData = new byte[1024];
String sentence = inFromUser.readLine();
sendData = sentence.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, udpPort);
mcastSocket.send(sendPacket);
mcastSocket.leaveGroup(IPAddress);
mcastSocket.close();
}
}
Loading…
Cancel
Save