如何读取 JSch 命令输出？

Posted 2023-03-04

【中文标题】如何读取 JSch 命令输出？

【英文标题】：How to read JSch command output?

【发布时间】：2011-10-17 15:49:36

【问题描述】：

我有以下代码：

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

它正在尝试从阅读器中读取。我该如何解决？我该如何追查正在发生的事情？

【参考方案1】：

必须在等待命令完成的同时连续读取输出。否则，如果命令产生足够的输出来填充输出缓冲区，则命令将挂起，等待缓冲区被消耗，这永远不会发生。所以你会陷入僵局。

以下示例在监视命令状态的同时连续读取 stdout 和 stderr。它基于official JSch exec.java example（只是添加了一个读取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();

---

如果你在channel.connect(); 之后添加while (!channel.isClosed()) ，你会看到在for 循环中的i 足够大（在我的环境中10000 就足够了），循环永远不会结束。