VPF::getRuntime().exec и потоки - Форум программистов

Demetrio

Дата 1.5.2007, 09:46 (ссылка)

(голосов:1)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 67
Регистрация: 1.5.2007

Репутация: нет
Всего: нет

Новичок в java
далее
Как правильно обеспечить удерживание процесса(или сессии)?
На данный момент делаю так, но ...
1. Второй раз вызов метода get_info ничего не вовзращает..... где накосячил?
2. Как мне очистить OutPutStream , так как мой mytelnet при старте выдает служебную информацию....

p.s. Конечно mytelnet не telnet никакой... просто консольная клиентская утилитка. Можно в ней затык.

Код


public class mytelnet 
{
    private Process proc;
    
    public mytelnet(String id_user, String password)  throws IOException
    {
             String pre_command = "mytelnet -id=admin -pa=admin";
        proc = Runtime.getRuntime().exec(pre_command);
    }
    
    public String get_info(String command) throws IOException
    {
        BufferedWriter buffOut = new BufferedWriter( new OutputStreamWriter(proc.getOutputStream()) ); 
        buffOut.write(command);
        buffOut.close();
        
        InputStream inputstream = proc.getInputStream();
        InputStreamReader inputstreamreader = new InputStreamReader(inputstream);
        BufferedReader bufferedreader = new BufferedReader(inputstreamreader);
    
        String line;
        String linea = new String();
        while ((line = bufferedreader.readLine()) != null)
        {
            linea += line+"\n";
        }
        return linea;
    }
}

Это сообщение отредактировал(а) tux - 1.5.2007, 10:04

LSD

Дата 1.5.2007, 14:43 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Demetrio @ 1.5.2007, 10:46

)

1. Второй раз вызов метода get_info ничего не вовзращает..... где накосячил?

Зачем ты закрываешь поток (buffOut.close();)? Не ты его открывал, не тебе его и закрывать.

Цитата(Demetrio @ 1.5.2007, 10:46

)

2. Как мне очистить OutPutStream , так как мой mytelnet при старте выдает служебную информацию....

Просто прочитать ее из process InputStream.

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

Demetrio

Дата 1.5.2007, 16:38 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 67
Регистрация: 1.5.2007

Репутация: нет
Всего: нет

Без закрытия close ничего не выводит вовсе.... может еще как надо подкрректировать...

НЕмного модернизировал под ProcessBuilder, но сути это не меняет...
Если у кого есть пример, как посылать команды открытому процессу по мере необходимости, не вызывая ProcessBuilder каждый раз, то с радостью воспользуюсь....
Еще раз повторюсь первый вызов метода get_info проходит на ура

Код



public class mytelnet
{
    private Process proc;
    private InputStream inputstream;
    private OutputStream outputstream;
    
    public mytelnet(String id_user, String password)  throws IOException
    {        
        this.proc = new ProcessBuilder("bash").start();                
        this.inputstream = this.proc.getInputStream();
        this.outputstream = this.proc.getOutputStream();        
    }
    
    public String get_info(String command) throws IOException
    {
        String line;
        String linea = new String();
        
        BufferedWriter buffOut = new BufferedWriter( new OutputStreamWriter(this.outputstream) );
        buffOut.write("pwd");
        buffOut.close();
                
        InputStreamReader inputstreamreader = new InputStreamReader(this.inputstream);
        BufferedReader bufferedreader = new BufferedReader(inputstreamreader);
         
        while ((line = bufferedreader.readLine()) != null)
        {
            linea += line+"\n";
        }
        return linea;
    }
}

Это сообщение отредактировал(а) powerOn - 1.5.2007, 16:48

powerOn

Дата 1.5.2007, 16:48 (ссылка)

(нет голосов)

Загрузка ...

software saboteur

Профиль
Группа: Участник
Сообщений: 4367
Регистрация: 7.10.2005

Репутация: 47
Всего: 159

Модератор: Используйте кнопку КОД для оформления исходников!

--------------------

нет времени думать - нужно писать КОД!

LSD

Дата 1.5.2007, 17:37 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Demetrio @ 1.5.2007, 17:38

)

Без закрытия close ничего не выводит вовсе.... может еще как надо подкрректировать...

Используй вместо close() - flush().

--------------------

Demetrio

Дата 2.5.2007, 09:26 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 67
Регистрация: 1.5.2007

Репутация: нет
Всего: нет

нет, данный вариант тоже не проходит

LSD

Дата 3.5.2007, 11:08 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Код

public class CmdTest
{
  private InputStream inputStream;
  private OutputStream outputStream;
  private InputStream errorStream;
  private Process proc;

  public CmdTest() throws IOException
  {
    proc = new ProcessBuilder("cmd.exe").start();
    this.inputStream = proc.getInputStream();
    this.outputStream = proc.getOutputStream();
    this.errorStream = proc.getErrorStream();
  }

  public void exec(String... commands)
  {
    new Spooler(inputStream, System.out).start();
    new Spooler(errorStream, System.err).start();

    BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(this.outputStream));
    for(String command : commands)
    {
      try
      {
        writer.write(command);
        writer.newLine();
        writer.flush();
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
    }
  }

  public int exit()
  {
    try
    {
      BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(this.outputStream));
      writer.write("exit");
      writer.newLine();
      writer.flush();
      return proc.waitFor();
    }
    catch(Exception e)
    {
      e.printStackTrace();
    }
    return -1;
  }

  public static void main(String[] args) throws IOException
  {
    CmdTest test = new CmdTest();
    test.exec("C:", "CD C:\\Windows", "dir");
    test.exit();
  }

  private static class Spooler extends Thread
  {
    private InputStream in;
    private OutputStream out;


    public Spooler(InputStream in, OutputStream out)
    {
      super("SpoolerThread");
      this.in = in;
      this.out = out;
    }

    @Override
    public void run()
    {
      byte[] buffer = new byte[1024];
      int read;
      try
      {
        while((read = in.read(buffer)) != -1)
          out.write(buffer, 0, read);
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
    }
  }
}

--------------------

Akeem

Дата 13.2.2008, 11:05 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

Вопрос по классу CmdTest.
Как можно переписать этот класс так чтобы результаты выводились не на консоль, а в в стринг.
Или плиз покажите строчку где выводятся результаты работы команды.

Сорри. Смотрю я на класс и не вижу где эти результаты выводятся. :-[

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

Sardar

Дата 13.2.2008, 12:32 (ссылка)

(нет голосов)

Загрузка ...

Бегун

Профиль
Группа: Модератор
Сообщений: 6986
Регистрация: 19.4.2002
Где: Нидерланды, Groni ngen

Репутация: 4
Всего: 317

Spooler перегоняет данные из input- в output-stream, тредом висит, блокируется по in.read(). Пока есть данные в потоке тред разблокирован, зачитывает их в переданный output-stream (81-82). Рядом с out.write поставь StringBuilder.append(buffer, 0, read). Если необходимо, то по in.available() > 0 можно определить заблокируемся ли на следующей итерации.

--------------------

Опыт - сын ошибок трудных © А. С. Пушкин
Процесс написания своего велосипеда повышает профессиональный уровень программиста. © Opik
Оценить мои качества можно тут.

Akeem

Дата 13.2.2008, 12:53 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

прописал строку StringBuilder.append(buffer, 0, read) перед out.write. И еклипс начал ругатся на buffer
Пишет что нужно чтобы он был CharSequence

А если использовать замисть переганяния StringBufferInputStream он вроде сражу должен возвращать нужный стринг.

Добавлено через 10 минут и 30 секунд
Решил проблему.

Код



 public void run()
    {
      char[] buffer = new char[1024];
      int read;
     
      try
      {
       InputStreamReader br = new InputStreamReader(in);
       StringBuilder sB = new StringBuilder();
        while((read = br.read(buffer)) != -1)
        {
         
         sB.append(buffer, 0, read); //Пихаем наш буфер в стринг.
        }
       
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
      
    }

Теперь у меня возник вопрос такой.
Возможен ли вывод каждого выполнения команды отдельно.
Например выполнил одну команду вывел её результат. И как это сделать?
П.С. Последовательный вывод возможен для одной консоли. smile

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

LSD

Дата 13.2.2008, 13:23 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Вместо:

Код


new Spooler(inputStream, System.out).start();
new Spooler(errorStream, System.err).start();

пиши:

Код


ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
ByteArrayOutputStream err = new ByteArrayOutputStream(1024);
new Spooler(inputStream, out).start();
new Spooler(errorStream, err).start();

а когда хочешь получить строку:

Код


String output = new String(out.toByteArray());
String errors = new String(err.toByteArray());

--------------------

Akeem

Дата 13.2.2008, 13:37 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

Цитата(LSD)

а когда хочешь получить строку:
Java

String output = new String(out.toByteArray());
String errors = new String(err.toByteArray());

Куда мне это добавить? В функцию exec?

П.С. Я добавил ее в эту функцию. но мне после выполнения команды например: test.exec("C:"); test.exec("CD"); выдает []

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

LSD

Дата 13.2.2008, 13:42 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Akeem @ 13.2.2008, 13:37

)

Куда мне это добавить? В функцию exec?

Туда где тебе надо получить результат выполнения команды.

--------------------

Akeem

Дата 13.2.2008, 13:52 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

Вот написал метод для вывода результатов

Код



 public String GetReslut() 
  {
      String output = new String(out.toByteArray());  //переменные обьявлены как глобальные в классе
        String errors = new String(err.toByteArray());
    return output+"\n"+errors;
  }

Результат выполнения команд

Код


Cmd test = new Cmd();
test.exec("C:"); 
test.exec("CD");
System.out.println(test.GetReslut());

Остается плачевным -- те выводит пустую консоль. Замисть того чтобы вывести C:\

Добавлено через 2 минуты и 11 секунд
П.С. Сорри за тупые вопросы. Чет туплю седня. smile

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

Akeem

Дата 13.2.2008, 14:17 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

Вот как нужно выводить результат каждой команды:
Функция для перехвата вывода:

Код



public void run()
    {
      char[] buffer = new char[1024];
      int read;
     
      try
      {
       InputStreamReader br = new InputStreamReader(in);
       
        while((read = br.read(buffer)) != -1)
        {
         
         sB.append(buffer, 0, read);

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

(генетически модифицированая функция написаная ЛСД (спасибо ему за это огромное) smile

)
Функция вывода:

Код


public StringBuilder GetReslut() 
  {

    return Spooler.sB;
  }

Вызов:

Код


Cmd test = new Cmd();
test.exec("C:"); 
test.exec("CD");
System.out.println(test.GetReslut());

Единственный минус не понятно каким Р оно работает.
Те при дебаге все работает как нужно, но при обычном выполнении ничего не выводится.

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

LSD

Дата 13.2.2008, 14:44 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Проблема состоит в том, что CmdTest.exec() не ждет пока будет выполнена команда. Команда просто передаётся cmd.exe и все. Сколько она будет выполняться - неизвестно. С выводом в System.out таких проблем нет, потому что по мере выполнения команды данные перекачиваются в System.out, а тут ты сам должен определить когда команда выполнилась, или просто подождать.

Код


import java.io.*;

public class CmdTest
{
  private OutputStream outputStream;
  private InputStream inputStream;
  private InputStream errorStream;
  private ByteArrayOutputStream output = new ByteArrayOutputStream();
  private ByteArrayOutputStream errors = new ByteArrayOutputStream();
  private Process proc;

  public CmdTest() throws IOException
  {
    proc = new ProcessBuilder("cmd.exe").start();
    this.inputStream = proc.getInputStream();
    this.outputStream = proc.getOutputStream();
    this.errorStream = proc.getErrorStream();

    new CmdTest.Spooler(inputStream, output).start();
    new CmdTest.Spooler(errorStream, errors).start();
  }

  public void exec(String... commands)
  {
    BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(this.outputStream));
    for(String command : commands)
    {
      try
      {
        writer.write(command);
        writer.newLine();
        writer.flush();
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
    }
  }

  public String getOutput(String charset) throws UnsupportedEncodingException
  {
    return new String(output.toByteArray(), charset);
  }

  public void clearOutput()
  {
    output.reset();
  }

  public String getErrors(String charset) throws UnsupportedEncodingException
  {
    return new String(errors.toByteArray(), charset);
  }

  public void clearErrors()
  {
    errors.reset();
  }

  public int exit()
  {
    try
    {
      BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(this.outputStream));
      writer.write("exit");
      writer.newLine();
      writer.flush();
      return proc.waitFor();
    }
    catch(Exception e)
    {
      e.printStackTrace();
    }
    return -1;
  }

  public static void main(String[] args) throws Exception
  {
    CmdTest test = new CmdTest();

    test.exec("C:", "CD C:\\Windows", "dir");
    Thread.sleep(1000);
    System.out.println("output = " + test.getOutput("Cp866"));
    test.clearOutput();
    System.out.println("errors = " + test.getErrors("Cp866"));
    test.clearErrors();
    System.out.println("\n=======================================\n");

    test.exec("ipconfig");
    Thread.sleep(1000);
    System.out.println("output = " + test.getOutput("Cp1251"));
    test.clearOutput();
    System.out.println("errors = " + test.getErrors("Cp1251"));
    test.clearErrors();
    System.out.println("\n=======================================\n");

    test.exec("find /?");
    Thread.sleep(1000);
    System.out.println("output = " + test.getOutput("Cp866"));
    test.clearOutput();
    System.out.println("errors = " + test.getErrors("Cp866"));
    test.clearErrors();
    System.out.println("\n=======================================\n");

    test.exit();
    Thread.sleep(1000);
    System.out.println("output = " + test.getOutput("Cp866"));
    test.clearOutput();
    System.out.println("errors = " + test.getErrors("Cp866"));
    test.clearErrors();
    System.out.println("\n=======================================\n");
  }

  private static class Spooler extends Thread
  {
    private InputStream in;
    private OutputStream out;

    public Spooler(InputStream in, OutputStream out)
    {
      super("SpoolerThread");
      this.in = in;
      this.out = out;
    }

    @Override
    public void run()
    {
      byte[] buffer = new byte[1024];
      int read;
      try
      {
        while((read = in.read(buffer)) != -1)
          out.write(buffer, 0, read);
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
    }
  }
}

--------------------

Akeem

Дата 13.2.2008, 15:15 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

LSD, спасибо!
Все работает. Премного благодарен.

Только вопрос: обезательно указывать кодировку? спрашиваю потому що если указать явно то выдает ошибку что неопознает кодировки. (мне не нужны лишние параметры)

П.С. Код переписал под свою программу.

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

LSD

Дата 13.2.2008, 15:22 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Akeem @ 13.2.2008, 15:15

)

Только вопрос: обезательно указывать кодировку?

У меня без указания кодировки не все работает корректно, вместо русских буквы кракозябры. Можешь переписать так:

Код


  public String getOutput(Charset charset)
  {
    return new String(output.toByteArray(), charset);
  }

тогда никаких Exception-ов выкидываться не будет.

Добавлено через 37 секунд
К тому же часть команд выводит данные в 866 кодировке, часть в 1251.

--------------------

Akeem

Дата 13.2.2008, 15:26 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 381
Регистрация: 14.7.2006
Где: Киев/Украина

Репутация: нет
Всего: 3

Ну в принципе у меня проблем с кодировкой не должно быть. Все результаты и команды на англ.

П.С. Я вообще убрал объявление кодировки с функции.

Код


public String getOutput()
  {
    return new String(output.toByteArray());
  }

--------------------

Мир огромен и мы только муравьи в нём! (С) formicha

Resilient

Дата 27.11.2008, 18:21 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 13
Регистрация: 26.11.2008

Репутация: нет
Всего: нет

Приветствую... вобщем-то тоже чайник в Яве, надеюсь, что только пока что smile

А нету ли способа гарантированно дождаться выполнения команды? и узнать, что вернула та програмка.

LSD

Дата 29.11.2008, 15:37 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Resilient @ 27.11.2008, 18:21

)

А нету ли способа гарантированно дождаться выполнения команды? и узнать, что вернула та програмка.

А нафига?
Если тебе нужно выполнить некую программу, то вызывай непосредственно её, а не через cmd.exe и таких проблем не будет. А если тебе нужно выполнить команду именно cmd.exe, то в любом случае ты будешь парсить вывод этой команды и по нему уже можно будет определить, что команда завершена.

--------------------

Resilient

Дата 1.12.2008, 16:52 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 13
Регистрация: 26.11.2008

Репутация: нет
Всего: нет

В данном случае неизвестно других методов вызова, кроме как из командной строки :(
Нужно же дождаться окончания выполнения и в зависимости от кода возврата в cmd продолжить.

LSD

Дата 1.12.2008, 18:23 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Resilient @ 1.12.2008, 16:52

)

В данном случае неизвестно других методов вызова, кроме как из командной строки :(

Вызова чего? Ты программу пытаешься вызвать или внутреннюю команду cmd.exe?

--------------------

Resilient

Дата 2.12.2008, 15:11 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 13
Регистрация: 26.11.2008

Репутация: нет
Всего: нет

программу. И другого вызова в данном случае не получится.
НО у меня оно дожидается окончания работы. smile

LSD

Дата 2.12.2008, 17:33 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Resilient @ 2.12.2008, 15:11

)

программу.

Ну так и запускай программу, а не cmd.exe smile

--------------------

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »