Server.java

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) throws IOException {
        Socket socket = null;
        InputStreamReader inputStreamReader = null;
        OutputStreamWriter outputStreamWriter = null;
        BufferedReader bufferedReader = null;
        BufferedWriter bufferedWriter=null;
        ServerSocket serverSocket = null;

        serverSocket= new ServerSocket(3333);

        while(true){
            try{
                socket=serverSocket.accept();

                inputStreamReader = new InputStreamReader(socket.getInputStream());
                outputStreamWriter= new OutputStreamWriter(socket.getOutputStream());

                bufferedReader=new BufferedReader(inputStreamReader);
                bufferedWriter=new BufferedWriter(outputStreamWriter);

                while(true){
                    String msgFromClient= bufferedReader.readLine();
                    System.out.println("Client: "+msgFromClient);
                    bufferedWriter.write("Message Received!");
                    bufferedWriter.newLine();
                                    //flush the buffer so that things  don't pile up

                    bufferedWriter.flush();

                    if(msgFromClient.equalsIgnoreCase("bye"))
                        break;
                }

                socket.close();
                inputStreamReader.close();
                outputStreamWriter.close();
                bufferedReader.close();
                bufferedWriter.close();




            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }

    }
}