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 18:50:38 +02:00
parent dd1c5d2227
commit 15422faf8b
1 changed files with 27 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -25,15 +25,15 @@ public class Client {
System.out.println("Recieved!");
InetAddress senderAddress = packetIn.getAddress();
int senderPort = packetIn.getPort();
String senderHost = senderAddress.getHostAddress();
SocketAddress senderSocketAddress = packetIn.getSocketAddress();
String syslogMessage = formatSyslogMessage(message);
byte[] buffer2 = syslogMessage.getBytes();
System.out.println("Sender Adress " + senderAddress);
System.out.println("Sender Port: "+ senderPort);
System.out.println("Sender IP: " + senderHost);
System.out.println("Sender socket address: " + senderSocketAddress);
DatagramPacket packet = new DatagramPacket(
buffer2,
buffer2.length,
packetIn.getAddress(),
514
);
System.out.println("Received from IP: " + senderHost);
// System.out.println("Received from IP: " + packetIn.getSocketAddress());
@ -42,4 +42,23 @@ public class Client {
e.printStackTrace();
}
}
private static String formatSyslogMessage(String message) {
// Basic RFC 5424 format without structured data
// <PRI>TIMESTAMP HOSTNAME APPNAME PID MESSAGEID [STRUCTURED-DATA] MSG
// Since you ignore structured data, we skip that part
int facility = 16; // local0
int severity = 6; // informational
int pri = (facility * 8) + severity;
String timestamp = java.time.Instant.now().toString();
String hostname = "test-client";
String appName = "SyslogTest";
String procId = "12345";
String msgId = "TEST001";
return String.format("<%d>1 %s %s %s %s %s - %s",
pri, timestamp, hostname, appName, procId, msgId, message);
}
}