[IdTCPClient] Comment scanner des ports en multithread ?

Lu,
Lu j'ai demander des conseils y'a quelques jours pour faire un scanner de ports, en fait j'utilise le composant "IdTCPClient" (a voir si le meilleur), mais j'arrive tout de meme a scanner, mais 2 inconvenients majeurs :

- j'aimerais savoir si possible de faire du "Multithread" avec un composant comme "IdTCPClient", et biensur si oui, un petit exemple serait le bienvenu.


- Autrement, ma fenetre se fige pendant le scan : elle ne se reactualise pas / elle ne se ferme pas.

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

begin P:= 1; repeat with IdTCPClient1 do begin Host := edit1.Text; Port := P; Str(P, po); P := P + 1; Edit2.Text := po; try Connect(500);   except on E : Exception do // Pour les Ports non-ouverts. begin po := ''; end; end; Memo1.Text := Memo1.Text + po; end; until P = 65500   end;

---

merci..

Les serveurs d'Indy sont tous forcément threadés : ils sont faits ainsi. Donc je ne comprends même pas l'à propos de ta question :?

http://delphi.developpez.com/faq/?page=indy_gene_thread non?

Citation:

---

j'aimerais savoir si possible de faire du "Multithread" avec un composant comme "IdTCPClient", et biensur si oui, un petit exemple serait le bienvenu

---

Oui. Il faut créer plusieurs threads avec chacun un TIdTCPClient, chaque thread s'occupant d'une plage de ports particuliers. Pour communiquer avec l'interface graphique, toujours par contre passer par Synchronize (cf. multitude de posts sur ce forum).

Citation:

---

Autrement, ma fenetre se fige pendant le scan : elle ne se reactualise pas / elle ne se ferme pas.

---

D'où l'intérêt de faire du multithread dès le départ. Ou utiliser le composant TIdAntiFreeze...

Citation:

---

sjrd --> Les serveurs d'Indy sont tous forcément threadés : ils sont faits ainsi. Donc je ne comprends même pas l'à propos de ta question

---

: à mon avis, tu n'as pas compris ma question.

Citation:

---

Reisubar --> Il faut créer plusieurs threads avec chacun un TIdTCPClient

---

je voudrais environ 300 threads max, ca va pas etre evident un composant pour chaque; y'a pas une routine pour ca?

Tu les créé dynamiquement

bonjour,

tu peux aussi utiliser les composants ICS (http://www.overbyte.be/frame_index.html?redirTo=/products/ics.html). Ils sont plus difficiles d'approche, mais ils sont évennementiel, donc non bloquant. Avec eux, tu n'aurais pas besoin de passer par une gestion multi-thread.

@++
Dany

Citation:

---

Tu les créé dynamiquement

---

Apolllo, tu peuts aprofondir un peu stp

skywaukers, merci, je vais regarder ...

Et merci aux autres.

J'ai peut etre parlé trop vite, si personne ne m'a suivit, je m'y connasi aps trop bien mais je pense que tu peux faire un truc comme ca

Code:

---

1 2	TidTCPClient.Create();

---

Avec une boucle genre

Code:

---

1 2 3 4 5 6 7

var NbSocket : integer; begin NbSocket:=100; For NbSocket:=0 to 100 do TidTCPClient.Create(); end;

---

Il doit y avoir d'autre parametres, mais il est surement possible de faire ca enfin c'est a vérifier, je suis noob :d ^^
Si ce que j'ai écrit est possible, je ne pense pas que ce soit la meilleure solution...Il faudrait les détruire massivement les TidTCPClient a la fin du scan :s
Attente du verdict !

Je vais essayer, mais je suis un peu pessimiste ...

Atta, je me suis planté !!!! lol j'ai modifié mon code !

Merci a toi Apollo, mais TidTCPClient.Create() ne peut pas etre un "integer", je n'ai rien trouvé comme exemple concret concernant la class .create(Tcomponent), je ne pense pas qu'elle créee d'autres composants.


Tout marche nickel sauf cette histoire de threads, GRRRR !!!!!!!!!! :x

Beh, ce n'est pas un integer,j'ai créé un boucle afin d'en créer autant que la var NbSocket !
Beh apres je m'y connais pas en indy donc voila, mais quel est le message d'erreur ?

Bon, voilà un exemple absolument pas testé mais qui peut te mettre dans la bonne direction :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64

type //Prototype de procédure à appeller quand un port est détecté ouvert TOpenPortEvent = procedure (Sender: TObject; const APort: Integer) of object;   //Idem, si fermé TClosedPortEvent = procedure (Sender: TObject; const APort: Integer) of object;   //Le thread de scan TScanThread = class(TThread) private FMinPort: Integer; FMaxPort: Integer; FTCPClient: TIdTCPClient; FOpenProc: TOpenPortEvent; FClosedProc: TClosedPortEvent; FHost: Integer; protected procedure Execute; override; public destructor Destroy; override; constructor Create(const AMinPort, AMaxPort : Integer; AOnOpenPort: TOpenPortEvent; AOnClosedPort: TClosedPortEvent; const AHost: string); end;   constructor TScanThread.Create(const AMinPort, AMaxPort : Integer; AOnOpenPort: TOpenPortEvent; AOnClosedPort: TClosedPortEvent; const AHost: string) begin inherited Create(True); //Création du client FTcpClient := TIdTCPClient.Create; //initialisation des propriétés FMaxPort := AMaxPort; FMinPort := AMinPort; FHost := AHost; FOpenProc := AOnOpenPort; FClosedPort := AOnClosedPort; end;   procedure TScanThread.Execute; var I: Integer; begin //le code du scan FTCPClient.Host := FHost; for I := FMinPort to FMaxPort do try FTCPClient.Port := I; FTCPClient.Connect(500); try FOpenProc(Self, I); //Appelle la procédure de notification port ouvert finally FTCPClient.Disconnect; end; except On E: TIdException do FClosedProc(Self, I); //Appelle la procédure de notification port fermé end; end; end;   destructor TScanThread.Destroy; begin if FTcpClient.Connected then FTcpClient.Disconnect; FTcpClient.Free; end;

---

Le principe est de donner au thread (lors de sa construction) un intervalle de port, deux fonctions à rappeller et un hôte. Le thread scannera l'hote et appellera alternativement les fonctions selon que le port est ouvert ou non. Il manque bien sûr le code relatif à leur création: il faudrait ici choisir un nombre de threads et diviser l'intervalle à scanner en fonction de ce nombre pour attrivuer une plage homogène à chaque thread.

Thx Reisubar, mais mon code fonctionne...

Citation:

---

Le thread scannera l'hote et appellera alternativement les fonctions selon que le port est ouvert ou non. Il manque bien sûr le code relatif à leur création

---

Mais c'est bien ca mon probleme, c'est bien créer un nombre definit de thread par l'utilisateur ou alors je n'ai compris ce que t'as voulu me dire.


Si

Code:

---

TIdTCPClient.Create

---

cree ton client peut-on en creer infiniment et si oui comment les gerer ?



Voila mon code pour le scanner de ports, à un seul theard malheureusement, mais il est OK !!!

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82

unit Unit1;   interface   uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls, IdBaseComponent, IdComponent, IdTCPConnection, IdTCPClient, IdAntiFreezeBase, IdAntiFreeze, DosCommand;   type TForm1 = class(TForm) IdTCPClient1: TIdTCPClient; Button1: TButton; Edit1: TEdit; Memo1: TMemo; Edit2: TEdit; Button2: TButton; IdAntiFreeze1: TIdAntiFreeze; DosCommand1: TDosCommand; procedure Button1Click(Sender: TObject); procedure IdTCPClient1Connected(Sender: TObject); procedure Button2Click(Sender: TObject); procedure FormActivate(Sender: TObject); private { Private declarations } public { Public declarations } end;   var Form1: TForm1; P : Integer; po : string ;   implementation   {$R *.dfm}     procedure TForm1.Button1Click(Sender: TObject); begin P:= 1; // Port min repeat with IdTCPClient1 do begin Host := edit1.Text; // L'IP biensur Port := P; Str(P, po); P := P + 1; // Incrementation des ports Edit2.Text := po; // Affiche les ports en cours de scan try Connect(500);   except on E : Exception do // Pour les Ports non-ouverts. begin po := ''; // Permet d'afficher dans memo1 que les ports ouverts end; end; Memo1.Text := Memo1.Text + po; end; until P = 65500 // Port max   end;   procedure TForm1.IdTCPClient1Connected(Sender: TObject); begin IdTCPClient1.Disconnect; // Deconnecter si port ouvert   end;   procedure TForm1.Button2Click(Sender: TObject); begin application.Terminate; end;   procedure TForm1.FormActivate(Sender: TObject); begin Memo1.clear; end;   end.

---

Merci a tout ceux qui s'investissent pour les autres :wink:

Voila l'appli d'un pote en C++, bien sur elel est en console mais il ne se sert pas d'indy, peut etre pourra tu t'en inspirer et integrer dans ton programme une console

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281

#include <winsock2.h> #include <stdio.h> #include <stdlib.h> #pragma comment(lib, "ws2_32.lib") #include <time.h> #include "stdafx.h" #include "String.h"   struct config { SOCKET sock; SOCKADDR_IN sin; int ip; int port; HANDLE hthread; };   int nthread=1;   DWORD WINAPI connection( LPVOID Param ) { struct config * conf = (struct config *)Param; WSADATA WSAData; WSAStartup(MAKEWORD(2,0), &WSAData); conf->sin.sin_addr.s_addr = ntohl(conf->ip); conf->sin.sin_family = AF_INET; conf->sin.sin_port = ntohs(conf->port); conf->sock = socket(AF_INET,SOCK_STREAM,0); bind(conf->sock, (SOCKADDR *)&conf->sin, sizeof(conf->sin)); if ( !connect(conf->sock, (SOCKADDR *)&conf->sin, sizeof(conf->sin)) ) { FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); /* Ecrire chaîne dans le fichier */ fwrite(inet_ntoa(conf->sin.sin_addr), strlen(inet_ntoa(conf->sin.sin_addr)), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); } nthread++; closesocket(conf->sock); WSACleanup(); CloseHandle(conf->hthread); free(conf); }   int main(int argc, char *argv[]) { int startip; int endip; int port; int aleatip; struct config * conf = NULL; if ( argc == 4 ) { startip = htonl(inet_addr(argv[1])); endip = htonl(inet_addr(argv[2])); port = atoi(argv[3]); nthread = 100; { FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); char commande[] = "scan.exe "; char espace[] = " "; /* Ecrire chaîne dans le fichier */ fwrite(commande, strlen(commande), 1, fic); fwrite(argv[1], strlen(argv[1]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[2], strlen(argv[2]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[3], strlen(argv[3]), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); } for (;startip <= endip;startip++) { while ( !nthread ); { conf = (struct config *) malloc(sizeof(struct config) ); conf->ip = startip; conf->port = port; conf->hthread = CreateThread(NULL, 0, &connection, conf, 0, 0); nthread--; } } _sleep(150); FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); char finscan[] = "scan terminé\n"; fwrite(finscan, strlen(finscan), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); return 0; } else if ( argc == 5) { startip = htonl(inet_addr(argv[1])); endip = htonl(inet_addr(argv[2])); port = atoi(argv[3]); nthread = atoi(argv[4]); { char retour[] = "\n"; char commande[] = "scan.exe "; char espace[] = " "; FILE * fic; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); /* Ecrire chaîne dans le fichier */ fwrite(commande, strlen(commande), 1, fic); fwrite(argv[1], strlen(argv[1]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[2], strlen(argv[2]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[3], strlen(argv[3]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[4], strlen(argv[4]), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); } for (;startip <= endip;startip++) { while ( !nthread ); { conf = (struct config *) malloc(sizeof(struct config) ); conf->ip = startip; conf->port = port; conf->hthread = CreateThread(NULL, 0, &connection, conf, 0, 0); nthread--; } } _sleep(150); FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); char finscan[] = "scan terminé\n"; /* Ecrire chaîne dans le fichier */ fwrite(finscan, strlen(finscan), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); return 0; } else if ( argc == 3) { srand ((unsigned)time (0)); //int a,b,c,d,i=1000; int a; int b; int c; int d; char str[20]; port = atoi(argv[1]); nthread = atoi(argv[2]); startip = 1; endip = 1000; { char retour[] = "\n"; char commande[] = "scan.exe random "; char espace[] = " "; FILE * fic; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); /* Ecrire chaîne dans le fichier */ fwrite(commande, strlen(commande), 1, fic); fwrite(argv[1], strlen(argv[1]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[2], strlen(argv[2]), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); } for (;startip = startip;startip++) { while (!nthread); { a=rand()%256; b=rand()%256; c=rand()%256; d=rand()%256; sprintf(str,"%d.%d.%d.%d",a,b,c,d); aleatip=htonl(inet_addr(str)); conf = (struct config *) malloc(sizeof(struct config) ); conf->ip = aleatip; conf->port = port; conf->hthread = CreateThread(NULL, 0, &connection, conf, 0, 0); nthread--; } } _sleep(150); FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); char finscan[] = "scan terminé\n"; /* Ecrire chaîne dans le fichier */ fwrite(finscan, strlen(finscan), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); return 0; } else if ( argc == 6) { port = atoi(argv[1]); nthread = atoi(argv[2]); int str[300]; char str1[20]; int i=0; int a; int b; int c; int d; srand ((unsigned)time (0)); FILE * pFile; pFile = fopen ("range.txt","rb"); rewind (pFile); while (!feof(pFile)) { fscanf (pFile, "%d", &str[i]); i++; } fclose (pFile); { char retour[] = "\n"; char commande[] = "scan.exe random dans range.txt "; char espace[] = " "; FILE * fic; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); /* Ecrire chaîne dans le fichier */ fwrite(commande, strlen(commande), 1, fic); fwrite(argv[1], strlen(argv[1]), 1, fic); fwrite(espace, strlen(espace), 1, fic); fwrite(argv[2], strlen(argv[2]), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); } for (;startip = startip;startip++) { while (!nthread); { a=str[rand()%i]; b=rand()%256; c=rand()%256; d=rand()%256; sprintf(str1,"%d.%d.%d.%d",a,b,c,d); aleatip=htonl(inet_addr(str1)); conf = (struct config *) malloc(sizeof(struct config) ); conf->ip = aleatip; conf->port = port; conf->hthread = CreateThread(NULL, 0, &connection, conf, 0, 0); nthread--; } } _sleep(150); FILE * fic; char retour[] = "\n"; /* Ouverture d'un fichier */ fic = fopen("resultats.dat", "a+"); char finscan[] = "scan terminé\n"; /* Ecrire chaîne dans le fichier */ fwrite(finscan, strlen(finscan), 1, fic); fwrite(retour, strlen(retour), 1, fic); fclose(fic); return 0; } else { printf("Usage : scan.exe ip_start ip_end port\n"); printf("alternatif : scan.exe ip_start ip_end port nbthreads\n"); printf("ou encore pour du random: scan.exe port nbthreads\n"); printf("ou encore pour du random trié: scan.exe port nbthreads random dans range.txt\n"); return 0;   } } Auteur Fredo->robustcs.com(code source a titre d'exemple)

---

Citation:

---

Thx Reisubar, mais mon code fonctionne...

---

Ta demande était de réaliser une application multithreadée, non ? C'est l'intérêt de mon code.

Citation:

---

Mais c'est bien ca mon probleme, c'est bien créer un nombre definit de thread par l'utilisateur

---

Dans ce cas, ce n'est pas compliqué. Une boucle for qui crée n threads et n appels à leur méthode Resume...

Citation:

---

cree ton client peut-on en creer infiniment et si oui comment les gerer ?

---

Indéfiniment, il ne vaut mieux pas. Dans mon code, chaque thread embarque son client, il est donc crée à leur création et détruit lorsqu'ils s'achèvent.

THX les gars, je vais regarder ca :D