这个非常简单，基本原理先通过ssh连接远程Linux主机，然后执行shell命令，获取返回结果，下面我简单介绍一下实现过程，主要内容如下：
1.首先，需要在maven中导入程序所依赖的Jar包，这个直接在pom.xml文件中输入就行，如下：
2.接着就可以用Java编程来实现远程连接Linux主机并执行shell命令或脚本了，主要步骤及截图如下：
首先，导入程序所依赖的包，初始化成员变量，这里定义了一个ExecuteShell类，创建对象时，需要输入IP地址、用户名和密码这3个参数，用于后面ssh连接远程Linux主机，代码如下，非常简单：
接着就是远程连接Linux主机了，测试代码如下，很好理解，创建一个Connection连接，如果连接成功，则返回true，失败则返回false：
连接成功后，我们就可以直接执行Linux shell脚本或命令了，测试代码如下，非常简单，打开一个Session会话，然后执行shell命令或脚本，返回执行结果：
processStdout函数代码如下，主要是取得shell命令和脚本返回的结果，代码如下：
最后，在main函数中创建ExecuteShell类对象，调用execute函数执行shell命令或脚本就行，如下：
点击运行程序，截图如下，已经成功执行shell，并取得返回的结果：
至此，我们就完成了利用Java来远程调用Linux命令或shell脚本。总的来说，整个过程非常简单，代码量也不多，很好理解，只要你有一定的Java基础，熟悉一下上面的代码和示例，多调试几遍程序，很快就能掌握的，网上也有相关教程和资料，非常丰富详细，感兴趣的话，可以搜一下，希望以上分享的内容能对你有所帮助吧，也欢迎大家评论、留言进行补充。
评论0
加载中...
1.导入maven依赖jar包
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>build210</version>
</dependency>
2.编辑相应Java代码
package com.ksy.fw.base.util;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import org.apache.commons.lang.StringUtils;
import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;
import ch.ethz.ssh2.StreamGobbler;
/**
* 远程执行linux的shell script
*/
public class RemoteExecuteCommand {
//字符编码默认是utf-8
private static String DEFAULTCHART="UTF-8";
private Connection conn;
private String ip;
private String userName;
private String userPwd;
public RemoteExecuteCommand(String ip, String userName, String userPwd) {
this.ip = ip;
this.userName = userName;
this.userPwd = userPwd;
}
public RemoteExecuteCommand() {
}
/**
* 远程登录linux的主机
* @return
* 登录成功返回true，否则返回false
*/
public Boolean login(){
boolean flg=false;
try {
conn = new Connection(ip);
conn.connect();//连接
flg=conn.authenticateWithPassword(userName, userPwd);//认证
} catch (IOException e) {
e.printStackTrace();
}
return flg;
}
/**
* 远程执行shll脚本或者命令
* @param cmd 即将执行的命令
* @return 命令执行完后返回的结果值
*/
public String execute(String cmd){
String result="";
try {
if(login()){
Session session= conn.openSession();//打开一个会话
session.execCommand(cmd);//执行命令
result=processStdout(session.getStdout(),DEFAULTCHART);
//如果为得到标准输出为空，说明脚本执行出错了
if(StringUtils.isBlank(result)){
result=processStdout(session.getStderr(),DEFAULTCHART);
}
conn.close();
session.close();
}
} catch (IOException e) {
e.printStackTrace();
}
return result;
}
/**
* 远程执行shll脚本或者命令
* @param cmd 即将执行的命令
* @return 命令执行成功后返回的结果值，如果命令执行失败，返回空字符串，不是null
*/
public String executeSuccess(String cmd){
String result="";
try {
if(login()){
Session session= conn.openSession();//打开一个会话
session.execCommand(cmd);//执行命令
result=processStdout(session.getStdout(),DEFAULTCHART);
conn.close();
session.close();
}
} catch (IOException e) {
e.printStackTrace();
}
return result;
}
/**
* 解析脚本执行返回的结果集
* @param in 输入流对象
* @param charset 编码
* @return 以纯文本的格式返回
*/
private String processStdout(InputStream in, String charset){
InputStream stdout = new StreamGobbler(in);
StringBuffer buffer = new StringBuffer();;
try {
BufferedReader br = new BufferedReader(new InputStreamReader(stdout,charset));
String line=null;
while((line=br.readLine()) != null){
buffer.append(line+" ");
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return buffer.toString();
}
public static void setCharset(String charset) {
DEFAULTCHART = charset;
}
public Connection getConn() {
return conn;
}
public void setConn(Connection conn) {
this.conn = conn;
}
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getUserPwd() {
return userPwd;
}
public void setUserPwd(String userPwd) {
this.userPwd = userPwd;
}
public static void main(String[] args) {
RemoteExecuteCommand rec=new RemoteExecuteCommand("127.0.0.1", "root","root");
//执行命令
System.out.println(rec.execute("chmod 777 /usr/ksybak/myshell/tomcat-fw.sh"));
System.out.println(rec.execute("/usr/ksybak/myshell/tomcat-fw.sh"));
//System.out.println(rec.execute("/usr/ksybak/myshell/tomcat-fw.sh"));
//执行脚本
//rec.execute("sh /usr/local/tomcat/bin/statup.sh");
//这个方法与上面最大的区别就是，上面的方法，不管执行成功与否都返回，
//这个方法呢，如果命令或者脚本执行错误将返回空字符串
//System.out.println(rec.executeSuccess("ifconfig"));
}
}
评论0
加载中...
0
回答0
回答0
回答0
回答0
回答0
回答0
回答0
回答3
回答0
回答
