「javassh连接」javassl

博主:adminadmin 2023-03-18 06:35:09 438

本篇文章给大家谈谈javassh连接,以及javassl对应的知识点,希望对各位有所帮助,不要忘了收藏本站喔。

本文目录一览:

JAVA怎么通过SSH隧道连接数据库查询

在界面中点击【新建】按钮,在Mysql下填写Mysql数据库的ip地址、用户名、密码、端口(默认在3306)就好,数据库名称。这里跟普通的连接数据库的方法一致。

这个时候读者可以点击一下【测试连接】,这个时候点击测试连接去连接数据库是不会成功的,因为数据库配置了SSH访问。如下图:

配置完成Mysql信息后,在旁边选择【SSH】

点击SSH后会弹出一个提示框,点击提示框的【确定】按钮。

点击后勾选“使用SSH隧道”

勾选后下方的配置信息由勾选前的灰色变更为白色可输入状态,在这里配置访问的SSH主机地址、用户名、密码或者公共密匙。

配置完成后来测试配置连接是否正确,点击【测试连接】由于已经配置了正确的SSH访问,这次测试连接成功了。

最后就可以点击界面下方的【连接】按钮,连接上数据库,进行操作了。

怎么用java实现ssh协议通信

import ch.ethz.ssh2.Connection;  

import ch.ethz.ssh2.Session;  

import ch.ethz.ssh2.StreamGobbler;  

import com.io.Debug;  

import java.io.BufferedReader;  

import java.io.IOException;  

import java.io.InputStream;  

import java.io.InputStreamReader;  

import java.io.OutputStream;  

/** 

 * 

 * @author leon.lee 

 */  

public class ChangeEmailPassword {  

    private String username = "";  

    private String oldpassword = "";  

    private Connection conn = ;  

    private boolean hasError = false;  

    private String ErrorMessage = "";  

    private boolean isSuccessfully = false;  

    private String SystemMessage = "";  

      

    public static final String HOST = "127.0.0.1"; //server ip  

    public boolean isSuccessfully(){  

        return isSuccessfully;  

    }  

    public boolean isHasError(){  

        return hasError;  

    }  

    public String getErrorMessage(){  

        return ErrorMessage;  

    }  

    public void setErrorMessage(String msg){  

        hasError = true;  

        this.ErrorMessage =  msg;  

    }  

    /** 

     * Creates a new instance of codeChangeEmailPassword/code. 

     * @param username 

     * @param oldpassword 

     */  

    public ChangeEmailPassword(String username,String oldpassword) {  

        this.username = username;  

        this.oldpassword = oldpassword;  

         try{  

             conn = new Connection(HOST);  

             conn.connect();  

            /* Authenticate */  

            boolean isAuthenticated = conn.authenticateWithPassword(username, oldpassword);  

            if (isAuthenticated == false) {  

                setErrorMessage("Authentication failed.");  

                conn=;  

            }  

         }catch(Exception e){  

             conn.close();  

             conn = ;  

             System.out.println(e);  

         }  

    }  

    public void setNewPassword(String newpassword) {  

        if(hasError){  

            return;  

        }  

        if (conn==){  

            return;  

        }  

        try{  

            Session sess = conn.openSession();  

            sess.execCommand("passwd");  

            InputStream so = sess.getStdout();  

            InputStream err = sess.getStderr();  

            OutputStream out = sess.getStdin();  

              

            byte[] buffer = new byte[500];//其实没有必要这么大.130就差不多了.怕万一有什么提示.  

            int length = 0;  

            length = err.read(buffer);  

//            if (length  0) {  

//                System.out.println("#1:"+ new String(buffer, 0, length));  

//                //(current) UNIX password:  

//            }  

            String coldpassword = oldpassword+"\n";  

            out.write(coldpassword.getBytes());  

            length = err.read(buffer);  

//            if (length  0) {  

//                System.out.println("#2:"+ new String(buffer, 0, length));  

//                //(current) UNIX password:  

//            }  

            String cnewpass = newpassword +"\n";  

            out.write(cnewpass.getBytes());  

            length = err.read(buffer);  

            if (length  0) {  

                String rs = new String(buffer, 0, length);  

                //System.out.println("#3:"+rs);  

                if(rs.indexOf("BAD")-1){  

                    sess.close();  

                    conn.close();  

                    setErrorMessage(rs);  

                    return;  

                }  

            }  

            out.write(cnewpass.getBytes());  

            length = so.read(buffer);  

            if (length  0) {  

                String rs = new String(buffer, 0, length);  

                if(rs.indexOf("successfully")-1){  

                    this.isSuccessfully = true;  

                    this.SystemMessage = rs;  

                }  

            }  

            /* Close this session */  

            sess.close();  

            /* Close the connection */  

            conn.close();  

        } catch (IOException e) {  

            e.printStackTrace(System.err);  

        }  

    }  

    /** 

     * @param args the command line arguments 

     */  

    public static void main(String[] args) {  

        ChangeEmailPassword cep = new ChangeEmailPassword("username", "oldpassword");  

        if(cep.isHasError()){  

            System.out.println(cep.getErrorMessage());  

            cep = ;  

            return;  

        }  

        cep.setNewPassword("newpassword");  

        if(cep.isHasError()){  

            System.out.println(cep.getErrorMessage());  

            cep = ;  

            return;  

        }  

        if(cep.isSuccessfully){  

            System.out.println(cep.getSystemMessage());  

        }  

    }  

    /** 

     * @return the SystemMessage 

     */  

    public String getSystemMessage() {  

        return SystemMessage;  

    }  

}

java通过ssh连接linux怎么设置超时

以下均针对redhat6.5系统进行说明。

一、设置ssh超时断连

使用root用户,编辑/etc/profile文件,在

HOSTNAME='/bin/hostname'

HISTIZE=30

后增加一行

TMOUT=300

其中,300表示超过300秒无操作即断开连接。

设置好之后,所有新建的连接超过5分钟没有操作即断开(当前连接需要断开重连才会生效)。

二、如果已设置了超时断连,如何配置以尽量保持连接:

修改server端的/etc/ssh/sshd_config文件:

ClientAliveInterval 60 #server每隔60秒发送一次请求给client,然后client响应,从而保持连接

ClientAliveCountMax 3 #server发出请求后,客户端没有响应得次数达到3,就自动断开连接,正常情况下,client不会不响应。

java连接ssh登陆路由器

package com.flyingzl.ssh;import java.util.ArrayList

import java.util.Hashtable

import java.util.List

import org.apache.log4j.Logger

import org.apache.oro.text.regex.MalformedPatternException

import com.jcraft.jsch.ChannelShell

import com.jcraft.jsch.JSch

import com.jcraft.jsch.Session

import com.jcraft.jsch.UserInfo

import expect4j.Closure

import expect4j.Expect4j

import expect4j.ExpectState

import expect4j.matches.EofMatch

import expect4j.matches.Match

import expect4j.matches.RegExpMatch

import expect4j.matches.TimeoutMatch

public class Shell {    private static Logger log = Logger.getLogger(Shell.class)

        private Session session

    private ChannelShell channel

    private static Expect4j expect = null

    private static final long defaultTimeOut = 1000

    private StringBuffer buffer=new StringBuffer()

        public static final int COMMAND_EXECUTION_SUCCESS_OPCODE = -2

    public static final String BACKSLASH_R = "\r"

    public static final String BACKSLASH_N = "\n"

    public static final String COLON_CHAR = ":"

    public static String ENTER_CHARACTER = BACKSLASH_R

    public static final int SSH_PORT = 22

        //正则匹配,用于处理服务器返回的结果    public static String[] linuxPromptRegEx = new String[] { "~]#", "~#", "#",            ":~#", "/$", "" }

        public static String[] errorMsg=new String[]{"could not acquire the config lock "}

        //ssh服务器的ip地址    private String ip

    //ssh服务器的登入端口    private int port

    //ssh服务器的登入用户名    private String user

    //ssh服务器的登入密码    private String password

        public Shell(String ip,int port,String user,String password) {        this.ip=ip

        this.port=port

        this.user=user

        this.password=password

        expect = getExpect()

    }        /**     * 关闭SSH远程连接     */    public void disconnect(){        if(channel!=null){            channel.disconnect()

        }        if(session!=null){            session.disconnect()

        }    }        /**     * 获取服务器返回的信息     * @return 服务端的执行结果     */    public String getResponse(){        return buffer.toString()

    }        //获得Expect4j对象,该对用可以往SSH发送命令请求    private Expect4j getExpect() {        try {            log.debug(String.format("Start logging to %s@%s:%s",user,ip,port))

            JSch jsch = new JSch()

            session = jsch.getSession(user, ip, port)

            session.setPassword(password)

            HashtableString, String config = new HashtableString, String()

            config.put("StrictHostKeyChecking", "no")

            session.setConfig(config)

            localUserInfo ui = new localUserInfo()

            session.setUserInfo(ui)

            session.connect()

            channel = (ChannelShell) session.openChannel("shell")

            Expect4j expect = new Expect4j(channel.getInputStream(), channel                    .getOutputStream())

            channel.connect()

            log.debug(String.format("Logging to %s@%s:%s successfully!",user,ip,port))

            return expect

        } catch (Exception ex) {            log.error("Connect to "+ip+":"+port+"failed,please check your username and password!")

            ex.printStackTrace()

        }        return null

    }    /**     * 执行配置命令     * @param commands 要执行的命令,为字符数组     * @return 执行是否成功     */    public boolean executeCommands(String[] commands) {        //如果expect返回为0,说明登入没有成功        if(expect==null){            return false

        }                log.debug("----------Running commands are listed as follows:----------")

        for(String command:commands){            log.debug(command)

        }        log.debug("----------End----------")

                Closure closure = new Closure() {            public void run(ExpectState expectState) throws Exception {                buffer.append(expectState.getBuffer())

// buffer is string                                                        // buffer for appending                                                        // output of executed                                                        // command                expectState.exp_continue()

                            }        }

        ListMatch lstPattern = new ArrayListMatch()

        String[] regEx = linuxPromptRegEx

        if (regEx != null  regEx.length  0) {            synchronized (regEx) {                for (String regexElement : regEx) {// list of regx like, :, /                                                    // etc. it is possible                                                    // command prompts of your                                                    // remote machine                    try {                        RegExpMatch mat = new RegExpMatch(regexElement, closure)

                        lstPattern.add(mat)

                    } catch (MalformedPatternException e) {                        return false

                    } catch (Exception e) {                        return false

                    }                }                lstPattern.add(new EofMatch(new Closure() { // should cause                                                            // entire page to be                                                            // collected                            public void run(ExpectState state) {                            }                        }))

                lstPattern.add(new TimeoutMatch(defaultTimeOut, new Closure() {                    public void run(ExpectState state) {                    }                }))

            }        }        try {            boolean isSuccess = true

            for (String strCmd : commands){                isSuccess = isSuccess(lstPattern, strCmd)

            }            //防止最后一个命令执行不了            isSuccess = !checkResult(expect.expect(lstPattern))

                        //找不到错误信息标示成功            String response=buffer.toString().toLowerCase()

            for(String msg:errorMsg){                if(response.indexOf(msg)-1){                    return false

                }            }                        return isSuccess

        } catch (Exception ex) {            ex.printStackTrace()

            return false

        }    }    //检查执行是否成功    private boolean isSuccess(ListMatch objPattern, String strCommandPattern) {        try {            boolean isFailed = checkResult(expect.expect(objPattern))

            if (!isFailed) {                expect.send(strCommandPattern)

                expect.send("\r")

                return true

            }            return false

        } catch (MalformedPatternException ex) {            return false

        } catch (Exception ex) {            return false

        }    }    //检查执行返回的状态    private boolean checkResult(int intRetVal) {        if (intRetVal == COMMAND_EXECUTION_SUCCESS_OPCODE) {            return true

        }        return false

    }        //登入SSH时的控制信息    //设置不提示输入密码、不显示登入信息等    public static class localUserInfo implements UserInfo {        String passwd

        public String getPassword() {            return passwd

        }        public boolean promptYesNo(String str) {            return true

        }        public String getPassphrase() {            return null

        }        public boolean promptPassphrase(String message) {            return true

        }        public boolean promptPassword(String message) {            return true

        }        public void showMessage(String message) {                    }    }}

Java中的“SSH”是什么?

SSH为struts+spring+hibernate的一个集成框架,是目前较流行的一种Web应用程序开源框架。\x0d\x0a集成SSH框架的系统从职责上分为四层:表示层、业务逻辑层、数据持久层和域模块层,以帮助开发人员在短期内搭建结构清晰、可复用性好、维护方便的Web应用程序。其中使用Struts作为系统的整体基础架构,负责MVC的分离,在Struts框架的模型部分,控制业务跳转,利用Hibernate框架对持久层提供支持,Spring做管理,管理struts和hibernate。具体做法是:用面向对象的分析方法根据需求提出一些模型,将这些模型实现为基本的Java对象,然后编写基本的DAO(DataAccessObjects)接口,并给出Hibernate的DAO实现,采用Hibernate架构实现的DAO类来实现Java类与数据库之间的转换和访问,最后由Spring做管理,管理struts和hibernate。\x0d\x0a具体内容包括:\x0d\x0aStruts\x0d\x0aStruts对Model,View和Controller都提供了对应的组件。\x0d\x0aActionServlet,这个类是Struts1的核心控制器,负责拦截来自用户的请求。\x0d\x0aAction,这个类通常由用户提供,该控制器负责接收来自ActionServlet的请求,并根据该请求调用模型的业务逻辑方法处理请求,并将处理结果返回给JSP页面显示。\x0d\x0aModel部分:\x0d\x0a由ActionForm和JavaBean组成,其中ActionForm用于将用户的请求参数封装成ActionForm对象,该对象被ActionServlet转发给Action,Action根据ActionForm里面的请求参数处理用户的请求。\x0d\x0aJavaBean则封装了底层的业务逻辑,包括数据库访问等。\x0d\x0aView部分:\x0d\x0a该部分采用JSP(或HTML、PHP??)实现。\x0d\x0aStruts提供了丰富的标签库,通过标签库可以减少脚本的使用,自定义的标签库可以实现与Model的有效交互,并增加了现实功能。对应上图的JSP部分。\x0d\x0aController组件:\x0d\x0aController组件有两个部分组成——系统核心控制器,业务逻辑控制器。\x0d\x0a系统核心控制器,对应上边的ActionServlet。该控制器继承了HttpServlet类,因此可以配置成标注的Servlet。该控制器负责拦截所有的HTTP请求,然后根据用户请求决定是否要转给业务逻辑控制器。\x0d\x0a业务逻辑控制器,负责处理用户请求,本身不具备处理能力,而是调用Model来完成处理。对应Action部分。\x0d\x0aStruts2是Struts的下一代产品,是在struts1和WebWork的技术基础上进行了合并的全新的Struts2框架。其全新的Struts2的体系结构与Struts1的体系结构差别巨大。Struts2以WebWork为核心,采用拦截器的机制来处理用户的请求,这样的设计也使得业务逻辑控制器能够与ServletAPI完全脱离开,所以Struts2可以理解为WebWork的更新产品。虽然从Struts1到Struts2有着太大的变化,但是相对于WebWork,Struts2的变化很小。\x0d\x0a\x0d\x0aSpring\x0d\x0aSpring是一个开源框架,它由RodJohnson创建。它是为了解决企业应用开发的复杂性而创建的。Spring使用基本的JavaBean来完成以前只可能由EJB完成的事情。然而,Spring的用途不仅限于服务器端的开发。从简单性、可测试性和松耦合的角度而言,任何Java应用都可以从Spring中受益。\x0d\x0a目的:解决企业应用开发的复杂性\x0d\x0a功能:使用基本的JavaBean代替EJB,并提供了更多的企业应用功能\x0d\x0a范围:任何Java应用\x0d\x0a简单来说,Spring是一个轻量级的控制反转(IoC)和面向切面(AOP)的容器框架。\x0d\x0a轻量——从大小与开销两方面而言Spring都是轻量的。完整的Spring框架可以在一个大小只有1MB多的JAR文件里发布。并且Spring所需的处理开销也是微不足道的。此外,Spring是非侵入式的:典型地,Spring应用中的对象不依赖于Spring的特定类。\x0d\x0a控制反转——Spring通过一种称作控制反转(IoC)的技术促进了松耦合。当应用了IoC,一个对象依赖的其它对象会通过被动的方式传递进来,而不是这个对象自己创建或者查找依赖对象。你可以认为IoC与JNDI相反——不是对象从容器中查找依赖,而是容器在对象初始化时不等对象请求就主动将依赖传递给它。\x0d\x0a面向切面——Spring提供了面向切面编程的丰富支持,允许通过分离应用的业务逻辑与系统级服务(例如审计(auditing)和事务(transaction)管理)进行内聚性的开发。应用对象只实现它们应该做的——完成业务逻辑——仅此而已。它们并不负责(甚至是意识)其它的系统级关注点,例如日志或事务支持。\x0d\x0a容器——Spring包含并管理应用对象的配置和生命周期,在这个意义上它是一种容器,你可以配置你的每个bean如何被创建——基于一个可配置原型(prototype),你的bean可以创建一个单独的实例或者每次需要时都生成一个新的实例——以及它们是如何相互关联的。然而,Spring不应该被混同于传统的重量级的EJB容器,它们经常是庞大与笨重的,难以使用。\x0d\x0a框架——Spring可以将简单的组件配置、组合成为复杂的应用。在Spring中,应用对象被声明式地组合,典型地是在一个XML文件里。Spring也提供了很多基础功能(事务管理、持久化框架集成等等),将应用逻辑的开发留给了你。\x0d\x0a所有Spring的这些特征使你能够编写更干净、更可管理、并且更易于测试的代码。它们也为Spring中的各种模块提供了基础支持。\x0d\x0a\x0d\x0aHibernate\x0d\x0aHibernate是一个开放源代码的对象关系映射框架,它对JDBC进行了非常轻量级的对象封装,使得Java程序员可以随心所欲的使用对象编程思维来操纵数据库。Hibernate可以应用在任何使用JDBC的场合,既可以在Java的客户端程序使用,也可以在Servlet/JSP的Web应用中使用,最具革命意义的是,Hibernate可以在应用EJB的J2EE架构中取代CMP,完成数据持久化的重任。\x0d\x0aHibernate的核心接口一共有5个,分别为:Session、SessionFactory、Transaction、Query和Configuration。这5个核心接口在任何开发中都会用到。通过这些接口,不仅可以对持久化对象进行存取,还能够进行事务控制。下面对这五个核心接口分别加以介绍。\x0d\x0a·Session接口:Session接口负责执行被持久化对象的CRUD操作(CRUD的任务是完成与数据库的交流,包含了很多常见的SQL语句。)。但需要注意的是Session对象是非线程安全的。同时,Hibernate的session不同于JSP应用中的HttpSession。这里当使用session这个术语时,其实指的是Hibernate中的session,而以后会将HttpSession对象称为用户session。\x0d\x0a·SessionFactory接口:SessionFactory接口负责初始化Hibernate。它充当数据存储源的代理,并负责创建Session对象。这里用到了工厂模式。需要注意的是SessionFactory并不是轻量级的,因为一般情况下,一个项目通常只需要一个SessionFactory就够,当需要操作多个数据库时,可以为每个数据库指定一个SessionFactory。\x0d\x0a·Configuration接口:Configuration接口负责配置并启动Hibernate,创建SessionFactory对象。在Hibernate的启动的过程中,Configuration类的实例首先定位映射文档位置、读取配置,然后创建SessionFactory对象。\x0d\x0a·Transaction接口:Transaction接口负责事务相关的操作。它是可选的,开发人员也可以设计编写自己的底层事务处理代码。\x0d\x0a·Query和Criteria接口:Query和Criteria接口负责执行各种数据库查询。它可以使用HQL语言或SQL语句两种表达方式。

关于javassh连接和javassl的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。