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 中国語 Web サイトの他の関連記事を参照してください。