Java et SSH provoquant des blocages

Question

Je tente d'exécuter quatre commandes sur un serveur distant en Java. Étant donné que les commandes impliquent des exportations, je les ai enchaîné en une seule commande:

rm -f nohup.out && export <a few similar commands> && nohup #here I execute a 
startup script#>nohup.out >nohup.out 2>nohup.err </dev/null & 

Je veux donc attendre un peu (environ 30 secondes) et analyser une adresse IP à partir nohup.out. Le problème que j'ai est que le programme se bloque et ne semble pas casser la connexion - le code de débogage indique qu'il casse quelque part dans le bloc de code ci-dessous, puisqu'il exécute effectivement la commande côté serveur avec succès

Comment puis-je fermer la connexion avec succès?

Le code d'envoi, qui utilise JSch et provient d'une solution mise à jour sur ce site, est le suivant. Il y a une ligne de débogage après celle-ci qui n'est jamais atteinte.

((ChannelExec)channel).setCommand(command); 
    InputStream commandOutput = channel.getInputStream(); 
    channel.connect(); 
    int readByte = commandOutput.read(); 

    while(readByte != 0xffffffff) 
    //while (true) 
    { 
     outputBuffer.append((char)readByte); 
     readByte = commandOutput.read(); 
    } 

Answer 1

J'ai eu des problèmes similaires, avec d'autres types de flux que je lisais (par exemple, les websockets). La plupart du temps, il s'agit de bloquer (read) et de ne pas réagir à l'interruption. Si tel est le cas, vous devrez peut-être forcer la fermeture du canal ou du swith pour ne pas bloquer (peut-être en utilisant available() ou quelque chose comme ça).

Encore mieux au lieu de faire des lectures d'interrogation, vous pouvez simplement spécifier le flux de sortie que vous voulez.

Voici un exemple de travail:

 executor = (ChannelExec) session.openChannel("exec"); 
     executor.setPty(true); 
     executor.setCommand(script); 
     executor.setOutputStream(output); 
     executor.setErrStream(error); 
     executor.connect(); 
     int errorStatus = -1; 

     for (int i = 0; !executor.isClosed(); i++) { 
      if (i > 0) { 
       long delayMs = (long) (200L * Math.pow(i, 2)); 
       Thread.sleep(delayMs); 
      } 
      if ((errorStatus = executor.getExitStatus()) != -1) { 
       break; 
      } 
     } 
     LOGGER.debug("Output: {}", output.toString()); 
     LOGGER.debug("Error: {}", error.toString());