JSch 명령 출력 교착 상태를 방지하고 지속적인 읽기를 보장하는 방법은 무엇입니까?

JSch 명령 출력 읽기: 출력 교착 상태 해결

이 코드는 Reader 인스턴스에서 읽으려고 시도하는 동안 지속적으로 중단됩니다.

JSch jsch = new JSch();
jsch.setKnownHosts(dotSshDir + "/known_hosts");
jsch.addIdentity(dotSshDir + "/id_rsa");

Session session = jsch.getSession(userName, hostname, 22);
session.connect();

ChannelExec channel = (ChannelExec) session.openChannel("exec");
channel.setCommand(command);
channel.setInputStream(null);
channel.setErrStream(System.err);
Reader reader = new InputStreamReader(channel.getInputStream());

char[] buf = new char[1024];
int numRead;
while ((numRead = reader.read(buf)) != -1) {
    String readData = String.valueOf(buf, 0, numRead);
    result.append(readData);
    buf = new char[1024];
}

근본 원인:

명령이 완료되기를 기다리는 동안 코드가 출력을 계속 읽지 않기 때문에 문제가 발생합니다. 명령이 출력 버퍼를 채울 만큼 충분한 출력을 생성하면 명령이 중단되고 버퍼가 소비될 때까지 기다립니다. 그러나 이는 절대 발생하지 않아 교착 상태가 발생합니다.

해결 방법:

이 문제를 해결하려면 모니터링하는 동안 stdout 및 stderr 스트림을 지속적으로 읽는 것이 중요합니다. 명령 상태:

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

channel.setCommand(
    "for((i=1;i<=10000;i+=2)); do echo \"Long output - $i\"; done ; " +
    "echo error output >&2");

ByteArrayOutputStream outputBuffer = new ByteArrayOutputStream();
ByteArrayOutputStream errorBuffer = new ByteArrayOutputStream();

InputStream in = channel.getInputStream();
InputStream err = channel.getExtInputStream();

channel.connect();

byte[] tmp = new byte[1024];
while (true) {
    while (in.available() > 0) {
        int i = in.read(tmp, 0, 1024);
        if (i < 0) break;
        outputBuffer.write(tmp, 0, i);
    }
    while (err.available() > 0) {
        int i = err.read(tmp, 0, 1024);
        if (i < 0) break;
        errorBuffer.write(tmp, 0, i);
    }
    if (channel.isClosed()) {
        if ((in.available() > 0) || (err.available() > 0)) continue;
        System.out.println("exit-status: " + channel.getExitStatus());
        break;
    }
    try {
      Thread.sleep(1000);
    } catch (Exception ee) {
    }
}

System.out.println("output: " + outputBuffer.toString("UTF-8"));
System.out.println("error: " + errorBuffer.toString("UTF-8"));

channel.disconnect();

이 접근 방식을 사용하면 출력을 지속적으로 읽어 교착 상태를 방지할 수 있습니다.

위 내용은 JSch 명령 출력 교착 상태를 방지하고 지속적인 읽기를 보장하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!