From 708b7baa9a309f9734a60139fa527ed77ac8ca53 Mon Sep 17 00:00:00 2001 From: 3013050 <3013050@stud.hs-mannheim.de> Date: Tue, 21 Oct 2025 19:06:54 +0200 Subject: [PATCH] w --- vs.pu01/src/main/java/vs/Client.java | 3 ++- vs.pu01/src/main/java/vs/DiscoveryServer.java | 18 +++++++++++------- vs.pu01/src/main/java/vs/SyslogUdpServer.java | 1 + 3 files changed, 14 insertions(+), 8 deletions(-) diff --git a/vs.pu01/src/main/java/vs/Client.java b/vs.pu01/src/main/java/vs/Client.java index 0dd5734..bff6234 100644 --- a/vs.pu01/src/main/java/vs/Client.java +++ b/vs.pu01/src/main/java/vs/Client.java @@ -20,10 +20,11 @@ public class Client { socket.send(packetOut); + //? Got server IP DatagramPacket packetIn = new DatagramPacket(new byte[512], 512); socket.receive(packetIn); - System.out.println("Recieved!"); + System.out.println("Recieved from " + packetIn.getSocketAddress()); String syslogMessage = formatSyslogMessage(message); byte[] buffer2 = syslogMessage.getBytes(); diff --git a/vs.pu01/src/main/java/vs/DiscoveryServer.java b/vs.pu01/src/main/java/vs/DiscoveryServer.java index 2a0bcce..b44aad4 100644 --- a/vs.pu01/src/main/java/vs/DiscoveryServer.java +++ b/vs.pu01/src/main/java/vs/DiscoveryServer.java @@ -21,18 +21,22 @@ public class DiscoveryServer implements Runnable { discoverySocket.setReuseAddress(true); discoverySocket.setBroadcast(true); - byte[] buffer = new byte[256]; while (true) { - DatagramPacket packet = new DatagramPacket(buffer, buffer.length); - discoverySocket.receive(packet); + byte[] buffer = new byte[256]; + DatagramPacket packetIn = new DatagramPacket(buffer, buffer.length); + discoverySocket.receive(packetIn); InetAddress clientAddress = packet.getAddress(); - int clientPort = packet.getPort(); + int clientPort = packetIn.getPort(); System.out.println("DISCOVERY from " + clientAddress.getHostAddress() + ":" + clientPort); - byte[] reply = new byte[0]; // leere Antwort - DatagramPacket response = new DatagramPacket(reply, reply.length, clientAddress, clientPort); - discoverySocket.send(response); + + DatagramPacket packetOut = new DatagramPacket(new byte[256], 256); + packetOut.setSocketAddress(packetIn.getSocketAddress()); + packetOut.setData(new byte[0]); + packetOut.setLength(0); + + discoverySocket.send(packetOut); } } catch (Exception e) { e.printStackTrace(); diff --git a/vs.pu01/src/main/java/vs/SyslogUdpServer.java b/vs.pu01/src/main/java/vs/SyslogUdpServer.java index 9b67dae..9f81da7 100644 --- a/vs.pu01/src/main/java/vs/SyslogUdpServer.java +++ b/vs.pu01/src/main/java/vs/SyslogUdpServer.java @@ -26,6 +26,7 @@ public class SyslogUdpServer implements Runnable { while (true) { DatagramPacket packet = new DatagramPacket(buffer, buffer.length); syslogSocket.receive(packet); // UDP-Paket empfangen + System.out.println("SYSLOG from " + packet.getSocketAddress()); int len = packet.getLength(); InetAddress clientAddress = packet.getAddress();