Fehlerhafte Thread Verwendung beim arbeiten mit Sockets

[duddits]

Hi,


seltsamerweise funktioniert dieser Code hier nicht:

/**
 *
 * @author daniel baier alias duddits
 * @version 0.2 alpha
 *
 */

import java.net.*;

public class ports  extends Thread{
	static int port;
	 static Socket client = null;
	 String ip_a;
	 
	int port_n;
	
	public ports(int port_start,String ip, int port_nummer){
		port_n = port_start;
		ip = ip_a;
		port_nummer = port;
	}
	
	public void run(){
		while (port_n <= port) {
            try {

               client = new Socket(ip_a, port_n);
               if (client.isConnected()) {
                  System.out.println(client.getPort() + "/tcp     open");
                  port_n++;
               }

            } catch (Exception e) {
               port_n++;
            }
         }
	}

   public static void main(String[] args) throws Exception {
     
      if (args.length == 0) {
         System.out.println("ports 0.2 alpha");
         System.out.println("Usage: java ports target_ip");

      } else {
         
         System.out.println("Starting ports 0.2 alpha");
         System.out.println("Interesting ports on " + args[0]);
         System.out.println("PORT        STATE ");
         ports p1 = new ports(1,args[0],100);
         ports p2 = new ports(101,args[0],200);
         ports p3 = new ports(201,args[0],300);
         ports p4 = new ports(301,args[0],400);
         ports p5 = new ports(401,args[0],500);
         p1.start();
         p2.start();
         p3.start();
         p4.start();
         p5.start();
      }

   }


}

Weis jemand Rat für mich? Es scheint so da ich ich in der Run-Methode den Fehler gemacht habe aber leider fällt es mir nicht auf.

mfg duddits

 

[SamHotte]

Wie wäre es, die Exception mal auszugeben?

 

[Murray]

Wird die statische Variable port irgendwo gesetzt? Wenn nicht, dann wird wohl im run die while-Bedingung niemals erfüllt sein.

Wazu sollen die statics denn überhaupt dienen? Dass aus mehreren Thread heraus die Variable client immer neu belegt wird, kann eigentlich nicht gut sein...

 

[duddits]

Hi,


erstmal danke für Eure Antworten.

1. Es wird keine Exception geworfen es sei den ich würde die der Main Methode irgendwo auffangen ( hmm mach ich am besten gleich direkt mal)

2. Ich dahcte das ich wenn ich ports p1 = new ports(1,args[0],100); so deklariere das ich die Variabel port mit dem Wert 100 belegt.

Wozu das gut sein soll? Gute Frage bis jetzt hatte ich static nur dazu verwendet um meine Instanzvariabeln auch in der Main Methode zu nutzen. Der genaue Verwendungszweck blieb mir bisweilen leider verborgen.

mfg duddits

 

[duddits]

Hi,

hab noch mal getetstet und habe dabei festgestellt, das ich im Konstruktor mich verschreiben hatte:

falsch:

...
port_nummer = port;
...

richtig:

...
port = port_nummer:
...

mfg duddits

 

[byte]

zu 1. Fehlerbehandlung gehört in den Task also in die run(). Ausserhalb geht das nicht.

zu 2. Erstmal solltest Du das static weg machen, weil sonst jeder Thread den gleichen Wert hat. Zweitens muss es statt port_nummer = port; richtig heissen port = port_nummer;

 

[Murray]

2. Ich dahcte das ich wenn ich ports p1 = new ports(1,args[0],100); so deklariere das ich die Variabel port mit dem Wert 100 belegt.

Da ist dann wohl ein Fehler im Konstruktor:

 public ports(int port_start,String ip, int port_nummer){
      port_n = port_start;
      ip = ip_a;
      port_nummer = port;
   }

Hier wird port_nummer auf port gesetzt (und dann sofort wieder vergessen, da port_nummer ja eine lokale Variable ist); in der Zuweisung muss die Reihenfolge umgedreht werden.

<off-topic>Solche Fehler kann man vermeiden, indem man die Parameter der Methode als final deklariert</off-topic>

Das Problem mit den statics ist aber, dass sie von allen Instanzen gemeinsam verwendet werden; jeder Konstruktor-Aufruf wird also port für alle anderen Instanzen verändern. Noch schlimmer im run: hier ziehen sich die einzelnen Threads gegenseitig das durch client referenzierte Socket-Objekt unter dem Hintern weg.

Und zu Exceptions:

   public void run(){
      while (port_n <= port) {
            try {

               client = new Socket(ip_a, port_n);
               if (client.isConnected()) {
                  System.out.println(client.getPort() + "/tcp     open");
                  port_n++;
               }

            } catch (Exception e) {
               /* 
                  Hier wird die Exception kommentarlos abgefangen und weder ausgegeben noch an 
                  aufrufenden Code weitergegen, daher kannst Du nicht sicher sein, dass nicht doch
                  eine Exception aufgetretetn ist.
               */

               port_n++;
            }
         }
   }

EDIT: zu langsam :wink: