From 0c9d694eb348bcae007021762de46810b7a187c0 Mon Sep 17 00:00:00 2001 From: Sebastian Rieger Date: Sun, 21 Oct 2018 15:33:12 +0200 Subject: [PATCH] status messages --- .../src/verteiltesysteme/socket/simple/TCPClient.java | 2 ++ .../src/verteiltesysteme/socket/simple/TCPServer.java | 4 ++++ .../src/verteiltesysteme/socket/simple/UDPClient.java | 2 ++ .../src/verteiltesysteme/socket/simple/UDPServer.java | 5 ++++- 4 files changed, 12 insertions(+), 1 deletion(-) diff --git a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPClient.java b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPClient.java index 21e7997..24b27d3 100644 --- a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPClient.java +++ b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPClient.java @@ -18,6 +18,8 @@ class TCPClient { DataOutputStream outToServer = new DataOutputStream(clientSocket.getOutputStream()); BufferedReader inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); + System.out.println("Enter message to sent to the server:"); + sentence = inFromUser.readLine(); outToServer.writeBytes(sentence + '\n'); modifiedSentence = inFromServer.readLine(); diff --git a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPServer.java b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPServer.java index 63ccbc1..dc3c858 100644 --- a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPServer.java +++ b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/TCPServer.java @@ -15,9 +15,13 @@ class TCPServer { @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()); diff --git a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPClient.java b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPClient.java index ef609dd..565c5bb 100644 --- a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPClient.java +++ b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPClient.java @@ -15,6 +15,8 @@ class UDPClient { byte[] sendData = new byte[1024]; byte[] receiveData = new byte[1024]; + System.out.println("Enter message to sent to the server:"); + String sentence = inFromUser.readLine(); sendData = sentence.getBytes(); diff --git a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPServer.java b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPServer.java index 1be8961..4b6f033 100644 --- a/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPServer.java +++ b/VerteilteSysteme-Examples/src/verteiltesysteme/socket/simple/UDPServer.java @@ -12,6 +12,8 @@ class UDPServer { byte[] receiveData = new byte[1024]; byte[] sendData = new byte[1024]; + System.out.println("UDP Server started. Waiting for incoming requests..."); + while (true) { DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); serverSocket.receive(receivePacket); @@ -19,8 +21,9 @@ class UDPServer { InetAddress IPAddress = receivePacket.getAddress(); int clientSrcPort = receivePacket.getPort(); - + System.out.println("Received request from client " + IPAddress + ":" + clientSrcPort + " generating response..."); + String capitalizedSentence = sentence.toUpperCase(); sendData = capitalizedSentence.getBytes(); DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, clientSrcPort);