依睛(IT blog) 我回来了，PHP<-->C/C++ LINUX

socket 多线程代码

多线程, 多客户端同时连接服务器源代码:

费活少说了, 代码出来吧.
代码可以运行. 因没时间 没写太详细 
/************************
client.cpp
************************/

#include <windows.h>
#include <iostream>
#pragma comment(lib, "ws2_32")

#define LEN          1024
#define TRUE            1
#define FALSE_F           -1
#define OK              1
#define ERROR_R         -1

int main()
{
    int          i=100;
    int             ret;
    char         buf1[LEN];
    char         buf[LEN];
    WORD            wdVersionRequired;
    WSADATA         wsaData;
 
    memset(buf, 0, sizeof(buf));
    memset(buf1, 0, sizeof(buf1));

 wdVersionRequired = MAKEWORD(2, 2);  /* 2.2°汾 */
 WSAStartup(wdVersionRequired, &wsaData);

    while(i--)
    {
        SOCKET              sock;
        sockaddr_in      saServer;

        sock = socket(AF_INET, SOCK_STREAM, 0);
        if (SOCKET_ERROR == sock)
        {
            return FALSE;
        }

     memset(&saServer, 0, sizeof(saServer));
     saServer.sin_family = AF_INET;
     saServer.sin_addr.S_un.S_addr = inet_addr("192.168.2.80");
     saServer.sin_port = htons(8066);

     if(connect(sock, (const sockaddr*)&saServer, sizeof(sockaddr)) != 0)
     {
     printf("connect error\n");
     }

        memset(buf, 0, sizeof(buf));
        strcpy(buf, "hello world");

        if(0 == send(sock, buf, strlen(buf), 0)) 
        {
            printf("send error\n");
            break;
        }
        ret = recv(sock, buf1, sizeof(buf1), 0);

        buf1[ret]='\0';
        printf("buf1: %s\n\n", buf1);
     closesocket(sock);
    }

 WSACleanup();
 return 1;
}

================================================
/*******************************
server.cpp
********************************/

#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "ws2_32")

#define LEN          1024
#define OK              1
#define ERROR_R         -1
#define FALSE           0
#define TRUE            1

DWORD  WINAPI  AnswerThread(LPVOID  lparam) 
{ 

    int                 err;
    char                buf[32]=""; 
    char                recvbuf[32]="yes receive!!";
    SOCKET              ClientSocket=(SOCKET)(LPVOID)lparam; 

  //  memset(recvbuf, 0, sizeof(recvbuf));
    memset(buf, 0, sizeof(buf));

    err = recv(ClientSocket, buf, sizeof(buf), 0);
    send(ClientSocket, recvbuf, strlen(recvbuf), 0);
    buf[err]='\0';
    printf("revc: %s\n", buf);
    closesocket(ClientSocket);
    return  OK; 
} 

int main()
{
    int        err;
    SOCKET       sock;
    SOCKET       sClient; 
    DWORD               dwThreadId; 
    WORD                wdVersionRequired;  
    HANDLE              hThread;
    WSADATA             wsaData;
    sockaddr_in         saServer, cli_addr;
    int                 len = sizeof(cli_addr);

 wdVersionRequired = MAKEWORD(2, 2); //³ÌÐòҪʹÓÃ2.2°æ±¾
 //×¢Ò⺯Êý·µ»ØÖµ£¬0±íʾÕý³£
 if ((err = WSAStartup(wdVersionRequired, &wsaData)) != 0)// ³õʼ»¯WinSock¿â¡£
        return FALSE;

 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
  printf(" create socket error\n");
    }

 saServer.sin_family = AF_INET;
 saServer.sin_addr.S_un.S_addr = inet_addr("192.168.2.80");
 saServer.sin_port = htons(8066);

 if ((err = bind(sock, (const sockaddr *)&saServer, sizeof(sockaddr)))!= 0)
    {
        printf("failed bind\n");    
    }

 if ((err = listen(sock, 100)) != 0)//listen()¼àÌý
    {
        printf("failed listen\n");
    }

    while(1)
    {
        sClient = accept(sock, (struct sockaddr*)&cli_addr, &len);
        Sleep(1000);
        hThread=CreateThread(NULL,NULL, AnswerThread,(LPVOID)sClient, 0, &dwThreadId); 
        if(hThread==NULL)   
            printf("CreatThread  AnswerThread()  failed.\n"); 
        else
            printf("CreateThread  OK.\n"); 
    }
   
 closesocket(sock);
 WSACleanup();

 return TRUE;
}

posted on 2008-11-24 22:11 向左向右走 阅读(2176) 评论(1)  编辑 收藏 引用 所属分类: C/C++学习资料库