我正在使用 J2ssh 库连接到 Unix 机器,运行命令并使用输入流获取结果。但是程序在读取输入流时会进入循环。我能够从输入蒸汽中得到结果,但是程序在那里触发并且没有继续。为什么程序会卡在那个循环中?
这是源代码,
public void loginAndCheckProcess(String hostName, String userName, String password, String port) {
try {
SshConnector con = SshConnector.createInstance();
SocketTransport transport = new SocketTransport(hostName, 22);
transport.setTcpNoDelay(true);
SshClient client = con.connect(transport, userName);
Ssh2Client ssh2 = (Ssh2Client) client;
PasswordAuthentication pwd = new PasswordAuthentication();
do {
pwd.setPassword(password);
} while (ssh2.authenticate(pwd) != SshAuthentication.COMPLETE && client.isConnected());
String command = "ps -ef | grep " + port + '\n';
if (client.isAuthenticated()) {
SshSession session = client.openSessionChannel();
session.startShell();
session.getOutputStream().write(command.getBytes());
InputStream is = session.getInputStream();
Scanner br = new Scanner(new InputStreamReader(is));
String line = null;
int isRunning = 0;
while (br.hasNextLine()) {
line = br.nextLine();
isRunning++;
System.out.println(line);
}
session.close();
}
} catch (SshException | IOException | ChannelOpenException ex) {
Logger.getLogger(Authenticator.class.getName()).log(Level.SEVERE, null, ex);
}
}
我试图用下面的循环替换上面的第二个while循环但没有运气,
try (Reader in = new InputStreamReader(is, "UTF-8")) {
for (;;) {
int rsz = in.read(buffer, 0, buffer.length);
if (rsz < 0)
break;
out.append(buffer, 0, rsz);
}
}
System.out.println(out);
并使用以下循环,但没有运气,
byte[] tmp = new byte[1024];
while (is.available() > 0) {
int i = is.read(tmp, 0, 1024);
if (i < 0) {
break;
}
System.out.print(new String(tmp, 0, i));
}