JSch: Как сохранить сеанс в живых и вверх
Я пишу программу Java GUI для статического управления маршрутами с помощью SSH. Мой код выглядит следующим образом:
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
Я также пытался использовать keepalive, но он также не работает.
Я намерен создать сеанс для хоста (вход в систему), оставив сеанс, выполнить команду или команды и, возможно, выполнить другие команды позже, а затем закрыть сеанс, когда он не понадобится (выйти из системы).
Я искал этот форум, и я нашел этот question, но код создает метод для определения команды для выполнения сначала, а затем создания сеанса, вызовите метод команды и закройте сеанс.
Любые идеи о том, как поступать, как я упоминал выше?
Ответы
Ответ 1
Попробовав Session.sendKeepAliveMsg()
безуспешно, я пришел к следующему решению, которое кажется довольно стабильным:
private Session getSession() throws Exception {
try {
if (!session.isConnected()) {
logger.info("Session successfully tested, use it again.");
session.connect();
}
} catch (Throwable t) {
logger.info("Session terminated. Create a new one.");
session = jsch.getSession(user, host, port);
session.setConfig(config);
session.connect();
}
return session;
}
Обновление: Через несколько дней это не удалось.
Я попытался проверить это, убив открытую сессию на сервере. Все предыдущие версии, которые я тестировал таким образом, демонстрировали одно и то же поведение, независимо от того, возникла ли проблема после нескольких дней ожидания или уничтожения серверного процесса, поэтому я подумал, что этот тест - и его результаты для вышеуказанного решения - имеют смысл. К сожалению, это не так.
Я собираюсь попробовать другие способы исправить это и держать вас в курсе.
Обновление 2: окончательное решение, гарантированное не изящное и работающее:
private Session getSession() throws Exception {
try {
ChannelExec testChannel = (ChannelExec) session.openChannel("exec");
testChannel.setCommand("true");
testChannel.connect();
if(logger.isDebugEnabled()) {
logger.debug("Session successfully tested, use it again.");
}
testChannel.exit();
} catch (Throwable t) {
logger.info("Session terminated. Create a new one.");
session = jsch.getSession(user, host, port);
session.setConfig(config);
session.connect();
}
return session;
}
Эта версия работает несколько недель в продуктивной среде. Один раз в день у меня регистрируется информационное сообщение.
Затраты на открытие канала и выполнение какой-либо команды "ничего не делать" несколько раздражают, но я не нашел другого способа быть уверенным в состоянии сеанса.
Ответ 2
Вы можете попробовать, вызвав следующий метод перед вызовом Session # connect().
Session # setServerAliveInterval (int миллисекунд)
Хотя я нашел еще одну функцию Session # sendKeepAliveMsg(), которую можно попробовать.
Ответ 3
Вы можете использовать пул, я использовал org.apache.commons.pool2, поэтому пул отвечает за предоставление подключенных сеансов, в основном:
- Создание сессии АОH по makeObject
- подключиться при активации, если отключен
- проверьте, если isConnected при проверке
- sendKeepAliveMsg при пассивации
Выше работали для меня, также имейте в виду, что если вы добавите логику для проверки, poolConfig должен установить true на testOnBorrow или testOnReturn. Поэтому я использовал KeyedObjectPool, вы должны получить соединения из пула с помощью метода loanObject и убедиться, что вы вернете их в пул после завершения операции через returnObject.
https://commons.apache.org/proper/commons-pool/api-2.2/org/apache/commons/pool2/PooledObjectFactory.html