Wie kann ein Deadlock bei der JSch-Befehlsausgabe verhindert und ein kontinuierliches Lesen sichergestellt werden?

JSch-Befehlsausgabe lesen: Ausgabe-Deadlock beheben

Dieser Code bleibt ständig hängen, während versucht wird, von der Reader-Instanz zu lesen:

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];
}

Grundursache:

Das Problem entsteht, weil der Code die Ausgabe nicht kontinuierlich liest, während er auf den Abschluss des Befehls wartet. Wenn der Befehl genügend Ausgabe generiert, um den Ausgabepuffer zu füllen, wird der Befehl angehalten und wartet auf den Verbrauch des Puffers. Dies geschieht jedoch nie und führt zu einem Deadlock.

Lösung:

Um dieses Problem zu beheben, ist es wichtig, während der Überwachung sowohl die stdout- als auch die stderr-Streams kontinuierlich zu lesen der Befehlsstatus:

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();

Dieser Ansatz stellt sicher, dass die Ausgabe kontinuierlich gelesen wird, wodurch ein Deadlock verhindert wird.

Das obige ist der detaillierte Inhalt vonWie kann ein Deadlock bei der JSch-Befehlsausgabe verhindert und ein kontinuierliches Lesen sichergestellt werden?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!