3013050
/
VS-LogServer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

w

main
Victor Hans-Georg Waitz 2025-10-21 19:13:32 +02:00
parent 708b7baa9a
commit 0e73a2ecf9
2 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
vs.pu01/src/main/java/vs/Client.java
View File

@ -10,15 +10,17 @@ public class Client {
public static void main(String[] args) { public static void main(String[] args) {
try (DatagramSocket socket = new DatagramSocket()) { try (DatagramSocket socket = new DatagramSocket()) {
socket.setBroadcast(true); socket.setBroadcast(true);
//? Get Server IP
String message = "DISCOVER_SERVERS"; String message = "DISCOVER_SERVERS";
byte[] buffer = message.getBytes(); byte[] buffer = message.getBytes();
InetAddress broadcastAddress = InetAddress.getByName("255.255.255.255"); InetAddress broadcastAddress = InetAddress.getByName("255.255.255.255");
int port = 8888; int port = 8888;
DatagramPacket packetOut = new DatagramPacket(buffer, buffer.length, broadcastAddress, port); DatagramPacket packetOutDisover = new DatagramPacket(buffer, buffer.length, broadcastAddress, port);
socket.send(packetOutDisover);
socket.send(packetOut);
//? Got server IP //? Got server IP
DatagramPacket packetIn = new DatagramPacket(new byte[512], 512); DatagramPacket packetIn = new DatagramPacket(new byte[512], 512);
@ -26,19 +28,18 @@ public class Client {
System.out.println("Recieved from " + packetIn.getSocketAddress()); System.out.println("Recieved from " + packetIn.getSocketAddress());
String syslogMessage = formatSyslogMessage(message); DatagramPacket packetOutSyslog = new DatagramPacket(new byte[BUFSIZE], BUFSIZE);
byte[] buffer2 = syslogMessage.getBytes(); packetOutSyslog.setAddress(packetIn.getAddress());
packetOutSyslog.setPort(514);
String syslogMessage = formatSyslogMessage(message);
byte[] syslogMessageBytes = syslogMessage.getBytes();
packetOutSyslog.setData(syslogMessageBytes);
packetOutSyslog.setLength(syslogMessageBytes.length);
DatagramPacket packet = new DatagramPacket(
buffer2,
buffer2.length,
packetIn.getAddress(),
514
);
socket.send(packet); socket.send(packet);
// System.out.println("Received from IP: " + packetIn.getSocketAddress());
} }
catch (IOException e) { catch (IOException e) {
e.printStackTrace(); e.printStackTrace();

2
vs.pu01/src/main/java/vs/DiscoveryServer.java
View File

@ -26,7 +26,7 @@ public class DiscoveryServer implements Runnable {
DatagramPacket packetIn = new DatagramPacket(buffer, buffer.length); DatagramPacket packetIn = new DatagramPacket(buffer, buffer.length);
discoverySocket.receive(packetIn); discoverySocket.receive(packetIn);
InetAddress clientAddress = packet.getAddress(); InetAddress clientAddress = packetIn.getAddress();
int clientPort = packetIn.getPort(); int clientPort = packetIn.getPort();
System.out.println("DISCOVERY from " + clientAddress.getHostAddress() + ":" + clientPort); System.out.println("DISCOVERY from " + clientAddress.getHostAddress() + ":" + clientPort);