0

マルチクライアントサーバーを作成しようとしていて、サーバーと単一のクライアント間の情報交換を保護することができましたが、複数のクライアントが同時にサーバーに接続できるように、スレッドを使用する必要があります.

インターネットの指示に従いましたが、エラーが表示されます

' CreateThread': パラメータ 3 を ' unsigned long (void *)'から ' unsigned long (__stdcall *) (void *)'に変換できません

この関数では、何を返せばよいかわからないため、0 を返します。

これが私のコードです：

#include"serveur.h"

server::server(int p)
{
port = p;

}


int server::init()
{    
WORD wVersionRequested;
WSADATA  Data;
int error= (WSAStartup(MAKEWORD(2,2), &Data ));

if(error != 0 )
{
    cerr <<"WSAStartup a échoué "<< endl;
    return 1;
}
else
{
        ServerAddr.sin_family = AF_INET;
        ServerAddr.sin_port = htons( port );   

        ServerAddr.sin_addr.s_addr=htons(INADDR_ANY) ;  
}

cout <<"server correctement initialise" << endl;    
return 0;   
}

DWORD WINAPI server::ClientThread(void * p)
{

    struct thread_param *Obj = (struct thread_param      *) p ;
    server *s = Obj->ser;       

    cout << "thread client start" << endl;


char buffer[100];
        //**** sent ****

            strcpy(buffer, "coucou \n");
            send(Obj->soc, buffer,strlen(buffer), 0);
            cout<<"message envoye"<<endl;

    int reponse = 0;    
        do
        {
        //  cout<<"******** reception ...********"<<endl;
            reponse = recv(Obj->soc, buffer, sizeof(buffer), 0);
            cout<<"reponse"<<reponse<<endl;
            buffer[reponse]='\0';
            cout<<"msg recu "<<buffer<<endl;

        }while(reponse=0);


return 0;
}

int server::start ()
{
SOCKADDR_IN             ClientAddr;
int                     ClientAddrLen;
HANDLE                  hProcessThread;

struct thread_param     p;

    ListeningSocket = socket(AF_INET, SOCK_STREAM, 0);

    if(ListeningSocket == INVALID_SOCKET)
    {
        perror("socket()");
        exit(-1);
    }
        cout <<"socket correctement creee" << endl;  
if( bind( ListeningSocket, (SOCKADDR *)&ServerAddr, sizeof( ServerAddr ) ) == SOCKET_ERROR )
    {
    cerr<<"bind a echoue avec l'erreur "<< WSAGetLastError()<< endl;
    cerr<<"Le port est peut-être deja utilise par un autre processus "<< endl;

        return 1;
    } 
            cerr<<"Bind... "<< endl;
    if( listen( ListeningSocket, 5 ) == SOCKET_ERROR )
    {
        cerr<<"listen a échoué avec l'erreur "<< WSAGetLastError()<< endl;

        return 1;
    } 

        cout <<"serveur demarre : a l ecoute du port "<<port<< endl; 
        running = true;
        ClientAddrLen = sizeof( ClientAddr );
    while(running)
    {   

if(Newconnection = accept(ListeningSocket, (struct sockaddr *)&ClientAddr, &ClientAddrLen) == INVALID_SOCKET)
        {

     cout<<"accept a echoue avec l erreur "<< WSAGetLastError() << endl;

            return 1;
        }
            p.ser=this;
            p.soc=Newconnection;
            cout<<"client connecte..."<<endl;
        hProcessThread = CreateThread(NULL, 0,ClientThread, &p,0,NULL);

        if ( hProcessThread == NULL )
        {                       
    cerr <<"CreateThread a échoué avec l'erreur "<<GetLastError()<< endl;
        }

    }

    closesocket( ListeningSocket );
            WSACleanup();
return 0;
}
4

1 に答える 1

1

このように、メンバ関数を関数ポインタとして C スタイル関数に渡すことはできません。ポインターを受け取りthis、オブジェクトをキャストする静的関数を使用して、静的関数内からメンバー関数を呼び出すことができます。または、さらに良いことに、std::thread を使用します。

于 2013-03-27T17:22:52.400 に答える