Hola compañeros!! Un gusto otra vez por aquí

Bueno les comento que estoy con ganas de crear un programa en C++, hasta digamos que voy bien, pero me topo ahora con un inconveniente, que en realidad no les, pero por el momento si.

Lo que yo deseo es crear un Bot Escaner de Puertos en C++ para Redes IRC de chat, yo al bot lo pude hacer solo y hasta cree una función split() para poder separar palabras en una cadena string.


La conexión me sale bien, el bot entra al Servidor, se loguea y recibe la IP del usuario que conecta al chat, el tema viene a la hora de escaner ciertos puertos para determinar si el usuario tiene un X puerto abierto que es prohibido.

Estos tipo de bots son de seguridad y se utilizan para prevenir ataques masivos de clones.


Yo he podido hacer el escaner que analiza por ejemplo 10 puertos para saber si un usuario tiene algún proxy no permitido, estos puertos casi siempre son usados por proxys y utilizan las IPs proxys para entrar "camuflados" o anónimos al servidor.


El escaner escanea puerto por puerto hasta terminar con el último puerto, pero lo que yo necesito es crear una función y hacer llamadas a esa función con el valor de la IP del usuario para saber si tiene un puerto abierto, pero cláro, para poder hacer esto, voy a necesitar el uso de Threads, en Python esto es simple, podría lograrlo con:


threading.Thread(target=Escaner.Analizar()).start( )


o utilizar otra clase para lograr esto o usar la clase padre que es threading.


Pero en C++ por lo que leí es mucho más difícil o más difícil, en realidad lo quiero hacer no creo que sea algo difícil, pienso que un poco, porque el programa no tiene más que hacer que escanear puertos de IPs que van conectando al servidor


Esas IPs pueden ser cientas en cuestión de minutos, por eso necesito usar Threads, necesito que se divida por hilos los procesos para poder hacer esto posible.

Osea que por ejemplo en 3 segundos, el bot escanee 5 IPs al mismo tiempo, eso es lo que necesito.


Me encantaría que me dejaran un código de ejemplo para poder hacer esto posible, uso windows, así que utilizo la librería winsock2.


Me imagino que para el que sabe esto debe ser algo fácil o pan comido, yo seguiré intentando poder lograr esto y tratar de entender de alguna manera como hacer un código que utilice los Threads.


Desde ya les agradezco, muchas gracias a todos y que tengan buen día!!

[menghi]

Hola!

La verdad es que hace mucho que no toco Threads en C++, pero tengo la documentacion de un proyecto antiguo donde los use, a ver si te sirve de algo:

CThread.h

Código C++:

Ver original
class CThread
{
private:
    HANDLE thandle;
    long thid;
public:
    CThread();
    ~CThread();
    int Start(unsigned int (__stdcall *func)(void *), void * params);
    HANDLE CThread::GetHandle();
    void Resume();
    void Pause();
    void Stop();
};
 

CThread.cpp

Código C++:

Ver original
#include "CThread.h"
CThread::CThread(){
    this->thid = NULL;
}
 
int CThread::Start(unsigned int (__stdcall * func)(void *), void * params)
{
    this->thandle = (HANDLE) _beginthreadex(NULL, 0, func, params, CREATE_SUSPENDED, &this->thid);
 
    if(!this->thandle)
    {
        return NULL;
    }
    return 1;
}
 
HANDLE CThread::GetHandle(){ return this->thandle; }
 
void CThread::Resume(){ ResumeThread(this->thandle); }
void CThread::Pause(){ SuspendThread(this->thandle); }
void CThread::Stop(){ _endthreadex(this->thid); }
CThread::~CThread(){ this->Stop(); CloseHandle((void*)this->thid); }
 

Y tal y como lo uso mas adelante es mas o menos de la siguiente forma:

Código C++:

Ver original
unsigned int WINAPI callback(void * params)
{
    //Esta funcion se ejecutara durante la vida del hilo...
}
 
void main()
{
    CThread * th = new CThread();
    th->Start(callback, params);
    th->Resume();
}
 

Un saludo!

[CalgaryCorpus]

Tengo la impresion que el destructor tiene un bug, por llamar closehandle y pasarle el id del thread.
Hay que pasarle el handle.

Muchas gracias!!
Pero podrías poner un ejemplo de uso? por favor
Necesito saber como hace las llamadas a los Threads
Por ejemplo usando 3 o 4 bucles al mismo tiempo para poder ver donde se debe poner eso y como llama a los Threads.
Gracias.

PD: He usado 2 códigos de ejemplo que vi en una web, pero los 2 me dieron este error:

C:\Users\Daniel\Desktop\C++\SocketPuertos.cpp|3|fa tal error: strsafe.h: No such file or directory|

No creo que haga falta ese archivo, he visto en otros lados que no lo necesitan.

[CalgaryCorpus]

.. y tengo la impresion que Stop () no detiene el thread asociado pues la mision de endthreadex es de housekeeping solamente.

[menghi]

Te pongo un ejemplo completo de como crear 3 threads que multipliquen un array de numeros por 3, 4 y 5 de forma asincrona.

He modificado un poco las clases que puse antes.

Se puede hacer mejor, pero es para que veas como funciona:

CThread.h

Código C++:

Ver original
#include <Windows.h>
 
class CThread
{
private:
    HANDLE hThread;
    unsigned int thread_id;
 
public:
    CThread();
    ~CThread();
 
    int Start(unsigned int (__stdcall * func)(void *), void * params, bool suspended);
    void Resume();
    void Suspend();
    HANDLE GetHandle();
};
 

CThread.cpp

Código C++:

Ver original
#include "CThread.h"
#include <process.h>
 
CThread::CThread()
{
    this->hThread = NULL;
    this->thread_id = 0;
}
 
CThread::~CThread()
{
    CloseHandle(this->hThread);
    this->thread_id = 0;
}
 
int CThread::Start(unsigned int (__stdcall * func)(void *), void * params, bool suspended)
{
    if(this->hThread == NULL || this->thread_id == 0)
    {
        this->hThread = (void *) _beginthreadex(NULL, 0, func, params, 0, &this->thread_id);
        if(suspended == false)
            ResumeThread(this->hThread);
        return 1;
    }
    return 0;
}
 
void CThread::Resume()
{
    if(this->hThread)
    {
        ResumeThread(this->hThread);
    }
}
 
void CThread::Suspend()
{
    if(this->hThread)
    {
        SuspendThread(this->hThread);
    }
}
 
HANDLE CThread::GetHandle()
{
    return this->hThread;
}
 

main.cpp

Código C++:

Ver original
#include <Windows.h>
#include <iostream>
#include <string>
#include "CThread.h"
 
using namespace std;
 
typedef struct{
    string cadena;
    int multiplicador;
}datos;
 
int valores[16];
 
unsigned int WINAPI multiplica(void * params);
 
CThread hilo[3];
 
int main(int argc, char *argv[])
{
    //rellenamos el array valores para tener datos con los que trabajar:
    for(int i=0;i<16;i++){ valores[i] = i; }
 
    //creamos tres hilos de ejecucion:
    hilo[0] = CThread(); datos *dato1 = new datos; dato1->cadena = "Hilo 1"; dato1->multiplicador = 3;
    hilo[0] = CThread(); datos *dato2 = new datos; dato2->cadena = "Hilo 2"; dato2->multiplicador = 4;
    hilo[0] = CThread(); datos *dato3 = new datos; dato3->cadena = "Hilo 3"; dato3->multiplicador = 5;
 
    //ponemos a los tres hilos a trabajar
    
    hilo[0].Start(multiplica, dato1, false);
    hilo[1].Start(multiplica, dato2, false);
    hilo[2].Start(multiplica, dato3, false);
 
    WaitForSingleObject(hilo[0].GetHandle(), INFINITE);
    WaitForSingleObject(hilo[1].GetHandle(), INFINITE);
    WaitForSingleObject(hilo[2].GetHandle(), INFINITE);
 
    cout << "Fin" << endl;
    cin.get();
}
 
unsigned int WINAPI multiplica(void * params)
{
    int cursor = 0;
    datos * dato = (datos *)params; //obtenemos el parametro;
    while(cursor < 16)
    {
        int resultado = valores[cursor]*dato->multiplicador;
        cout << dato->cadena << ": " << resultado << endl;
        cursor++;
        Sleep(1);
    }
    cout << dato->cadena << ": TERMINADO" << endl;
    return 1;
}
 

Al ejecutarlo devuelve algo como esto:

Código C++:

Ver original
Hilo 1: Hilo 2: 0
Hilo 2: 4
0
Hilo 3: 0
Hilo 2: 8
Hilo 3: Hilo 2: 12
5
Hilo 1: Hilo 2: 16
Hilo 3: 10
3
Hilo 2: 20
Hilo 2: 24
Hilo 3: 15
Hilo 1: 6
Hilo 2: 28
Hilo 2: 32
Hilo 3: 20
Hilo 1: 9
Hilo 2: 36
Hilo 1Hilo 2: 40
: 12
Hilo 3Hilo 2: 44
: 25
Hilo 2: 48
Hilo 1: 15
Hilo 3: 30
Hilo 1: 18
Hilo 3: 35
Hilo 1: 21
Hilo 1: 24
Hilo 2: 52
Hilo 3: 40
Hilo 2: 56
Hilo 3: 45
Hilo 2: 60
Hilo 3: 50
Hilo 2: TERMINADO
Hilo 1: 27
Hilo 3: 55
Hilo 1: 30
Hilo 3: 60
Hilo 1: 33
Hilo 3: 65
Hilo 1: 36
Hilo 3: 70
Hilo 1: 39
Hilo 3: 75
Hilo 1: 42
Hilo 3: TERMINADO
Hilo 1: 45
Hilo 1: TERMINADO
Fin
 

Como ves al principio, las salidas por consola se mezclan un poco, esto es porque dentro del thread habrá que usar un mecanismo de mutex o semaforos, supongo.

Un saludo!!

Hola amigo, muchas gracias por el código!!
Intenté compilarlo al main.cpp, pero me dió estos errores:

mingw32-g++.exe -c C:\Users\Daniel\Desktop\C++\main.cpp -o C:\Users\Daniel\Desktop\C++\main.o
mingw32-g++.exe -o C:\Users\Daniel\Desktop\C++\main.exe C:\Users\Daniel\Desktop\C++\main.o -lws2_32
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x8e): undefined reference to `CThread::CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0xa8): undefined reference to `CThread::~CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0xfb): undefined reference to `CThread::CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x115): undefined reference to `CThread::~CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x171): undefined reference to `CThread::CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x18b): undefined reference to `CThread::~CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x1fd): undefined reference to `CThread::Start(unsigned int (*)(void*), void*, bool)'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x220): undefined reference to `CThread::Start(unsigned int (*)(void*), void*, bool)'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x243): undefined reference to `CThread::Start(unsigned int (*)(void*), void*, bool)'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x250): undefined reference to `CThread::GetHandle()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x26d): undefined reference to `CThread::GetHandle()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x28a): undefined reference to `CThread::GetHandle()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x483): undefined reference to `CThread::~CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x519): undefined reference to `CThread::CThread()'
C:\Users\Daniel\Desktop\C++\main.o:main.cpp:(.text +0x576): undefined reference to `CThread::~CThread()'
collect2.exe: error: ld returned 1 exit status
Process terminated with status 1 (0 minute(s), 0 second(s))
15 error(s), 0 warning(s) (0 minute(s), 0 second(s))


A los otros 2 archivos les puse el nombre que especificaste, pero no los compilé.
¿porque falla la compilación?

Gracias nuevamente.

SOLUCIONADO: Al toque me di cuenta del error, eso pasa porque te equivocaste en el archivo main.cpp y pusiste mal el nombre de la librería CThread, en realidad era CThread.cpp y vos pusiste CThread.h, pero la librería que carga a CThread.h es CTread.cpp, así que cambié eso y funciona perfectamente, ahora me pondré a estudiar esos mecanismos!! :D
Aunque me encantaría que comentaras un poco más los códigos asi le entenderé mejor!!!

Te agradezco enormemente amigo y espero que con los sockets funcione perfectamente!!