diff --git a/src/main/java/mpms/service/node/ssh/SshService.java b/src/main/java/mpms/service/node/ssh/SshService.java index b6f9f8cefc9878d610f4a0545f77b1d850306017..9acc7a135fc494c0e16549768cc9e1dd5d5a8ec8 100644 --- a/src/main/java/mpms/service/node/ssh/SshService.java +++ b/src/main/java/mpms/service/node/ssh/SshService.java @@ -225,4 +225,24 @@ public class SshService extends BaseOperService implements BaseDynamic JschUtil.close(session); } } + + private String exec(Session session, Charset charset, String command) throws IOException, JSchException { + ChannelExec channel = null; + try { + channel = (ChannelExec) JschUtil.createChannel(session, ChannelType.EXEC); + // 添加环境变量 + channel.setCommand(ServerExtConfigBean.getInstance().getSshInitEnv() + " && " + command); + InputStream inputStream = channel.getInputStream(); + InputStream errStream = channel.getErrStream(); + channel.connect(); + // 读取结果 + String result = IoUtil.read(inputStream, charset); + // + String error = IoUtil.read(errStream, charset); + return result + error; + } finally { + JschUtil.close(channel); + } + } + }