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

public class Server {
    public static void main(String[] ar)
    {
        int port = 6789; // случайный порт (может быть любое число от 1025 до 65535)
        try {
            ServerSocket ss = new ServerSocket(port); // создаем сокет сервера и привязываем его к вышеуказанному порту
            System.out.println("Waiting for a client...");
            while (true) {
                Socket socket = ss.accept(); // заставляем сервер ждать подключений и выводим сообщение когда кто-то связался с сервером
                new Thread()
                {
                    Socket client = socket;

                    InputStream sin = client.getInputStream();
                    OutputStream sout = client.getOutputStream();

                    // Конвертируем потоки в другой тип, чтоб легче обрабатывать текстовые сообщения.
                    DataInputStream in = new DataInputStream(sin);
                    DataOutputStream out = new DataOutputStream(sout);

                    String line = null;

                    public void run()
                    {
                        System.out.println("Ready to recive and execute commands.");
                        Boolean stop = false;
                        while(!stop) {
                            try {
                                out.writeBytes("Enter command: ");
                                out.flush();
                                line = in.readLine();
                                if(line.equals("")) continue;
                                if(line.toUpperCase().equals("EXIT"))
                                {
                                    stop = true;
                                    in.close();
                                    out.close();
                                    client.close();
                                    break;
                                }

                                System.out.println("Executing command: \"" + line + "\"");
                                try {
                                    String str = executeCommand(line);
                                    System.out.println(str + "\r\n");
                                    out.writeUTF(str + "\r\n");
                                    out.flush();
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                            } catch (Exception E) {}
                        }
                    }

                }.start();
            }
        } catch(Exception x) {

        }
    }

    public static String executeCommand(String command)
    {
        StringBuffer output = new StringBuffer();

        Process p;
        try {
            p = Runtime.getRuntime().exec(command);
            p.waitFor();
            BufferedReader reader =
                    new BufferedReader(new InputStreamReader(p.getInputStream()));

            String line = "";
            while ((line = reader.readLine())!= null) {
                output.append(line + "\n");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return output.toString();
    }
}