ჩაწერის პროგრამა Windows კლიენტ-სერვერის კომუნალური პროგრამების ფუნქციონირებით, ნაწილი 01

სალამი.

დღეს მსურს შევხედო კლიენტ-სერვერის აპლიკაციების დაწერის პროცესს, რომლებიც ასრულებენ Windows-ის სტანდარტული კომუნალური პროგრამების ფუნქციებს, როგორიცაა Telnet, TFTP და ა.შ. სუფთა Java-ში. გასაგებია, რომ ახალს არაფერს მოვიტან - ყველა ეს კომუნალური პროგრამა წარმატებით მუშაობს ერთ წელზე მეტი ხნის განმავლობაში, მაგრამ მჯერა, რომ ყველამ არ იცის რა ხდება ქუდის ქვეშ.

ეს არის ზუსტად ის, რაც განიხილება ჭრის ქვეშ.

ამ სტატიაში, რომ არ გავაჭიანუროთ, ზოგადი ინფორმაციის გარდა, დავწერ მხოლოდ Telnet სერვერზე, მაგრამ ამ დროისთვის არის მასალა სხვა კომუნალურებზეც - ეს იქნება სერიის შემდგომ ნაწილებში.

პირველ რიგში, თქვენ უნდა გაარკვიოთ, რა არის Telnet, რისთვის არის საჭირო და რისთვის გამოიყენება. წყაროებს სიტყვასიტყვით არ მოვყვები (საჭიროების შემთხვევაში, სტატიის ბოლოს დავურთავ ბმულს თემის შესახებ), მხოლოდ ვიტყვი, რომ Telnet უზრუნველყოფს დისტანციურ წვდომას მოწყობილობის ბრძანების ხაზზე. ზოგადად, აქ მთავრდება მისი ფუნქციონირება (მე განზრახ გავჩუმდი სერვერის პორტზე წვდომის შესახებ; ამის შესახებ მოგვიანებით). ეს ნიშნავს, რომ მის განსახორციელებლად, ჩვენ უნდა მივიღოთ ხაზი კლიენტზე, გადავიტანოთ სერვერზე, ვცადოთ გადავიტანოთ ბრძანების ხაზში, წავიკითხოთ ბრძანების ხაზის პასუხი, თუ არის, გადავაბრუნოთ კლიენტს და აჩვენეთ ის ეკრანზე, ან შეცდომის შემთხვევაში აცნობეთ მომხმარებელს, რომ რაღაც არასწორია.

ზემოაღნიშნულის განსახორციელებლად, შესაბამისად, გვჭირდება 2 სამუშაო კლასი და რამდენიმე სატესტო კლასი, საიდანაც გავუშვით სერვერი და რომლის მეშვეობითაც კლიენტი იმუშავებს.
შესაბამისად, ამ დროისთვის განაცხადის სტრუქტურა მოიცავს:

• TelnetClient
• TelnetClientTester
• TelnetServer
• TelnetServerTester

მოდით გავიაროთ თითოეული მათგანი:

TelnetClient

ამ კლასს მხოლოდ უნდა შეეძლოს, გაგზავნოს მიღებული ბრძანებები და აჩვენოს მიღებული პასუხები. გარდა ამისა, თქვენ უნდა შეძლოთ დისტანციური მოწყობილობის თვითნებურ (როგორც ზემოთ აღინიშნა) პორტთან დაკავშირება და მისგან გათიშვა.

ამის მისაღწევად განხორციელდა შემდეგი ფუნქციები:

ფუნქცია, რომელიც არგუმენტად იღებს სოკეტის მისამართს, ხსნის კავშირს და იწყებს შეყვანის და გამომავალი ნაკადებს (ნაკადის ცვლადები ზემოთ არის გამოცხადებული, სრული წყაროები სტატიის ბოლოს).

 public void run(String ip, int port)
    {
        try {
            Socket socket = new Socket(ip, port);
            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();
            Scanner keyboard = new Scanner(System.in);
            reader = new Thread(()->read(keyboard, sout));
            writer = new Thread(()->write(sin));
            reader.start();
            writer.start();
        }
        catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

იგივე ფუნქციის გადატვირთვა, ნაგულისხმევ პორტთან დაკავშირება - ტელნეტისთვის ეს არის 23

    public void run(String ip)
    {
        run(ip, 23);
    }

ფუნქცია კითხულობს სიმბოლოებს კლავიატურიდან და აგზავნის მათ გამომავალი სოკეტში - რაც ტიპიურია ხაზის რეჟიმში და არა სიმბოლოების რეჟიმში:

    private void read(Scanner keyboard, OutputStream sout)
    {
        try {
            String input = new String();
            while (true) {
                input = keyboard.nextLine();
                for (char i : (input + " n").toCharArray())
                    sout.write(i);
            }
        }
        catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

ფუნქცია იღებს მონაცემებს სოკეტიდან და აჩვენებს მას ეკრანზე

    private void write(InputStream sin)
    {
        try {
            int tmp;
            while (true){
                tmp = sin.read();
                System.out.print((char)tmp);
            }
        }
        catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

ფუნქცია აჩერებს მონაცემთა მიღებას და გადაცემას

    public void stop()
    {
        reader.stop();
        writer.stop();
    }
}

TelnetServer

ამ კლასს უნდა ჰქონდეს სოკეტიდან ბრძანების მიღების, შესასრულებლად გაგზავნის და ბრძანებიდან პასუხის გაგზავნის ფუნქცია სოკეტში. პროგრამა შეგნებულად არ ამოწმებს შეყვანის მონაცემებს, რადგან ჯერ ერთი, "boxed telnet"-შიც კი შესაძლებელია სერვერის დისკის ფორმატირება და მეორეც, ამ სტატიაში უსაფრთხოების საკითხი პრინციპში გამოტოვებულია და ამიტომ არ არის რამდენიმე სიტყვა დაშიფვრის ან SSL-ის შესახებ.

არსებობს მხოლოდ 2 ფუნქცია (ერთი მათგანი გადატვირთულია) და ზოგადად ეს არ არის ძალიან კარგი პრაქტიკა, მაგრამ ამ ამოცანის მიზნებისთვის მიზანშეწონილად მომეჩვენა, რომ ყველაფერი ისე დავტოვო, როგორც არის.

 boolean isRunning = true;
    public void run(int port)    {

        (new Thread(()->{ try {
            ServerSocket ss = new ServerSocket(port); // создаем сокет сервера и привязываем его к вышеуказанному порту
            System.out.println("Port "+port+" is waiting for connections");

            Socket socket = ss.accept();
            System.out.println("Connected");
            System.out.println();

            // Берем входной и выходной потоки сокета, теперь можем получать и отсылать данные клиенту.
            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();

            Map<String, String> env = System.getenv();
            String wayToTemp = env.get("TEMP") + "tmp.txt";
            for (int i :("Connectednnr".toCharArray()))
                sout.write(i);
            sout.flush();

            String buffer = new String();
            while (isRunning) {

                int intReader = 0;
                while ((char) intReader != 'n') {
                    intReader = sin.read();
                    buffer += (char) intReader;
                }


                final String inputToSubThread = "cmd /c " + buffer.substring(0, buffer.length()-2) + " 2>&1";


                new Thread(()-> {
                    try {

                        Process p = Runtime.getRuntime().exec(inputToSubThread);
                        InputStream out = p.getInputStream();
                        Scanner fromProcess = new Scanner(out);
                        try {

                            while (fromProcess.hasNextLine()) {
                                String temp = fromProcess.nextLine();
                                System.out.println(temp);
                                for (char i : temp.toCharArray())
                                    sout.write(i);
                                sout.write('n');
                                sout.write('r');
                            }
                        }
                        catch (Exception e) {
                            String output = "Something gets wrong... Err code: "+ e.getStackTrace();
                            System.out.println(output);
                            for (char i : output.toCharArray())
                                sout.write(i);
                            sout.write('n');
                            sout.write('r');
                        }

                        p.getErrorStream().close();
                        p.getOutputStream().close();
                        p.getInputStream().close();
                        sout.flush();

                    }
                    catch (Exception e) {
                        System.out.println("Error: " + e.getMessage());
                    }
                }).start();
                System.out.println(buffer);
                buffer = "";

            }
        }
        catch(Exception x) {
            System.out.println(x.getMessage());
        }})).start();

    }

პროგრამა ხსნის სერვერის პორტს, კითხულობს მონაცემებს მისგან, სანამ არ შეხვდება ბრძანების ბოლოს სიმბოლოს, გადასცემს ბრძანებას ახალ პროცესზე და გადამისამართებს გამომავალს პროცესიდან სოკეტში. ყველაფერი ისეთივე მარტივია, როგორც კალაშნიკოვის ავტომატი.

შესაბამისად, ამ ფუნქციის გადატვირთვაა ნაგულისხმევი პორტით:

 public void run()
    {
        run(23);
    }

შესაბამისად, ფუნქცია, რომელიც აჩერებს სერვერს, ასევე ტრივიალურია, ის წყვეტს მარადიულ მარყუჟს, არღვევს მის მდგომარეობას.

    public void stop()
    {
        System.out.println("Server was stopped");
        this.isRunning = false;
    }

მე აქ არ მივცემ სატესტო კლასებს, ისინი ქვემოთ არის - ყველაფერი რაც აკეთებენ არის საჯარო მეთოდების ფუნქციონირების შემოწმება. ყველაფერი რიგზეა.

შეჯამებისთვის, რამდენიმე საღამოს შეგიძლიათ გაიგოთ ძირითადი კონსოლის კომუნალური საშუალებების მუშაობის პრინციპები. ახლა, როდესაც დისტანციურ კომპიუტერს ვუკავშირდებით, ჩვენ გვესმის, რა ხდება - მაგია გაქრა)

ასე რომ, ლინკები:
ყველა წყარო იყო, არის და იქნება აქ
ტელნეტის შესახებ
მეტი Telnet-ის შესახებ

წყარო: www.habr.com