import java.net.*; import java.io.*; public class FinalServer { public static void main(String[] args) throws Exception { //Open server socket (Start listening). int portToListenOn = 8901; ServerSocket listenSocket = new ServerSocket(portToListenOn); //Wait for connection. Socket connection = listenSocket.accept(); //Open I/O streams to socket. PrintWriter os = new PrintWriter(connection.getOutputStream(), true); //when we write to out, we send things out BufferedReader is = new BufferedReader(new InputStreamReader(connection.getInputStream())); //when we read from in, we get messages from the server //Read and write to socket. int messageCount = 0; while(true) { System.out.println("MessageCount: " + messageCount); String inMessage = is.readLine(); if (inMessage != null) { System.out.println("From client: " + inMessage); String replyMessage = "Received message"; os.println(replyMessage); System.out.println("To client:" + replyMessage); messageCount++; } if (messageCount > 10) { break; } } //Clean up. is.close(); os.close(); connection.close(); listenSocket.close(); } }