JSch:如何保持会话活着,向上(JSch: How to keep the session ali

2019-08-31 15:36发布

我使用SSH编写Java GUI程序的静态路由管理。 我的代码如下:

import com.jcraft.jsch.*;
import java.io.*;

public class Konsep {
    String status;
    static String username;
    static String hostname;
    String inputcommand;
    String output;
    static Session session;

    JSch jsch = new JSch();

    public String status(String stringstatus) {
        stringstatus = status;
        return stringstatus;
    }

    public String InputCommand(String inputcommandstatus) {
        inputcommandstatus = inputcommand;
        return inputcommandstatus;
    }

    public void connect(String usernamelokal, String hostnamelokal,
            String password, int port) {
        //        JSch jsch=new JSch();
        try {
            Session sessionlokal = jsch.getSession(usernamelokal,
                    hostnamelokal, port);
            sessionlokal.setPassword(password);
            UserInfo ui = new UserInfoku.Infoku();
            sessionlokal.setUserInfo(ui);
            sessionlokal.setTimeout(0);
            sessionlokal.connect();
            status = "tersambung \n";
            username = usernamelokal;
            hostname = hostnamelokal;
            session = sessionlokal;
            System.out.println(username + " " + hostname);
        } catch (Exception e) {
            System.out.println(e);
            status = "Exception = \n " + e + "\n";

        }
    }

    public void disconnect() {
        //        JSch jsch=new JSch();
        try {
            Session sessionlokal = jsch.getSession(username, hostname);
            //            System.out.println(username +" "+ hostname);
            sessionlokal.disconnect();
            status = "wes pedhoott \n";
        } catch (Exception e) {
            System.out.println(e);
            status = "Exception = \n " + e + "\n";
        }

    }

    public void addRoute() {
        //        JSch jsch=new JSch();
        System.out.println(username + " " + hostname);
        try {
            Session sessionlokal = session; // =jsch.getSession(username, hostname);
            Channel channel = sessionlokal.openChannel("exec");
            ((ChannelExec) channel).setCommand(inputcommand);
            channel.setInputStream(null);
            channel.connect();
            ((ChannelExec) channel).setErrStream(System.err);
            InputStream in = channel.getInputStream();
            channel.connect();

            byte[] tmp = new byte[1024];
            while (true) {
                while (in.available() > 0) {
                    int i = in.read(tmp, 0, 1024);
                    if (i < 0)
                        break;
                    System.out.print(new String(tmp, 0, i));
                }
                if (channel.isClosed()) {
                    System.out.println("exit-status: "
                            + channel.getExitStatus());
                    break;
                }
                try {
                    Thread.sleep(1000);
                } catch (Exception ee) {
                }
            }

            channel.disconnect();
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}      

问题是,当我调用connect方法,然后调用addroute,程序返回

root 192.168.50.2
root 192.168.50.2
com.jcraft.jsch.JSchException: session is down

我一直试图让与会话状态要么

Session sessionlokal=session; //returns com.jcraft.jsch.JSchException: ChannelExec

要么

Session sessionlokal=jsch.getSession(username, hostname); //returns session is down

我也试着使用存活,但它不工作要么。

我的目的是创建一个会话到主机(登录),同时保留了会话,执行命令或指令,也许以后执行其他命令,然后关闭其在不需要时(注销)会议。 我一直在寻找在这个论坛上,我发现这个问题,但这些代码是创建一个方法来定义一个命令首先执行,然后创建会话,调用命令的方法,并关闭会话。

有关如何执行正如我上面提到的任何想法?

Answer 1:

尝试后Session.sendKeepAliveMsg()没有成功,我来到了以下解决方案,这似乎是相当稳定:

private Session getSession() throws Exception {
    try {
        if (!session.isConnected()) {
            logger.info("Session nicht konnektiert. Versuche (erneut) zu konnektieren.");
            session.connect();
        }
    } catch (Throwable t) {
        logger.info("Session kaputt. Baue neue.");
        session = jsch.getSession(user, host, port);
        session.setConfig(config);
        session.connect();
    }
    return session;
}

更新:几天后,它失败了。

我试图通过在服务器上杀开会议来测试它。 我测试了这种方式,所有之前的版本显示完全相同的行为,无论惠特问题等待几天或杀死服务器进程后POP操作了,所以我想这个测试 - 以及其对上述方案的结果 - 是有意义的。 不幸的是事实并非如此。

我要去尝试一些其他的方式来解决它,让你及时更新。

更新2:最终的解决方案,guarateed unelegant和工作:

private Session getSession() throws Exception {
    try {
        ChannelExec testChannel = (ChannelExec) session.openChannel("exec");
        testChannel.setCommand("true");
        testChannel.connect();
        if(logger.isDebugEnabled()) {
            logger.debug("Session erfolgreich getestet, verwende sie erneut");
        }
        testChannel.exit();
    } catch (Throwable t) {
        logger.info("Session kaputt. Baue neue.");
        session = jsch.getSession(user, host, port);
        session.setConfig(config);
        session.connect();
    }
    return session;
}

这个版本在生产环境中运行数周。 每天一次我有信息记录此消息。

打开一个通道,并执行一些什么都不做的命令的成本有些烦人,但我发现没有其他办法可以definitly肯定会话的状态。



Answer 2:

您可以通过调用之前调用以下方法尝试会话连接#() 。

活动#setServerAliveInterval(INT毫秒)

虽然我发现多了一个功能活动#sendKeepAliveMsg()可以尝试。



Answer 3:

您可以使用游泳池,我用org.apache.commons.pool2所以池负责提供会话连接,基本的:

  • 创建于makeObject JSCH会议
  • 连接上激活,如果断开
  • 检查是否对验证isConnected
  • sendKeepAliveMsg上钝化

以上为我工作,也请记住,如果你在验证添加的逻辑,poolConfig应testOnBorrow或testOnReturn设置为true。 所以我用KeyedObjectPool你应该从通过borrowObject方法池连接,并确保将其返回到池中,一旦你操作是通过返回object完成。

https://commons.apache.org/proper/commons-pool/api-2.2/org/apache/commons/pool2/PooledObjectFactory.html



文章来源: JSch: How to keep the session alive and up