2123000
/
VS
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fertig

master
Dara Soun 2024-04-12 12:44:15 +02:00
parent 16221f3c29
commit 7d91bb4d3c
2 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Service-Discovery/src/de/hs_mannheim/ffi/vs/syslog/model/SyslogClient.java
View File

@ -3,16 +3,17 @@ package de.hs_mannheim.ffi.vs.syslog.model;
import java.io.IOException; import java.io.IOException;
import java.net.*; import java.net.*;
import de.hs_mannheim.ffi.vs.syslog.model.SyslogMessage.Message;
public class SyslogClient { public class SyslogClient {
private static final int SYSLOG_PORT = 514; private static final int SYSLOG_PORT = 514;
private static final int DISCOVERY_PORT = 8888; private static final int DISCOVERY_PORT = 8888;
private static final int TIMEOUT = 2000;
public static void main(String[] args) throws SocketException { public static void main(String[] args) throws SocketException {
String message = "Test message from SyslogClient"; String message = "Test Test Test";
try { try {
sendToSyslogPort(message); sendToSyslogPort(message);
@ -29,7 +30,10 @@ public class SyslogClient {
InetAddress serverAddress = InetAddress.getLocalHost(); InetAddress serverAddress = InetAddress.getLocalHost();
DatagramPacket packet = new DatagramPacket(message.getBytes(), message.getBytes().length, serverAddress, DatagramPacket packet = new DatagramPacket(message.getBytes(), message.getBytes().length, serverAddress,
SYSLOG_PORT); SYSLOG_PORT);
// Warten auf die Antwort vom Server
socket.send(packet); socket.send(packet);
System.out.println("Nachricht zurückerhalten von " + packet.getAddress());
socket.close(); socket.close();
} }
@ -45,7 +49,7 @@ public class SyslogClient {
byte[] responseBuffer = new byte[1024]; byte[] responseBuffer = new byte[1024];
DatagramPacket responsePacket = new DatagramPacket(responseBuffer, responseBuffer.length); DatagramPacket responsePacket = new DatagramPacket(responseBuffer, responseBuffer.length);
socket.receive(responsePacket); socket.receive(responsePacket);
System.out.println("Received response from SyslogServer: " + responsePacket.getAddress()); System.out.println("Nachricht zurückerhalten von " + responsePacket.getAddress() + " Portnummer " + responsePacket.getPort());
socket.close(); socket.close();
} }

7
Service-Discovery/src/de/hs_mannheim/ffi/vs/syslog/model/SyslogServer.java
View File

@ -6,7 +6,7 @@ import java.net.DatagramSocket;
public class SyslogServer { public class SyslogServer {
private static final int SYSLOG_PORT = 514; private static final int SYSLOG_PORT = 514;
private static final int DISCOVERY_PORT = 8888; private static final int DISCOVERY_PORT = 8888;
private static final int MAX_MESSAGE_LENGTH = 1024; private static final int MAX_MESSAGE_LENGTH = 512;
public void startServer() { public void startServer() {
try{ try{
@ -27,13 +27,13 @@ public class SyslogServer {
processDiscovery(discoveryPacket); processDiscovery(discoveryPacket);
} }
} catch (IOException e) { } catch (IOException e) {
System.err.println(e); e.printStackTrace();
} }
} }
private void processMessage(DatagramPacket packet) { private void processMessage(DatagramPacket packet) {
System.out.println("Message received from " + packet.getAddress() + ": " + new String(packet.getData()).trim()); System.out.println("Nachricht bekommen von " + packet.getAddress() + ": " + new String(packet.getData(), 0, packet.getLength()));
} }
private void processDiscovery(DatagramPacket packet) { private void processDiscovery(DatagramPacket packet) {
@ -49,7 +49,6 @@ public class SyslogServer {
} }
} }
//Bind nicht verwenden
public static void main(String[] args) { public static void main(String[] args) {
SyslogServer server = new SyslogServer(); SyslogServer server = new SyslogServer();