Channel'In/Out'putStream problème

Logiciel & apps Programmation
1

Bonjour,

Actuellement je développe un outil en JAVA, qui va me permettre d’envoyer via SSH des commandes Telnet à partir d’un poste distant. J’utilise l’API J2SSH/SSHTools qui me permet de me connecter en SSH. Sur ce point tout fonctionne, à part la base de mon programme qui est d’envoyer des commandes via le flux de données Output.

Deuxiemement, je n’arrive pas très bien à lire ce que je recois dans mon flux Input, étant donné que la fonction read() renvoie un tableau de int :s

Voici les liens des docs pour les différentes classes Output et Input :
ChannelOutputStream
ChannelInputStream

public static void run(String from, String to, String hostClient, String pool, String helo, String hostTarantel, String user, String pass) throws IOException
	{
		//C'est dans cette fonction que va se passer tout le mécanisme de connexion en SSH, et d'envoie du mail
		ConfigurationLoader.initialize(false);
		
		System.out.println("Host : " + hostTarantel + " Username : " + user + " Password : " + pass);
		
		//On créer une connection SSH
		SshClient ssh = new SshClient();
		
		//On connecte le client ssh, avec l'ip de tarantella, et une clé
		IgnoreHostKeyVerification verif = new IgnoreHostKeyVerification();
		ssh.connect(hostTarantel, verif);
		
		//On récupere les identifiants de connexion de tarantella
		PasswordAuthenticationClient pwd = new PasswordAuthenticationClient();
		pwd.setUsername(user);
		pwd.setPassword(pass);
		
		//on regarde si tout c'est bien passer
		int result = ssh.authenticate(pwd);
		
		
		if(result == AuthenticationProtocolState.COMPLETE)// si oui, on peut ouvrir un channel
		{
			System.out.println("authentifation réussie");
			ForwardingIOChannel channel = new ForwardingIOChannel(ForwardingIOChannel.LOCAL_FORWARDING_CHANNEL,"tarantella",hostTarantel,22,"myhost",22);
			
			if(ssh.openChannel(channel))//si le channel c'est bien ouvert, on envoie les requetes au serveur tarantella
			{
				//toutes les commandes nécessaires sont ici
				String [] commande = {"ssh " + pool, pass, "telnet " + hostClient + " 25", "helo " + helo, "mail from: " + from, "rcpt to: " + to, "data", "Ceci est un mail test de Orange Business Service, merci de ne pas en tenir compte.", ".", "quit"};
				
				
				System.out.println("channel ouvert");
				ChannelOutputStream out = channel.getOutputStream();
				ChannelInputStream in = channel.getInputStream();
				
				try {
					Thread.sleep(3000);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
				for(int i = 0; i <commande.length; i++)
				{
					try{
					Interface.Jbody.append(commande[i] + "\n");
					System.out.println(commande[i]);
					byte[] requete = commande[i].getBytes();
					out.write(requete);
					/*while(in.read() != -1){
						
						System.out.println(in.read());}*/
					System.out.println("i = " + i);
					}catch (IOException e){System.out.println("erreur");};
				}
				channel.close();
			}
			else 
				System.out.println("Channel pas ouvert");
			
			//ssh.close();
				
		}//if
	}//run()
2

Je te réponds comme ça de tête vite fais.
Mais il me semble qu’il existe des classes BufferedInputStream et BufferedOutputStream qui permet de faire du writeLine et du readLine, donc d’envoyé et de récupérer des String et donc tes commandes seront plus facile à faire transiter.
Sinon à la place dans ton flux, tu dois pouvoir faire transiter une tableau de bytes à partir du quel tu peux reconstruire une string

outputstream.write(maStringSortante.getBytes());
maStringEntrante = new string(inputstream.readBytes());

je suis pas sur de la syntaxe mais tu as le principe avec ça

3

Le probleme du read() avec l’api SShTools c’est qu’il renvoie un tableau de bytes.
Enfin je pense que ce n’est pas très adéquat, j’ai donc essayer avec des classes BufferedReader et PrintWriter, pour les flux d’entrée et de sortie.
Alors, en premier, le in.read() renvoie des int :s problématique à lire, et aussi il plante, il s’arrete et fait buguer le programme je ne sais pas pourquoi …

Voila comment j’ai écrit :

//toutes les commandes nécessaires sont ici
				String [] commande = {"ssh " + pool, pass, "telnet " + hostClient + " 25", "helo " + helo, "mail from: " + from, "rcpt to: " + to, "data", "Ceci est un mail test de Orange Business Service, merci de ne pas en tenir compte.", ".", "quit"};
				System.out.println("channel ouvert");
				
				Socket sconx = new Socket(hostTarantel, 22);
				
				BufferedReader in = new BufferedReader(new InputStreamReader(sconx.getInputStream()));
				PrintWriter out = new PrintWriter(new OutputStreamWriter(sconx.getOutputStream())); 
				
				try {
					Thread.sleep(3000);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
				for(int i = 0; i <commande.length; i++)
				{
					Interface.Jbody.append(commande[i] + "\n");
					System.out.println(commande[i]);
					
					out.write(commande[i]);
					while(in.read() != -1)
					{
						System.out.println(in.read());
					}
		
					System.out.println("i = " + i);;
				}
				
				
				channel.close();
4

bonjour,

voila j’avance dans mon projet, un peu, donc j’ai écrit de nouvelle chose qui me semble plutot bonne, mais je me heurte à un probleme.

Voila mon code

try{
					sconx = new Socket(hostTarantel, 25);
					if(sconx == null)
						System.out.println("Socket echoué");
					
					in = new BufferedReader(new InputStreamReader(sconx.getInputStream()));
					out = new OutputStreamWriter(sconx.getOutputStream());
					if(in == null || out == null)
						System.out.println("Flux échoué");
					
					trace(response = in.readLine());
					if(!response.startsWith("220"))
						System.out.println("Serveur invalide");
					
					String command;
					
					command = commande[0]; //ssh
				      out.write(command + "\r\n");
				      out.flush();
				      trace(command);
				      trace(response = in.readLine());
                                      
                                      sconx.close();
				      sconx = null;
				      
				}catch(IOException ioe) {System.out.println("Erreur Exception IO");}

voila en fait quand je met le Socket sur le port 25 il met sort : Une exception IO
Et si je met le port 22 (pour une connexion SSH) sur Socket, il me dit : Serveur Invalide avant meme que je fasse une commande

Donc la je ne sais pas trop quoi mettre ?

Merci de ton aide