From 5975895262d26b8b33d211b42461ecfa0544ff6f Mon Sep 17 00:00:00 2001
From: Sebastian Rieger <sebastian.rieger@informatik.hs-fulda.de>
Date: Wed, 8 Nov 2017 00:17:28 +0100
Subject: [PATCH] Initial multi-thread udp experiment

---
 .../socket/multithread/UDPServerMulti.java    | 48 +++++++++++++++++++
 1 file changed, 48 insertions(+)
 create mode 100644 VerteilteSysteme-Examples/src/verteiltesysteme/socket/multithread/UDPServerMulti.java

diff --git a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/multithread/UDPServerMulti.java b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/multithread/UDPServerMulti.java
new file mode 100644
index 0000000..97c7886
--- /dev/null
+++ b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/multithread/UDPServerMulti.java
@@ -0,0 +1,48 @@
+package verteiltesysteme.socket.multithread;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+
+class UDPServerMulti implements Runnable {
+	DatagramSocket serverSocket;
+	DatagramPacket receivePacket;
+	
+	UDPServerMulti(DatagramSocket serverSocket, DatagramPacket receivePacket) {
+		this.receivePacket = receivePacket;
+		this.serverSocket = serverSocket;
+	}
+
+	public static void main(String argv[]) throws Exception {
+		int udpPort = 36037;
+
+		DatagramSocket serverSocket = new DatagramSocket(udpPort);
+		byte[] receiveData = new byte[1024];
+
+		while (true) {
+			DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
+			serverSocket.receive(receivePacket);
+			// IST DAS SINNVOLL? Unter welchen Bedingungen? ;-)
+			new Thread(new UDPServerMulti(serverSocket, receivePacket)).start();
+		}
+	}
+
+	public void run() {
+		byte[] sendData = new byte[1024];
+		String sentence = new String(receivePacket.getData(), 0, receivePacket.getLength());
+
+		InetAddress IPAddress = receivePacket.getAddress();
+		int clientSrcPort = receivePacket.getPort();
+
+		String capitalizedSentence = sentence.toUpperCase();
+		sendData = capitalizedSentence.getBytes();
+		DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, clientSrcPort);
+		try {
+			serverSocket.send(sendPacket);
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+}