java 远程调用shell脚本demo代码,Java代码库,德仔网

代码语言

代码分类

【Java】 java 远程调用shell脚本demo

作者: / 发布于2017/12/19/ 416

首先在远程服务器上编写一个测试脚本test.sh,并赋予可执行权限：chmod +x test.sh

#!/bin/bash  
echo 'test22'  
echo $1  

$1是脚本传进来的第一个参数，我们控制台打印一下这个参数
 
新建maven项目，添加依赖：

<dependency>  
    <groupId>org.jvnet.hudson</groupId>  
    <artifactId>ganymed-ssh2</artifactId>  
    <version>build210-hudson-1</version>  
</dependency>  

编写一个工具类：

package com.xj.runshell;  
  
import java.io.IOException;  
import java.io.InputStream;  
import java.nio.charset.Charset;  
  
import ch.ethz.ssh2.Connection;  
import ch.ethz.ssh2.Session;  
  
public class RemoteShellTool {  
  
    private Connection conn;  
    private String ipAddr;  
    private String charset = Charset.defaultCharset().toString();  
    private String userName;  
    private String password;  
  
    public RemoteShellTool(String ipAddr, String userName, String password,  
            String charset) {  
        this.ipAddr = ipAddr;  
        this.userName = userName;  
        this.password = password;  
        if (charset != null) {  
            this.charset = charset;  
        }  
    }  
  
    public boolean login() throws IOException {  
        conn = new Connection(ipAddr);  
        conn.connect(); // 连接  
        return conn.authenticateWithPassword(userName, password); // 认证  
    }  
  
    public String exec(String cmds) {  
        InputStream in = null;  
        String result = "";  
        try {  
            if (this.login()) {  
                Session session = conn.openSession(); // 打开一个会话  
                session.execCommand(cmds);  
                  
                in = session.getStdout();  
                result = this.processStdout(in, this.charset);  
                session.close();  
                conn.close();  
            }  
        } catch (IOException e1) {  
            e1.printStackTrace();  
        }  
        return result;  
    }  
  
    public String processStdout(InputStream in, String charset) {  
      
        byte[] buf = new byte[1024];  
        StringBuffer sb = new StringBuffer();  
        try {  
            while (in.read(buf) != -1) {  
                sb.append(new String(buf, charset));  
            }  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
        return sb.toString();  
    }  
  
    /** 
     * @param args 
     */  
    public static void main(String[] args) {  
  
        RemoteShellTool tool = new RemoteShellTool("192.168.27.41", "hadoop",  
                "hadoop", "utf-8");  
  
        String result = tool.exec("./test.sh xiaojun");  
        System.out.print(result);  
  
    }  
  
}

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

同语言下

可能有用的

贡献的其它代码Label