如何防止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&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) {
        int i = err.read(tmp, 0, 1024);
        if (i  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中文網其他相關文章！