秘钥登录服务器执行shell脚本

import com.jcraft.jsch.*;
import org.slf4j.LoggerFactory;
 java.io.BufferedReader;
 java.io.IOException;
 java.io.InputStream;
 java.io.InputStreamReader;
 java.nio.charset.Charset;
 java.util.Properties;

/**
 * @author 
 *    秘钥形式登录服务器执行shell脚本操作
 */
public class ExecuteShellWithKey {

    
     * slf4j
     */

    private final static org.slf4j.Logger logger = LoggerFactory.getLogger(ExecuteShellWithKey.);
    private Session session;

    
     * 远程连接Linux 服务器 执行相关的命令
     *
     * @param keyFile    秘钥文件
     *  userName   用户名
     *  passphrase 重置后密码
     *  host       主机ip
     *  cmd        执行shell调用命令
     * @throws JSchException
     *  IOException
     */
    void runShell(String keyFile,String userName,String passphrase,String host,String cmd) {
        if (!connect(keyFile,userName,passphrase,host)) {
            return;
        }
        ChannelExec channelExec = null;
        BufferedReader reader = ;
        try {
            channelExec = (ChannelExec) session.openChannel("exec");
            channelExec.setCommand(cmd);
            channelExec.setInputStream();
            channelExec.setErrStream(System.err);
            channelExec.connect();
            InputStream in = channelExec.getInputStream();
            reader = new BufferedReader(new InputStreamReader(in,Charset.forName("UTF-8")));
            String buf = ;
            StringBuffer sb = new StringBuffer();
            while ((buf = reader.readLine()) != ) {
                sb.append(buf);
                // 输出每个命令执行后，返回数据
                logger.info(sb.toString());
            }
        } catch (JSchException e) {
            e.printStackTrace();
        }  (IOException e) {
            e.printStackTrace();
        } finally {
             {
                if (reader != ) {
                    reader.close();
                }
            }  (IOException e) {
                e.printStackTrace();
            }
            if (channelExec != ) {
                channelExec.disconnect();
            }
            if (null != session) {
                session.disconnect();
            }
        }
    }

    
     * 连接到指定的HOST
     *
     *  keyFile
     *  userName
     *  passphrase
     *  host
     *  JSchException
     boolean connect(String keyFile,String host) {
         创建JSch对象
        JSch jsch =  JSch();
         引入秘钥文件       
            jsch.addIdentity(keyFile);
             根据用户名，主机ip，端口获取一个Session对象
            session = jsch.getSession(userName,host,22);
            UserInfo ui =  MyUserInfo(passphrase);
            session.setUserInfo(ui);
             设置密码
            session.setPassword(passphrase);
            Properties config =  Properties();
            config.put("StrictHostKeyChecking","no");
             为Session对象设置properties
            session.setConfig(config);
            int timeout = 60000000;
             设置timeout时间
            session.setTimeout(timeout);
             通过Session建立链接
            session.connect();
        }  (JSchException e) {
            e.printStackTrace();
            logger.error("connect error !"return false;
        }
        true;
    }

    class MyUserInfo implements UserInfo {
        private String passphrase = ;

        public MyUserInfo(String passphrase) {
            this.passphrase = passphrase;
        }

         String getPassphrase() {
             String getPassword() {
            ;
        }

         promptPassphrase(String s) {
             promptPassword(String s) {
             promptYesNo(String s) {
             showMessage(String s) {
            logger.info(s);
        }
    }
}