Threading-Aufgaben zum Scannen öffnen TCP-Port

Question

Ich habe Probleme mit WaitAll in der unteren Code. Diese Methode empfängt eine Liste von IP-Adressen und einen Port (ich scanne nach WMI-Port 135) und gibt eine Liste von IP-Adressen zurück, bei denen der Port geöffnet ist. Ich glaube, ich habe WaitAll nicht korrekt implementiert, als wenn ich diesen Code verlangsame, scheint es die richtigen Systeme auszuführen und zurückzugeben. Vielen Dank.

private static List<IPAddress> openSystems = new List<IPAddress>(); 

public static List<IPAddress> Scan(List<IPAddress> addresses, ushort port) 
{ 
    int count = addresses.Count; 
    Task[] tasks = new Task[count]; 

    //Loop through ip address 
    for(int x = 0; x <= count -1; x++) 
    { 
     tasks[x] = Task.Factory.StartNew(() => 
     { 
      using (TcpClient tcp = new TcpClient()) 
      { 
       try 
       { 
        Console.WriteLine("Trying to get into {0}", addresses[x]); 
        tcp.Connect(addresses[x], port); 
        openSystems.Add(addresses[x]); 
       } 
       catch 
       { 
        Console.WriteLine("Can't get into {0}", addresses[x]); 
        //ignore exceptions 
       } 
      } 
     }); 
    } 

    Task.WaitAll(tasks); 
    return openSystems; 
} 

Answer 1

Es gibt mehrere Best Practices, die in Ihrem Code ignoriert werden.

Sie sollten die ConnectAsync Methode des TcpClient nennen und zu Task.Factory.StartNew des Anrufs loszuwerden

Sie nicht Task.WaitAll verwenden sollten aber await Task.WhenAll

Die Methodensignatur wird dann public static Task> ScanAsync(List addresses, ushort port) und man kann erwarten, dass in dem codieren wird genannt.

Sie greifen auf die Liste openSystems für verschiedene Threads zu. Liste ist nicht threadsafe, also sollten Sie eine gleichzeitige Sammlung verwenden oder es andernfalls tun.

public static async Task<List<IPAddress>> ScanAsync(List<IPAddress> addresses, ushort port) 
{ 
    var tasks = addresses.Select(a => CheckIpAsync(a, port); 

    await Task.WhenAll(tasks); 
    return openSystems; 
} 

private async Task CheckIpAsync(IPAddress address, ushort port) 
{ 
    using (TcpClient tcp = new TcpClient()) 
    { 
     try 
     { 
      Console.WriteLine("Trying to get into {0}", address); 
      await tcp.ConnectAsync(address, port); 
      openSystems.Add(address); 
     } 
     catch 
     { 
      Console.WriteLine("Can't get into {0}", address); 
      //ignore exceptions 
     } 
    } 
} 

Das könnte Ihre Frage immer noch nicht beantworten, da ich keine finden kann. Aber es zeigt eine bessere Implementierung.