From c467a3e9bb9f0b5e366fc4034953f39ddccef801 Mon Sep 17 00:00:00 2001 From: 3013050 <3013050@stud.hs-mannheim.de> Date: Tue, 21 Oct 2025 19:15:35 +0200 Subject: [PATCH] w --- vs.pu01/src/main/java/vs/Client.java | 10 ++++++---- vs.pu01/src/main/java/vs/DiscoveryServer.java | 1 + vs.pu01/src/main/java/vs/Main.java | 2 +- vs.pu01/src/main/java/vs/SyslogUdpServer.java | 1 + 4 files changed, 9 insertions(+), 5 deletions(-) diff --git a/vs.pu01/src/main/java/vs/Client.java b/vs.pu01/src/main/java/vs/Client.java index 8d6c244..157c8e2 100644 --- a/vs.pu01/src/main/java/vs/Client.java +++ b/vs.pu01/src/main/java/vs/Client.java @@ -7,6 +7,7 @@ import java.net.InetAddress; import java.net.SocketAddress; public class Client { + private static final int BUFSIZE = 512; public static void main(String[] args) { try (DatagramSocket socket = new DatagramSocket()) { socket.setBroadcast(true); @@ -16,21 +17,22 @@ public class Client { byte[] buffer = message.getBytes(); InetAddress broadcastAddress = InetAddress.getByName("255.255.255.255"); - int port = 8888; + int discoveryPort = 8888; - DatagramPacket packetOutDisover = new DatagramPacket(buffer, buffer.length, broadcastAddress, port); + DatagramPacket packetOutDisover = new DatagramPacket(buffer, buffer.length, broadcastAddress, discoveryPort); socket.send(packetOutDisover); //? Got server IP - DatagramPacket packetIn = new DatagramPacket(new byte[512], 512); + DatagramPacket packetIn = new DatagramPacket(new byte[BUFSIZE], BUFSIZE); socket.receive(packetIn); System.out.println("Recieved from " + packetIn.getSocketAddress()); DatagramPacket packetOutSyslog = new DatagramPacket(new byte[BUFSIZE], BUFSIZE); packetOutSyslog.setAddress(packetIn.getAddress()); - packetOutSyslog.setPort(514); + int syslogPort = 514; + packetOutSyslog.setPort(syslogPort); String syslogMessage = formatSyslogMessage(message); byte[] syslogMessageBytes = syslogMessage.getBytes(); diff --git a/vs.pu01/src/main/java/vs/DiscoveryServer.java b/vs.pu01/src/main/java/vs/DiscoveryServer.java index e852ede..ad46f14 100644 --- a/vs.pu01/src/main/java/vs/DiscoveryServer.java +++ b/vs.pu01/src/main/java/vs/DiscoveryServer.java @@ -17,6 +17,7 @@ public class DiscoveryServer implements Runnable { @Override public void run() { + System.out.println("Discovery running on " + port); try (DatagramSocket discoverySocket = new DatagramSocket(port)) { discoverySocket.setReuseAddress(true); discoverySocket.setBroadcast(true); diff --git a/vs.pu01/src/main/java/vs/Main.java b/vs.pu01/src/main/java/vs/Main.java index 00ba340..8de1c37 100644 --- a/vs.pu01/src/main/java/vs/Main.java +++ b/vs.pu01/src/main/java/vs/Main.java @@ -8,7 +8,7 @@ public class Main { private static final int DISCOVERY_PORT = 8888; // Port für Auto-Discovery public static void main(String[] args) { - System.out.println("Syslog server is running on UDP/514 and discovery on UDP/8888..."); + // System.out.println("Syslog server is running on UDP/514 and discovery on UDP/8888..."); // Thread 1: Empfängt Syslog-Nachrichten und druckt Sender-IP + Nachricht new Thread(new SyslogUdpServer(SYSLOG_PORT), "syslog").start(); // Thread 2: Beantwortet Broadcast-Anfragen und verrät so die Server-IP diff --git a/vs.pu01/src/main/java/vs/SyslogUdpServer.java b/vs.pu01/src/main/java/vs/SyslogUdpServer.java index 9f81da7..df74918 100644 --- a/vs.pu01/src/main/java/vs/SyslogUdpServer.java +++ b/vs.pu01/src/main/java/vs/SyslogUdpServer.java @@ -19,6 +19,7 @@ public class SyslogUdpServer implements Runnable { @Override public void run() { + System.out.println("Syslog running on " + port); // Socket öffnen und auf allen Interfaces an Port 514 lauschen try (DatagramSocket syslogSocket = new DatagramSocket(port)) { syslogSocket.setReuseAddress(true); // erlaubt schnelles Neu-Starten