首页 / JAVA / java使用ssh远程操作linux 提交spark jar

java使用ssh远程操作linux 提交spark jar

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java使用ssh远程操作linux 提交spark jar，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2132字，纯文字阅读大概需要4分钟。

内容图文

maven依赖
<!--Java ssh-2 -->
<dependency>
    <groupId>ch.ethz.ganymed</groupId>
    <artifactId>ganymed-ssh2</artifactId>
    <version>262</version>
</dependency>
            
                
import
             ch.ethz.ssh2.Connection;

            import
             ch.ethz.ssh2.Session;


            import
             java.io.IOException;

            import
             java.io.InputStream;

            import
             java.nio.charset.Charset;



            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;
        }
    }
    publicboolean 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);
                conn.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return result;
    }

    public String processStdout(InputStream in, String charset) {
        byte[]  buffer = newbyte[1024];
        StringBuffer sb = new StringBuffer();
        try {
            while (in.read(buffer)!=-1){
                sb.append(new String(buffer,charset));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return  sb.toString();
    }

    publicstaticvoid main(String[] args) {
//将jar包命名为task任务，根据传入taskid 找到对应的jar包 调用接口提交
//      args[0]="{1}";
        RemoteShellTool rst = new RemoteShellTool("bigdata.server1","hejunhong","123456","utf-8");
        System.out.println(rst.exec("/opt/cdh5/hadoop-2.5.0-cdh5.3.6/sbin/hadoop-daemon.sh start datanode"));
        System.out.println(rst.exec("ls /opt/cdh5/"));
//String submit="/opt/cdh5/spark-2.2.1-bin-2.6.0-cdh5.14.2/bin/spark-submit --master yarn --deloy-modle cluster" +
//        "--class spark.jar  hdfs://  "+args[0]+ " --conf  spark.ssss:20";    }
}

 

原文：https://www.cnblogs.com/hejunhong/p/10343513.html

内容总结

以上是互联网集市为您收集整理的java使用ssh远程操作linux 提交spark jar全部内容，希望文章能够帮你解决java使用ssh远程操作linux 提交spark jar所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1288155.html

来源：【匿名】