SSH连接远程服务器的一个简单的工程

package com.sep.conn; import java.io.BufferedReader; import java.io.InputStreamReader; import java.util.ArrayList; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelExec; import com.jcraft.jsch.JSch; import com.jcraft.jsch.JSchException; import com.jcraft.jsch.Session; public class Shell { private static final Logger logger = LoggerFactory.getLogger(Shell.class); /** * 远程主机的ip地址 */ private String ip; /** * 远程主机的端口号 */ private int port; /** * 远程主机登录用户名 */ private String username; /** * 远程主机的登录密码 */ private String password; /** * 设置ssh连接的远程端口 */ //public static final int DEFAULT_SSH_PORT = 22; /** * 保存输出内容的容器 */ private List<String> stdout; /** * 初始化登录信息 * @param ip * @param username * @param password */ public Shell(final String ip, final int port, final String username, final String password) { this.ip = ip; this.port = port; this.username = username; this.password = password; stdout = new ArrayList<String>(); } /** * 执行shell命令 * * @param command * @return */ public int execute(final String command) { int returnCode = 0; JSch jsch = new JSch(); MyUserInfo userInfo = new MyUserInfo(); try { // 创建session并且打开连接，因为创建session之后要主动打开连接 Session session = jsch.getSession(username, ip, port); session.setPassword(password); session.setUserInfo(userInfo); session.connect(); // 打开通道，设置通道类型，和执行的命令 Channel channel = session.openChannel("exec"); ChannelExec channelExec = (ChannelExec) channel; channelExec.setCommand(command); channelExec.setInputStream(null); BufferedReader input = new BufferedReader(new InputStreamReader(channelExec.getInputStream())); channelExec.connect(); logger.debug("The remote command is :" + command); // 接收远程服务器执行命令的结果 String line; while ((line = input.readLine()) != null) { stdout.add(line); } input.close(); // 得到returnCode if (channelExec.isClosed()) { returnCode = channelExec.getExitStatus(); } // 关闭通道 channelExec.disconnect(); // 关闭session session.disconnect(); } catch (JSchException e) { logger.error("" + e); } catch (Exception e) { logger.error("" + e); } return returnCode; } /** * get stdout * * @return */ public List<String> getStandardOutput() { return stdout; } public static void main(final String[] args) { Shell shell = new Shell("xxx.xxx.xxx.xxx", 22, "username", "password"); shell.execute("uname -s -r -v"); List<String> stdout = shell.getStandardOutput(); for (String str : stdout) { logger.debug(str); } } }