java远程调用linux的命令或者脚本

转载自：http://eksliang.iteye.com/blog/2105862

 Java通过SSH2协议执行远程Shell脚本(ganymed-ssh2-build210.jar) 

 使用步骤如下：

一、导ganymed-ssh2-build210.jar包

1. <!-- https://mvnrepository.com/artifact/ch.ethz.ganymed/ganymed-ssh2 -->
2.  <dependency>
3.  <groupId>ch.ethz.ganymed</groupId>
4.  <artifactId>ganymed-ssh2</artifactId>
5.  <version>build210</version>
6.  </dependency>​

二、API说明

1.  首先构造一个连接器，传入一个需要登陆的ip地址

Connection conn = new Connection(hostname);

2.  模拟登陆目的服务器 传入用户名和密码 

1. //它会返回一个布尔值，true 代表成功登陆目的服务器，否则登陆失败
2. boolean isAuthenticated = conn.authenticateWithPassword(username, password);​

3.  打开一个session，有点象hibernate的session ，执行你需要的Linux 脚本命令 。

1. Session sess = conn.openSession();
2. sess.execCommand("last");​

4. 接收目标服务器上的控制台返回结果，读取br中的内容

1. InputStream stdout =newStreamGobbler(sess.getStdout());
2. BufferedReader br =newBufferedReader(newInputStreamReader(stdout));​

5.得到脚本运行成功与否的标志 ：0－成功 非0－失败

1. System.out.println("ExitCode: "+ sess.getExitStatus());​

6.关闭session和connection

1.  sess.close();
2.  conn.close();​

 

备注：

1.通过第2步认证成功后，当前目录就位于/home/username/目录之下，你可以指定脚本文件所在的绝对路径，或者通过cd导航到脚本文件所在的目录，然后传递执行脚本所需要的参数，完成脚本调用执行。

 

2.执行脚本以后，可以获取脚本执行的结果文本，需要对这些文本进行正确编码后返回给客户端，避免乱码产生。

 

3.如果你需要执行多个linux控制台脚本，比如第一个脚本的返回结果是第二个脚本的入参，你必须打开多个Session,也就是多次调用

Session sess = conn.openSession();,使用完毕记得关闭就可以了

 

三、实例代码，这个类可以直接拷贝过去用

1. import java.io.BufferedReader;
2. import java.io.IOException;
3. import java.io.InputStream;
4. import java.io.InputStreamReader;
5. import java.io.UnsupportedEncodingException;
6. import org.apache.commons.lang.StringUtils;
7. import ch.ethz.ssh2.Connection;
8. import ch.ethz.ssh2.Session;
9. import ch.ethz.ssh2.StreamGobbler;
11. /**
12. * 远程执行linux的shell script
13. * @author Ickes
14. * @since V0.1
15. */
16. publicclassRemoteExecuteCommand{
17. //字符编码默认是utf-8
18. privatestaticString DEFAULTCHART="UTF-8";
19. privateConnection conn;
20. privateString ip;
21. privateString userName;
22. privateString userPwd;
24. publicRemoteExecuteCommand(String ip,String userName,String userPwd){
25. this.ip = ip;
26. this.userName = userName;
27. this.userPwd = userPwd;
28. }
31. publicRemoteExecuteCommand(){
33. }
35. /**
36. * 远程登录linux的主机
37. * @author Ickes
38. * @since V0.1
39. * @return
40. * 登录成功返回true，否则返回false
41. */
42. publicBoolean login(){
43. boolean flg=false;
44. try{
45. conn =newConnection(ip);
46. conn.connect();//连接
47. flg=conn.authenticateWithPassword(userName, userPwd);//认证
48. }catch(IOException e){
49. e.printStackTrace();
50. }
51. return flg;
52. }
53. /**
54. * @author Ickes
55. * 远程执行shll脚本或者命令
56. * @param cmd
57. * 即将执行的命令
58. * @return
59. * 命令执行完后返回的结果值
60. * @since V0.1
61. */
62. publicString execute(String cmd){
63. String result="";
64. try{
65. if(login()){
66. Session session= conn.openSession();//打开一个会话
67. session.execCommand(cmd);//执行命令
68. result=processStdout(session.getStdout(),DEFAULTCHART);
69. //如果为得到标准输出为空，说明脚本执行出错了
70. if(StringUtils.isBlank(result)){
71. result=processStdout(session.getStderr(),DEFAULTCHART);
72. }
73. conn.close();
74. session.close();
75. }
76. }catch(IOException e){
77. e.printStackTrace();
78. }
79. return result;
80. }
83. /**
84. * @author Ickes
85. * 远程执行shll脚本或者命令
86. * @param cmd
87. * 即将执行的命令
88. * @return
89. * 命令执行成功后返回的结果值，如果命令执行失败，返回空字符串，不是null
90. * @since V0.1
91. */
92. publicString executeSuccess(String cmd){
93. String result="";
94. try{
95. if(login()){
96. Session session= conn.openSession();//打开一个会话
97. session.execCommand(cmd);//执行命令
98. result=processStdout(session.getStdout(),DEFAULTCHART);
99. conn.close();
100. session.close();
101. }
102. }catch(IOException e){
103. e.printStackTrace();
104. }
105. return result;
106. }
108. /**
109. * 解析脚本执行返回的结果集
110. * @author Ickes
111. * @param in 输入流对象
112. * @param charset 编码
113. * @since V0.1
114. * @return
115. * 以纯文本的格式返回
116. */
117. privateString processStdout(InputStreamin,String charset){
118. InputStream stdout =newStreamGobbler(in);
119. StringBuffer buffer =newStringBuffer();;
120. try{
121. BufferedReader br =newBufferedReader(newInputStreamReader(stdout,charset));
122. String line=null;
123. while((line=br.readLine())!=null){
124. buffer.append(line+" ");
125. }
126. }catch(UnsupportedEncodingException e){
127. e.printStackTrace();
128. }catch(IOException e){
129. e.printStackTrace();
130. }
131. return buffer.toString();
132. }
134. publicstaticvoid setCharset(String charset){
135. DEFAULTCHART = charset;
136. }
137. publicConnection getConn(){
138. return conn;
139. }
140. publicvoid setConn(Connection conn){
141. this.conn = conn;
142. }
143. publicString getIp(){
144. return ip;
145. }
146. publicvoid setIp(String ip){
147. this.ip = ip;
148. }
149. publicString getUserName(){
150. return userName;
151. }
152. publicvoid setUserName(String userName){
153. this.userName = userName;
154. }
155. publicString getUserPwd(){
156. return userPwd;
157. }
158. publicvoid setUserPwd(String userPwd){
159. this.userPwd = userPwd;
160. }
161. }

 测试代码：

 

1.  publicstaticvoid main(String[] args){
2. RemoteExecuteCommand rec=newRemoteExecuteCommand("192.168.168.200","root","123456");
3. //执行命令
4. System.out.println(rec.execute("ifconfig"));
5. //执行脚本
6. rec.execute("sh /usr/local/tomcat/bin/statup.sh");
7. //这个方法与上面最大的区别就是，上面的方法，不管执行成功与否都返回，
8. //这个方法呢，如果命令或者脚本执行错误将返回空字符串
9. rec.executeSuccess("ifconfig");
10. }

 

 需要导入的包：

 

1. <!-- https://mvnrepository.com/artifact/ch.ethz.ganymed/ganymed-ssh2 -->
2. <dependency>
3. <groupId>ch.ethz.ganymed</groupId>
4. <artifactId>ganymed-ssh2</artifactId>
5. <version>build210</version>
6. </dependency>
7.  
8. <!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
9. <dependency>
10. <groupId>commons-io</groupId>
11. <artifactId>commons-io</artifactId>
12. <version>2.5</version>
13. </dependency>
14.  
15. <dependency>
16. <groupId>commons-lang</groupId>
17. <artifactId>commons-lang</artifactId>
18. <version>2.6</version>
19. <type>jar</type>
20. <scope>compile</scope>
21. </dependency>

 

 

 

如果是直接通过导jar包的，附百度云盘下载地址：链接：http://pan.baidu.com/s/1c2dr34 密码：g3l7

 

四、注意事项

执行命令的时候，比如：jps，Linux系统因为有环境变量，所以命令正确。但是如果是在java中远程调用Linux命令，

那么必须使用绝对路径，如：/usr/local/java/jdk1.8/bin/jps