Server Develop （二） 多线程实现C/S

//线程需要调用的函数

void pthread_work(struct argc *argc2)
{
    int flag;
    struct argc argc1;
    argc1.sock_clt = argc2->sock_clt;
    argc1.sock_serv = argc2->sock_serv;
    printf("%d,%d\n",argc1.sock_clt,argc1.sock_serv);
    char buffer[1024];
    strcpy(buffer, "this is server! welcome!\n");
    //send(sock_client, buffer, 1024, 0);
    send(argc1.sock_clt, buffer, 1024, 0);

    bzero(buffer,sizeof(buffer));
    //flag = recv(sock_client, buffer, 1024, 0);
    flag = recv(argc1.sock_clt, buffer, 1024, 0);
    if(flag < 0){
        perror("recv error!\n");
        close(argc1.sock_serv);
        return;
    }
    printf("recv : %s\n",buffer);

    while(1){
        bzero(buffer,sizeof(buffer));
        //flag = recv(sock_client, buffer, 1024, 0);
        recv(argc1.sock_clt, buffer, 1024, 0);
        if(flag < 0){
            perror("recv error!\n");
            close(argc1.sock_serv);
            return;
        }
        printf("i have recv buffer\n");
        printf("recv : %s\n",buffer);
        if(strcmp(buffer,"quit") == 0){
            printf("quit!!!\n");
            break;
        }
    }
    close(argc1.sock_serv);
    pthread_exit(0);
}

//在这个函数中需要把accept后的执行过程开启一个线程来执行

void server::startListen()
{
    int flag = listen(sock_serv, 5);
    if(flag < 0){
        perror("listen error!\n");
        close(sock_serv);
        return;
    }

    //char buffer[1024];

    while(1){

        //bzero(buffer,sizeof(buffer));

        struct sockaddr_in client_addr;
        int size = sizeof(client_addr);
        int sock_client = accept(sock_serv, (struct sockaddr*)(&client_addr), (unsigned int*)(&size));
        if(sock_client < 0){
            perror("accept error!\n");
            continue;
        }

        printf("%d\n",sock_client);

        argc arg1;
        arg1.sock_serv = sock_serv;
        arg1.sock_clt  = sock_client;

        pthread_t new_thread;
        flag = pthread_create(&new_thread,NULL,(void*(*)(void*))(&pthread_work),(void*)(&arg1));
        if(flag != 0){
            perror("thread creation failed!\n");
            continue;
        }
    }
}