SSH через Java - PullRequest
       18

SSH через Java

0 голосов
/ 15 апреля 2011

Я использую инструменты java ssh, чтобы установить ssh-соединение со своей школьной учетной записью, найти файл и затем удалить его. Однако я создаю три функции для выполнения одной и той же операции, но с разными файлами, и я ищу способ сделать это с помощью одной и той же вещи, а не выполнять одну за другой. Вот код По сути, я хочу знать, есть ли способ сделать все это на одном ssh-соединении или на каком-то форке или многопоточности.

public void updateinterval() {
    try {
        JSch jsch = new JSch();

        String user = "***********";
        String host = "********";
        Session session = jsch.getSession(user, host, 22);

        session.setPassword("*********");

        // username and password will be given via UserInfo interface.
        UserInfo userInfo = new SftpUserInfo();

        session.setUserInfo(userInfo);

        session.connect();

        // look for a file named feedinterval

        String checkfortimeupdate =
                "cd public_html/final;grep '-send' feedinterval";

        Channel channel = session.openChannel("exec");
        ((ChannelExec) channel).setCommand(checkfortimeupdate);

        // X Forwarding
        // channel.setXForwarding(true);

        // channel.setInputStream(System.in);
        channel.setInputStream(null);

        // channel.setOutputStream(System.out);

        // FileOutputStream fos=new FileOutputStream("/tmp/stderr");
        // ((ChannelExec)channel).setErrStream(fos);
        ((ChannelExec) channel).setErrStream(System.err);

        InputStream in = channel.getInputStream();

        channel.connect();

        byte[] tmp = new byte[1024];

        while (true) {
            while (in.available() > 0) {
                int i = in.read(tmp, 0, 1024);
                if (i < 0)
                    break;
                String returned = new String(tmp, 0, i);

                String argument = returned.substring(6);

                if (returned.contains("-send")) {

                    // if its there its calls the removeinterval function
                    // which removes the file it found
                    // by doing the same thing this function does but with a
                    // different ssh command

                    arduinoupdate hey = new arduinoupdate();

                    hey.removeinterval();

                    try {
                        Runtime rt = Runtime.getRuntime();

                        String[] commands = {
                                "system.exe", "-send", argument };

                        Process proc = rt.exec(commands);
                    }

                    catch (IOException e) {
                    }
                }
            }

            if (channel.isClosed()) {
                System.out.println("UpdateInterval Closed exit-status: "
                        + channel.getExitStatus());
                break;
            }
            try {
                /* Thread.sleep(1000); */
            } catch (Exception ee) {
            }
        }
        channel.disconnect();
        session.disconnect();
    } catch (Exception e) {
        System.out.println(e);
    }
}

Ответы [ 3 ]

1 голос
/ 15 апреля 2011

Если вы хотите запустить несколько задач, возможно, ExpectJ будет работать лучше для вас.ExpectJ использует JSCH под одеялами, так что это может облегчить вашу жизнь.

final ExpectJ expectJ = new ExpectJ();
final Spawn spawn = expectJ.spawn("host", 22, "user", "pass");
spawn.send("cd public_html/final\n");
spawn.expect("someReturn");
...
spawn.send("exit\n");
spawn.expectClose();
0 голосов
/ 02 ноября 2011

Что касается использования ExpectJ, какую библиотеку лучше всего использовать в критически важных производственных приложениях для функций, основанных на ожиданиях?

ExpectJ или Expect4J библиотека?Хотя обе библиотеки используют JSch внизу!Или Apache SSHD - Клиент:

SshClient client = SshClient.setUpDefaultClient(); PipedOutputStream PipedIn...?
0 голосов
/ 15 апреля 2011

Как сказали комментаторы, лучше разбить его на отдельные функции. Затем становится более понятным, как повторно использовать одно и то же соединение (т. Е. Session ) для нескольких команд.

public void updateInterval(Session s, String filename) {
    String checkfortimeupdate = "fgrep '-send' \"public_html/final/" + filename + "\"";

    ChannelExec channel = (ChannelExec)session.openChannel("exec");
    channel.setCommand(checkfortimeupdate);

    channel.setInputStream(null);
    channel.setErrStream(System.err);
    BufferedReader in = new BufferedReader(new InputStreamReader(channel.getInputStream(), encoding));

    channel.connect();

    eatOutput(in);

    if (channel.isClosed()) {
        System.out.println("UpdateInterval Closed exit-status: "
                           + channel.getExitStatus());
        break;
    }
    channel.disconnect();
}

Затем поместите чтение из BufferedReader (у него есть метод readLine) в метод eatOutput и получите другой метод, который открывает сеанс и трижды вызывает метод, показанный здесь (с разными именами файлов), и снова закрывает сессию.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...