java 连接ssh2服务器，运行命令，ftp上传文件 返回命令信息

蒋琴韵

需要jdk6 , jsch-0.1.44.jar 如果你的jar 和这个不匹配 命令返回信息 就有问题

       private String host;

private String user;

private String password;

private int port;

private Session session;

/**
* 创建一个连接
* @param host 地址
* @param user 用户名
* @param password 密码
* @param port ssh2端口
*/
public Ssh2Util(String host, String user, String password, int port) {
this.host = host;
this.user = user;
this.password = password;
this.port = port;
}

private void initialSession() throws Exception {
if (session == null) {
JSch jsch = new JSch();
session = jsch.getSession(user, host, port);
session.setUserInfo(new UserInfo() {

public String getPassphrase() {
return null;
}

public String getPassword() {
return null;
}

public boolean promptPassword(String arg0) {
return false;
}

public boolean promptPassphrase(String arg0) {
return false;
}

public boolean promptYesNo(String arg0) {
return true;
}

public void showMessage(String arg0) {
}

});
session.setPassword(password);
session.connect();
}
}

/**
* 关闭连接
* @throws Exception
*/
public void close() throws Exception {
if (session != null && session.isConnected()) {
session.disconnect();
session = null;
}
}

/**
* 上传文件
* @param localPath 本地路径，若为空，表示当前路径
* @param localFile 本地文件名，若为空或是“*”，表示目前下全部文件
* @param remotePath 远程路径，若为空，表示当前路径，若服务器上无此目录，则会自动创建
* @throws Exception
*/
public void putFile(String localPath, String localFile, String remotePath) throws Exception {
this.initialSession();
Channel channelSftp = session.openChannel("sftp");
channelSftp.connect();
ChannelSftp c = (ChannelSftp)channelSftp;
String remoteFile = null;
if (remotePath != null && remotePath.trim().length() > 0) {
try {
c.mkdir(remotePath);
} catch (Exception e) {}
remoteFile = remotePath + "/.";
} else {
remoteFile = ".";
}
String file = null;
if (localFile == null || localFile.trim().length() == 0) {
file = "*";
} else {
file = localFile;
}
if (localPath != null && localPath.trim().length() > 0) {
if (localPath.endsWith("/")) {
file = localPath + file;
} else {
file = localPath + "/" + file;
}
}
c.put(file, remoteFile);

channelSftp.disconnect();
}
//public static void main(String[] args) {
//Ssh2Util ssh = new Ssh2Util("192.168.1.189", "root", "test" , 22);
// try {
//String rs = ssh.runCommand("ddddd");
//} catch (Exception e) {
//e.printStackTrace();
//}
//}
        //command 命令
public String runCommand(String command) throws Exception {
CommonUtil.printLogging("[" + command + "] begin", host, user);

this.initialSession();
InputStream in = null;
InputStream err = null;
BufferedReader inReader = null;
BufferedReader errReader = null;
int time = 0;
String s = null;
boolean run = false;
    StringBuffer sb = new StringBuffer();

Channel channel = session.openChannel("exec");
((ChannelExec) channel).setCommand(command);
channel.setInputStream(null);  
((ChannelExec) channel).setErrStream(null);   
err = ((ChannelExec) channel).getErrStream();
in = channel.getInputStream();  
    channel.connect();  
    inReader = new BufferedReader(new InputStreamReader(in, "UTF-8"));
    errReader = new BufferedReader(new InputStreamReader(err, "UTF-8"));
   
    while (true) {
    s = errReader.readLine();
    if (s != null) {
    sb.append("error:" + s).append("\n");
    } else {
    run = true;
    break;
    }
    }  
while (true) {
s = inReader.readLine();
if (s != null) {
sb.append("info:" + s).append("\n");
} else {
run = true;
    break;
    }
}

while (true) {   
if (channel.isClosed() || run) {
//CommonUtil.printLogging("[" + command + "] finish: " + channel.getExitStatus(), host, user);
break;
}
try {
Thread.sleep(1000);
} catch (Exception ee) {
}
if (time > 180) {
//CommonUtil.printLogging("[" + command + "] finish2: " + channel.getExitStatus(), host, user);
break;
}
time ++;
}

    inReader.close();
    errReader.close();
channel.disconnect();
                session.disconnect();
System.out.println(sb.toString());
return sb.toString();
}