JSch連線SSH遠端執行命令
阿新 • • 發佈：2019-01-03
package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
/**
* SSH工具類
*
*/
public class SSHExcuteCommandHelper {
Session session = null;
ChannelExec openChannel = null;
/**
* @param host 主機ip
* @param uname 使用者名稱
* @param upwd 密碼
* @param port ssh埠
*/
public SSHExcuteCommandHelper(String host, String user, String pwd, int port) {
JSch jsch = new JSch();
try {
session = jsch.getSession(user, host, port);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setTimeout(1000);
session.setConfig(config);
session.setPassword(pwd);
} catch (JSchException e) {
e.printStackTrace();
}
}
/**
* 是否連線成功,呼叫如果不需要呼叫execCommand方法那麼必須呼叫 disconnect方法關閉session
* @return
*/
public boolean canConnection(){
try {
session.connect();
return true;
} catch (JSchException e) {
e.printStackTrace();
return false;
}
}
/**
* 關閉連線
*/
public void disconnect(){
if (openChannel != null && !openChannel.isClosed()) {
openChannel.disconnect();
}
if (session != null && session.isConnected()) {
session.disconnect();
}
}
/**
* 執行命令
* @param command
* @return
*/
public String execCommand(String command) {
StringBuffer result = new StringBuffer();
try {
if(!session.isConnected()){
session.connect();
}
openChannel = (ChannelExec) session.openChannel("exec");
openChannel.setCommand(command);
//int exitStatus = openChannel.getExitStatus();
openChannel.connect();
InputStream in = openChannel.getInputStream();
BufferedReader reader = new BufferedReader(
new InputStreamReader(in));
String tmpStr = "";
while ((tmpStr = reader.readLine()) != null) {
result.append(new String(tmpStr.getBytes("gbk"), "UTF-8")).append("\n");
}
} catch (JSchException | IOException e) {
e.printStackTrace();
result.append(e.getMessage());
} finally {
disconnect();
}
return result.toString();
}
/**
* 解析
* @param result
* @return
*/
public List<List<String>> parseResult(String result){
List<List<String>> parseResult = new ArrayList<>();
List<String> list = null;
//
for (String line : result.split("\n")) {
list = new ArrayList<String>();
String[] columns = {};
//這個是針對df命令的 [Mounted on] 其實就一個,如果用空格就會分割出兩個
if(line.contains("Mounted ")){
columns = line.replace("Mounted ", "Mounted-").split(" ");
}else{
columns = line.split(" ");
}
for (String column : columns) {
if (!" ".equals(column) && !"".equals(column)) {
list.add(column);
}
}
parseResult.add(list);
}
return parseResult;
}
public static void main(String args[]) {
SSHExcuteCommandHelper execute = new SSHExcuteCommandHelper("xxxx", "xxxx", "xxxxx", 22);
System.out.println("是否連線成功"+execute.canConnection());
String s = execute.execCommand("df");
System.out.println("解析前");
System.out.println(s);
System.out.println("解析後");
List<List<String>> parseResult = execute.parseResult(s);
for (List<String> l : parseResult) {
System.out.println(l);
}
}
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
/**
* SSH工具類
*
*/
public class SSHExcuteCommandHelper {
Session session = null;
ChannelExec openChannel = null;
/**
* @param host 主機ip
* @param uname 使用者名稱
* @param upwd 密碼
* @param port ssh埠
*/
public SSHExcuteCommandHelper(String host, String user, String pwd, int port) {
JSch jsch = new JSch();
try {
session = jsch.getSession(user, host, port);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setTimeout(1000);
session.setConfig(config);
session.setPassword(pwd);
} catch (JSchException e) {
e.printStackTrace();
}
}
/**
* 是否連線成功,呼叫如果不需要呼叫execCommand方法那麼必須呼叫 disconnect方法關閉session
* @return
*/
public boolean canConnection(){
try {
session.connect();
return true;
} catch (JSchException e) {
e.printStackTrace();
return false;
}
}
/**
* 關閉連線
*/
public void disconnect(){
if (openChannel != null && !openChannel.isClosed()) {
openChannel.disconnect();
}
if (session != null && session.isConnected()) {
session.disconnect();
}
}
/**
* 執行命令
* @param command
* @return
*/
public String execCommand(String command) {
StringBuffer result = new StringBuffer();
try {
if(!session.isConnected()){
session.connect();
}
openChannel = (ChannelExec) session.openChannel("exec");
openChannel.setCommand(command);
//int exitStatus = openChannel.getExitStatus();
openChannel.connect();
InputStream in = openChannel.getInputStream();
BufferedReader reader = new BufferedReader(
new InputStreamReader(in));
String tmpStr = "";
while ((tmpStr = reader.readLine()) != null) {
result.append(new String(tmpStr.getBytes("gbk"), "UTF-8")).append("\n");
}
} catch (JSchException | IOException e) {
e.printStackTrace();
result.append(e.getMessage());
} finally {
disconnect();
}
return result.toString();
}
/**
* 解析
* @param result
* @return
*/
public List<List<String>> parseResult(String result){
List<List<String>> parseResult = new ArrayList<>();
List<String> list = null;
//
for (String line : result.split("\n")) {
list = new ArrayList<String>();
String[] columns = {};
//這個是針對df命令的 [Mounted on] 其實就一個,如果用空格就會分割出兩個
if(line.contains("Mounted ")){
columns = line.replace("Mounted ", "Mounted-").split(" ");
}else{
columns = line.split(" ");
}
for (String column : columns) {
if (!" ".equals(column) && !"".equals(column)) {
list.add(column);
}
}
parseResult.add(list);
}
return parseResult;
}
public static void main(String args[]) {
SSHExcuteCommandHelper execute = new SSHExcuteCommandHelper("xxxx", "xxxx", "xxxxx", 22);
System.out.println("是否連線成功"+execute.canConnection());
String s = execute.execCommand("df");
System.out.println("解析前");
System.out.println(s);
System.out.println("解析後");
List<List<String>> parseResult = execute.parseResult(s);
for (List<String> l : parseResult) {
System.out.println(l);
}
}
}