Thread zu langsam ==> kann doch nicht sein oder?

[chris1507]

Hallo,

ich habe hab folgendes Problem und benötige mal ne neue Idee. Ich habe eine Application geschrieben welche über Sockets über den Port 23 Nachrichten sendet. Um die Nachrichten zu empfangen habe ich ein Thread eingesetzt. Was auch einwandfrei so funktoniert.

Nun möchte ich die Application mittels einer Schleife dazu bringen sequentiell nacheinander Verbindungen zu verschiedenen Adressen aufzubauen um dort die Kommandos auszuführen.

Das Problem ist nun das meine Application tadellos im Debug Modus funktoniert wenn ich sie selber Schritt für Schritt durchführe.

Wenn ich allerdings die Application im normalen Betrieb starte, connectet er nur zum erster Adresse und führt da die Kommandos aus und bei den anderen passiert nichts.

Warum ist mir schleierhaft. Ist der eingetzte Thread zu langsam???

Irgendwo muss ich vermutlich einen Wartepunkt einbauen, was aber nich genau wo.

Hier mal der Code:

Hauptklasse:

import java.io.IOException;
import java.io.*;
import java.net.*;

public class Telnetcon 
{	
	public static String host[]={"172.30.230.5","172.30.244.4","172.30.230.5"};
	public static int port=23;

	public static void main(String[] args) throws InterruptedException 
	{
		try
		{
			for(int i=0;i<=,2;i++)
			{		
			
				System.out.println("\n\nSchleifenanfang:"+i);
				Socket client=new Socket(host[i],23);
			
			
				
				System.out.println(client);
				InputStreamReader in =new InputStreamReader( client.getInputStream());
				PrintStream os = new PrintStream( client.getOutputStream());
				BufferedReader input=new BufferedReader(in);
							
				System.out.println("\nVor dem Thread:\n");
						
				TelnetInput a=new TelnetInput(input);
								
				System.out.println("\nNach dem Thread:\n");
											
				os.print("u0000883\n");
				os.print("passwort\n");
				os.print("en\n");
				os.print("passwort\n");
				os.print("sh users\n");
				os.print("exit\n");
				os.flush();
                                                                //warten auf das ende des threads
				while(!a.finish())
					;
					
				System.out.println("\n\nSchleifenende");	
				try
				{
					client.close();
				}
				catch(IOException e)
				{
					System.out.println("Socket noch nicht geschlossen");
				}
			}
		}
		catch(IOException e)
		{
			System.out.println("No Connection to the host");
		}		
	}
}

und hier der Code der Thread- Klasse:

import java.io.BufferedReader;
import java.io.IOException;

public class TelnetInput extends Thread 
{
	private static BufferedReader input;
	private static boolean wstatus=true;
	private static boolean finished=false;
		
	TelnetInput(BufferedReader a)
	{
		input=a;
		this.setDaemon(true);
		this.start();
	}
	
	public void run()
	{
		try
		{
			while(!isInterrupted())
			{
				try
				{	
					if(input.ready())
					{
						
						String s=input.readLine();
						System.out.println(s);
						if(s.indexOf("exit") != -1)
							if(s.indexOf("(config)") == -1)
							{
								
								System.out.println("Thread finished");
								this.interrupt();
								finished=true;
							} 							
					}
					
				}
				catch(IOException e)
				{			
				}				
			}
			sleep(1);
		}
		catch(InterruptedException e)
		{
		}		
	}
	boolean finish()
	{
		return finished;
	}
}

Bin für jeden Ansatz dankbar.

Danke schon mal im vorraus.

 

[hugo]

Wie sieht es mit deinem Thread aus? Wird der beendet? Ich würde fast behaupten nein, und damit ist der Socket weiterhin belegt und kein anderer kann darauf zugreifen

 

[Luma]

Das sollte dann so aussehen:

import java.io.BufferedReader;
import java.io.IOException;

public class TelnetInput extends Thread
{
   private static BufferedReader input;
   private static boolean wstatus=true;
   private static boolean finished=false;
      
   TelnetInput(BufferedReader a)
   {
      input=a;
      this.setDaemon(true);
      this.start();
   }
   
   public void run()
   {
      try
      {
         while(!isInterrupted())
         {
            try
            {   
               if(input.ready())
               {
                  
                  String s=input.readLine();
                  System.out.println(s);
                  if(s.indexOf("exit") != -1)
                     if(s.indexOf("(config)") == -1)
                     {
                        
                        System.out.println("Thread finished");
                        this.interrupt();
                        finished=true;
                     }                      
               }
               
            }
            catch(IOException e)
            {         
            }            
         }
         sleep(1);
      }
      catch(InterruptedException e)
      {
         interrupt(); // DAS IST NEU!
      }      
   }
   boolean finish()
   {
      return finished;
   }
}

Du musst das interrupted-Flag neu im catch-Block wo's aufgefangen wird normal neu setzen, da nur 1 Aufruf von interrupt() zwar eine InterruptedException auslöst, die Flag allerdings dann zurücksetzt...



Edit: Uhh sieht der Code scheußlich von der Formatierung aus. Naja kommt ja nur auf eine Zeile an...

 

[chris1507]

Danke für den Typ das hat aber leider auch nicht geholfen.
Wenn ich das Programm im Debug Modus durchlaufe, funktoniert es einwandfrei. Aber im normalen Modus wird nur die Verbindung zur ersten Adresse aufgebaut. Irgendwelche weitere Ideen??

 

[Luma]

Ähhm cris wenn ich meine neue Version des Programms bei mir teste, läuft das nicht und bricht mit der Meldung: Network is reachable: connect ab! Das heißt das die IP's wahrscheinlich nicht aktiv sind... Ich will hier aber das Forum nicht voll mit Codeversuchen von mir zu spammen. Soll ich dir die neue Version einfach schicken und du testest sie dann?

 

[chris1507]

Hallo Luma,

danke erst mal für deine Hilfe aber leider muss ich sagen dass es immer noch nicht geht, was daran liegt das er den Thread nicht beendet. Im Debug Modus bleibt er beim folgenden Codestück hängen:

 while (true) 
            { 
               if (telnetInput.isInterrupted()) 
                  break; 
               System.out.print("."); 
            }

Der Thread wird einfach nicht beendet. Und das mir doch etwas schleierhaft.

Du kommst nicht auf die Ip Adressen da diese nur im Intranet verfügbar sind und von aussen durch die Firmenfirewall blockiert werden.

Weitere Ideen??

Ihr wundert euch sicher warum ich immer so komische Zeiten beim Posten habe, was daran liegt das ich hier in China sitze und wir Deutschland 6 Stunden voraus sind

Hoffe auf neue Ansätze da ich das Problem in den Griff bekommen muss.

Danke

 

[Luma]

Hio. Also ich glaub ich hab jetzt die Lösung. Ich habe nämlich nur mal so bissel rumgespielt und nur die Threadfunktionalität getestet (und alles andere ausgekommentart ;D). Und dann bleibt der auch bei mir in der Schleife stehen und ich weiss nicht warum. Um zu testen ob der Thread wirklich tot (oder eben beendet ist) hab ich am Ende der run-Methode ein println("has finished") hinzugefügt. Und selbst diese Ausgabe kam. Dann muss was mit der Abfrage telnetInput.isInterrupted() faul sein. Warum? Keine Ahnung. Deswegen hab ich nur so zum Test die ganze while-Schleife mit join() erstetzt. Und siehe da es ging. Für einen weiteren Test hab ich join wieder entfernt, die gleiche while-Schleife wieder eingefügt nur das nicht das interrupted-Falg abgefragt wird, sonder ob der Thread noch lebt (mit isAlive). Der Thread war natürlich tod und alles und das Programm hat wiederum funktioniert. Das isInterrupted funktioniert also nicht. Und ich kann mir auch vorstellen warum: Wenn der Thread nämlich tod ist (Das ist ein Zustand, den ein Thread einnehmen kann. Mehr siehe mein Multithreadingprogramm) kann er logisch gesehen nicht unterbrochen (interrupted) sein...

Probier das Programm jetzt einfach nochmal aus. Hier die neue Version:

/*
 * Telnetcon.java
 */


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;


public class Telnetcon {
	private String host[] = { "172.30.230.5", "172.30.244.4", "172.30.230.5" };
	private int port = 23;
	
	
	public void startConnection() {
		Socket clientSocket = null;
		PrintStream output = null;
		BufferedReader input = null;
		
		for (int i = 0; i <= 2; i++) {
			System.out.println("\n\nSchleifenanfang [" + i + "]");
			
			try {
				clientSocket = new Socket(host[i], port);
			}
			catch (IOException ioe) {
				ioe.printStackTrace();
				break;		// Hier kann man evt. gleich aus Schleife aus-
							// brechen, wenn man den Server nicht findet...
			}
			System.out.println(clientSocket);
			
			try {
				output = new PrintStream(clientSocket.getOutputStream());
				input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
			}
			catch (IOException ioe) {
				ioe.printStackTrace();
			}
			
			
			// System.out.println("\nVor dem Thread:\n");
			TelnetInput telnetInput = new TelnetInput(input);
			telnetInput.setPriority(Thread.NORM_PRIORITY);
			telnetInput.start();
			
			// System.out.println("\nNach dem Thread:\n");
			System.out.println("output...\n\n");
			
			output.print("u0000883\n");
			output.print("passwort\n");
			output.print("en\n");
			output.print("passwort\n");
			output.print("sh users\n");
			output.print("exit\n");
			output.flush();
			
			// Warten auf das Ende des Threads mit join()
			try {
				telnetInput.join();
			}
			catch (InterruptedException ie)
			{ ie.printStackTrace(); }
			
			System.out.println("\nSchleifenende [" + i + "]");
			
			// Hier wusste ich net genau... Aber ich bin der festen
			// Ueberzeugung, dass man auch die Streams schließen muss
			try {
				clientSocket.close();
				output.close();
				input.close();
			}
			catch (IOException ioe)
			{ ioe.printStackTrace(); }
		}
	}
	
	public static void main(String[] args)
	{
		Telnetcon telnetcon = new Telnetcon();
		telnetcon.startConnection();
	}
}

/*
 * TelnetInput.java
 */



import java.io.BufferedReader;
import java.io.IOException;


public class TelnetInput extends Thread {
	private BufferedReader input;
	
	
	public TelnetInput(BufferedReader a) {
		input = a;
	}
	
	
	public void run() {
		while (true) {
			if (this.isInterrupted()) {
				// Wenn die Interrupted-Flag gesetzt wurde, muss hier aus der
				// Schleife mit break ausgebrochen werden.
				
				break;
			}
			
			try {
				System.out.println("Waiting for input...");
				Thread.sleep(500);
				
				if (input.ready()) {
					String s = input.readLine();
					System.out.println("Readline  " + s);
					System.out.println("Index of exit " + s.indexOf("exit") + "\nIndex of (config) " + s.indexOf("(config)"));
					if (s.indexOf("exit") != -1) {
						if (s.indexOf("(config)") == -1) {
							System.out.println("Thread finished");
							this.interrupt();
						}
					}
				}
				this.interrupt();
			}
			catch (InterruptedException ie) {
				ie.printStackTrace();
				this.interrupt();
			}
			catch (IOException e) {
				e.printStackTrace();
			}
		}
		
		
		System.out.println("Thread [" + this.getName() + "] has finished");
	}
}

 

[chris1507]

Hallo,

Du wirst es nicht glauben aber es funktoniert. Du hattest zwar noch einen kleinen Fehler drinnen aber das glaube hast du nur vergessen.
Und zwar muss in der TelnetInput Klasse in der run Methode der zweite Aufruf von

this.interrupt();

in den else - Zweig der

if (input.ready())

Anweisung gepackt werden, sonst beendet er den Thread jedes mal beim Aufruf von run.

Somit sieht der komplette Code nun so aus:

import java.io.BufferedReader; 
import java.io.IOException; 


public class TelnetInput extends Thread 
{ 
   private BufferedReader input; 
    
    
   public TelnetInput(BufferedReader a) 
   { 
      input = a; 
   }    
   public void run() 
   { 
      while (true) 
      { 
         if (this.isInterrupted()) 
         { 
            // Wenn die Interrupted-Flag gesetzt wurde, muss hier aus der 
            // Schleife mit break ausgebrochen werden. 
            break; 
         }
          
         try 
		 { 
            
            Thread.sleep(1); 
             
            if (input.ready()) 
            { 
               String s = input.readLine(); 
               System.out.println(s); 
               if (s.indexOf("exit") != -1) 
               { 
                  if (s.indexOf("(config)") == -1) 
                  { 
                     System.out.println("Thread finished"); 
                     this.interrupt(); 
                  } 
               } 
            }
            else           	
            	this.interrupt(); 
         } 
         catch (InterruptedException ie) 
		 { 
            ie.printStackTrace(); 
            this.interrupt(); 
         } 
         catch (IOException e) 
		 { 
            e.printStackTrace(); 
         } 
      }       
      System.out.println("Thread [" + this.getName() + "] has finished"); 
   } 
}

Die andere Datei bleibt unverändert.

Vielen vielen Dank für deine Hilfe und respekt dass du dies raus gefunden hast.

Gruss
Chris

 

[Luma]

Sorry für die kleinen Fehler. Hab die Klassen ein paar mal getestet. Und beim letzten Test hab ich wohl vergessen, das this.interrupt() zu entfernen. Aber gut von dir, dass du das gesehen hast.

Grüße an deine Chinesen 8)
Luma

 

[chris1507]

kein problem.

danke nochmal.