Bagaimana untuk Mencegah Kebuntuan Output Perintah JSch dan Memastikan Pembacaan Berterusan?

Membaca Output Perintah JSch: Menyelesaikan Kebuntuan Output

Kod ini secara konsisten digantung semasa cuba membaca daripada contoh Pembaca:

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

Punca Punca:

Masalah timbul kerana kod tidak membaca output secara berterusan sementara menunggu arahan selesai. Apabila arahan menjana output yang mencukupi untuk mengisi penimbal keluaran, arahan terhenti, menunggu penggunaan penimbal. Walau bagaimanapun, ini tidak pernah berlaku, membawa kepada kebuntuan.

Penyelesaian:

Untuk menyelesaikan isu ini, adalah penting untuk membaca kedua-dua aliran stdout dan stderr secara berterusan semasa memantau status arahan:

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

Pendekatan ini memastikan output dibaca secara berterusan, mengelakkan kebuntuan.

Atas ialah kandungan terperinci Bagaimana untuk Mencegah Kebuntuan Output Perintah JSch dan Memastikan Pembacaan Berterusan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!