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 = 36041; 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]; System.out.println("Geben Sie eine Nachricht ein: "); String sentence = inFromUser.readLine(); sendData = sentence.getBytes(); DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, udpPort); mcastSocket.send(sendPacket); mcastSocket.leaveGroup(IPAddress); mcastSocket.close(); } }