verteilte-systeme-bsc-ai-examples/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPServer.java

/* Angelehnt an Kurose/Ross Computernetzwerke (bis 5e Java, ab 6e Python) */

package verteiltesysteme.socket.simple;

import java.io.*;
import java.net.*;

class TCPServer {
	public static void main(String argv[]) throws Exception {
		int tcpPort = 36037;
		String clientSentence;
		String capitalizedSentence;

		// Server-Socket erzeugen
		@SuppressWarnings("resource")
		ServerSocket welcomeSocket = new ServerSocket(tcpPort);
		
		System.out.println("TCP Server started. Waiting for incoming requests...");
		
		while (true) {
			Socket connectionSocket = welcomeSocket.accept();

			System.out.println("Received request from client " + connectionSocket.getInetAddress() + ":" + connectionSocket.getPort() + " generating response...");
			
			BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
			DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());

			// Try/Catch hinzugef�gt, nachdem bei Einsatz Amazon AWS (Healthcheck des ELB) clientSentence null war  
			try {
				clientSentence = inFromClient.readLine();
				if (clientSentence != null) {
					capitalizedSentence = clientSentence.toUpperCase() + '\n';
					outToClient.writeBytes(capitalizedSentence);
				}
			} catch (IOException ioe) {
				ioe.printStackTrace();
			}
			connectionSocket.close();
		}
	}
}