// network/SimpleServer.java

// (c)2016 MindView LLC: see Copyright.txt

// We make no guarantees that this code is fit for any purpose.

// Visit http://OnJava8.com for more book information.

// Echoes what the client sends.

package network;

import java.io.*;

import java.net.*;

public class SimpleServer implements Runnable {

// Choose a port outside of the range 1-1024:

public static final int PORT = 8080;

public void run() {

try (

ServerSocket s = new ServerSocket(PORT);

// Blocks until a connection occurs:

Socket socket = s.accept();

BufferedReader in =

new BufferedReader(

new InputStreamReader(

socket.getInputStream()));

PrintWriter out =

new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(

// Enable auto-flush:

socket.getOutputStream())), true)

) {

System.out.println("Connection: " + socket);

in.lines().anyMatch(message->{

if (message.equals("END")) {

System.out.println("Received END. Closing Socket.");

return true;

}

System.out.println("Server Response: " + message);

out.println(message);

return false;

});

} catch (IOException e) {

throw new RuntimeException(e);

}

}

}