Server.java

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;


public class Server {

	ServerSocket ss = null;
	Socket s = null;
	DataInputStream dis = null;
	DataOutputStream dos = null;
	BufferedReader br = null;
	//String address = "localhost";
	int port = 3333;

	public Server(){
		try {
			System.out.println("========== Establishing server connection ==========");

			ss = new ServerSocket(port);
			s = ss.accept();
			dis = new DataInputStream(s.getInputStream());
			dos = new DataOutputStream(s.getOutputStream());
			br = new BufferedReader(new InputStreamReader(System.in));

			System.out.println("========== Server connection established! ==========");

			String msg="",rcv="";
			while(!msg.equals("stop")) {
				rcv = readSocket();
				System.out.println("Client says"+ rcv);
				msg = br.readLine();
				System.out.println("You: "+ writeSocket(msg));

			}

			closeServerConnection();


		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public String readSocket() throws IOException {
		System.out.println("========== Fetching message... ==========");

		String received = dis.readUTF();
		return received;
	}

	public String writeSocket(String message) throws IOException {
		System.out.println("========== Write something. ==========");
		System.out.print("You :");
		dos.writeUTF(message);
		dos.flush();
		return message;
	}

	public void closeServerConnection() throws IOException {
		System.out.println("========== Closing server connection ==========");
		dis.close();
		dos.close();
		s.close();
		ss.close();
	}

}