자바 호출 셸 스 크 립 트 차단

  자바 가 셸 을 호출 할 때 프로 세 스 의 표준 출력 과 오류 출력 흐름 에 대한 정 보 를 계속 읽 어야 합 니 다. 그렇지 않 으 면 버퍼 가 가득 쓰 이면 하위 프로 세 스 가 막 혀 서 계속 실행 할 수 없습니다. 두 스 레 드 에서 표준 출력, 오류 흐름 정 보 를 계속 읽 을 수 있 습 니 다. 다음 코드 는 다음 과 같 습 니 다.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.nio.charset.Charset;
 
import org.apache.commons.io.IOUtils;
 
import ch.ethz.ssh2.ChannelCondition;
import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;
 
 
public class RmtShellExecutor {
 
     
    private Connection conn;
    private String ip;
    private String usr;
    private String psword;
    private String charset = Charset.defaultCharset().toString();
 
    private static final int TIME_OUT = 1000 * 5 * 60;
 
    public RmtShellExecutor(String ip, String usr, String ps) {
        this.ip = ip;
        this.usr = usr;
        this.psword = ps;
    }
 
    private boolean login() throws IOException {
        conn = new Connection(ip);
        conn.connect();
        return conn.authenticateWithPassword(usr, psword);
    }
 
    //本地执行方法
    public static void execLocal(String cmd) {
           try {
                Process proc = Runtime.getRuntime().exec(cmd);
                StreamGobbler errorGobbler = new StreamGobbler(proc.getErrorStream(), "ERROR");
                StreamGobbler outputGobbler = new StreamGobbler(proc.getInputStream(), "OUTPUT");
                errorGobbler.start();
                outputGobbler.start();
                int exitVal = proc.waitFor();
                System.out.println("ExitValue: " + exitVal);
             } catch (Exception e) {
                  e.printStackTrace();
             } 
             
        }
         
    //远程执行方法
    public int execRemote(String cmds){
        InputStream stdOut = null;
        InputStream stdErr = null;
        int ret = -1;
        try {
            if (login()) {
                // Open a new {@link Session} on this connection
                Session session = conn.openSession();
                // Execute a command on the remote machine.
                session.execCommand(cmds);
 
                GobblerThread gtOut = new GobblerThread(session.getStdout(),"STD_OUT");
                GobblerThread gtErr = new GobblerThread(session.getStderr(),"STD_ERR");
                gtOut.start();
                gtErr.start();
 
                session.waitForCondition(ChannelCondition.EXIT_STATUS, TIME_OUT);
                ret = session.getExitStatus();
            } else {
            }
        }catch(Exception e){
            e.printStackTrace();
        }
        finally {
            if (conn != null) {
                conn.close();
            }
            IOUtils.closeQuietly(stdOut);
            IOUtils.closeQuietly(stdErr);
        }
        return ret;
    }
 
    public static void main(String args[]) throws Exception {
        RmtShellExecutor exe = new RmtShellExecutor("192.168.3.5", "test",
                "123456");
        System.out.println(exe.execRemote("sh /home/test/cmd.sh company=32"));
    }
}
 
class GobblerThread extends Thread
{
    InputStream is;
    String type;
     
    GobblerThread(InputStream is, String type)
    {
        this.is = is;
        this.type = type;
    }
     
    public void run()
    {
        try
        {
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String line=null;
            while ( (line = br.readLine()) != null)
                System.out.println(line);    
            } catch (IOException e)
              {
                e.printStackTrace();  
              }
    }
}

그 중에서 exec Local 이 로 컬 에서 cmd 를 호출 하 는 방법
  exeRemote 는 ssh 를 이용 하여 원 격 기기 에 로그 인하 여 cmd 를 호출 하 는 방법