程序代码：

unsigned __stdcall ServerThreadFunc(void* pArguments)
{
    DWORD dwRecv = 0,
        dwSend=0,
        dwTransCount = 0,
        dwFlags=0;


    PPER_IO_DATA pPerIoData = NULL;

    PPER_HANDLE_DATA pPerHandleData = NULL;






    while (TRUE)
    {
        if (GetQueuedCompletionStatus(hIOCP, &dwTransCount, (LPDWORD)&pPerHandleData,

            (LPOVERLAPPED*)&pPerIoData, INFINITE))
        {
            if (0 == dwTransCount&&IO_QUIT == pPerIoData->TYPE)
            {
               

                EnterCriticalSection(&csLinkList);
                //从链表中删除
                LeaveCriticalSection(&csLinkList);
                closesocket(pPerHandleData->Socket);
                //continue;
            }
            switch (pPerIoData->TYPE)
            {
            case IO_SIGN:
               

                pPerHandleData->Socket = pPerIoData->socket;
                setsockopt(pPerIoData->socket, SOL_SOCKET, SO_UPDATE_ACCEPT_CONTEXT,
                    (char*)&(pPerHandleData->Socket), sizeof(pPerHandleData->Socket));
               


                //将新的客户套接字与完成端口连接
                CreateIoCompletionPort((HANDLE)pPerHandleData->Socket,
                    hIOCP, (ULONG_PTR)pPerHandleData, 0);

                memset(&(pPerIoData->OverLapped), 0, sizeof(OVERLAPPED));
                pPerIoData->TYPE = IO_RECV;        //将状态设置成接收
                //设置WSABUF结构
                pPerIoData->DataBuf.buf = pPerIoData->Buf;
                pPerIoData->DataBuf.len = 8192;
                dwFlags = 0;
                WSARecv(pPerHandleData->Socket, &pPerIoData->DataBuf, 1, &dwRecv, &dwFlags, (LPWSAOVERLAPPED)(pPerIoData), NULL);
                m_TabForm001.AddClient(_T("guid"), _T("ipp"));
                break;
            case IO_RECV:


                memset(&(pPerIoData->OverLapped), 0, sizeof(OVERLAPPED));
                pPerIoData->TYPE = IO_SEND;        //将状态设置成发送
                WSASend(pPerHandleData->Socket, &pPerIoData->DataBuf,
                    1, &dwSend, 0, &(pPerIoData->OverLapped), NULL);

                m_TabForm001.AddClient(_T("guid"), _T("i4174171pp"));




                break;
            case IO_SEND:
                m_TabForm001.AddClient(_T("guid"), _T("41414141414141414141171pp"));
                break;
            case IO_QUIT:

                break;






            default:
                break;
            }


        }







    }
    return TRUE;
}

程序代码：

int CIOCP::Init(int port)
{




    WSADATA wsa;
    memset(&wsa,0,sizeof(WSADATA));
    WSAStartup(MAKEWORD(2,2),&wsa);
    listenSocket = INVALID_SOCKET;

    listenSocket = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP,0,  0, WSA_FLAG_OVERLAPPED);

    if (listenSocket == INVALID_SOCKET)
    {
        WSACleanup();
        return FALSE;
    }


    SOCKADDR_IN localAddr;
    memset(&localAddr,0,sizeof(SOCKADDR_IN));
    localAddr.sin_family = AF_INET;
    localAddr.sin_addr.S_un.S_addr = INADDR_ANY;
    localAddr.sin_port = htons(4262);
    if (bind(listenSocket, (SOCKADDR*)&localAddr, sizeof(SOCKADDR)))
    {
        closesocket(listenSocket);
        WSACleanup();
        return FALSE;
    }



    if (listen(listenSocket, SOMAXCONN) != 0)
    {
        GetLastError();
        closesocket(listenSocket);
        WSACleanup();
        return FALSE;
    }




    hIOCP = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 0);

    if (hIOCP == NULL)
    {
        return FALSE;
    }

   



    LPFN_ACCEPTEX lpfnAcceptEx = NULL;
    GUID guidAcceptEx = WSAID_ACCEPTEX;
    DWORD dwBytes = 0;
    WSAIoctl(listenSocket, SIO_GET_EXTENSION_FUNCTION_POINTER,
        &guidAcceptEx, sizeof(guidAcceptEx), &lpfnAcceptEx, sizeof(lpfnAcceptEx),
        &dwBytes, NULL, NULL);







    SYSTEM_INFO si;
    GetSystemInfo(&si);
    //启动线程

    for (int i = 0; i < (si.dwNumberOfProcessors * 2 + 2); i++)
    {
        _beginthreadex(NULL,
            0,
            &ServerThreadFunc,
            NULL,
            0,
            0);
    }

    //投递 CUP*2+2个请求
    for (int i = 0; i < (si.dwNumberOfProcessors * 2 + 2); i++)
    {

        PPER_IO_DATA perIoData = new PER_IO_DATA;
        memset(&(perIoData->OverLapped), 0, sizeof(OVERLAPPED));
        perIoData->TYPE = IO_SIGN;
        //在使用AcceptEx前需要事先重建一个套接字用于其第二个参数。这样目的是节省时间
        //通常可以创建一个套接字库
        perIoData->socket = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP, 0, 0, WSA_FLAG_OVERLAPPED);
        DWORD flags = 0;

        lpfnAcceptEx(listenSocket, perIoData->socket, perIoData->DataBuf.buf,
            perIoData->DataBuf.len - ((sizeof(SOCKADDR_IN)+16) * 2),
            sizeof(SOCKADDR_IN)+16, sizeof(SOCKADDR_IN)+16, &dwBytes,
            &(perIoData->OverLapped));
    }

    return TRUE;
}

程序代码：

            WORD wVersionRequested;
            WSADATA wsaData;
            int err;

            wVersionRequested = MAKEWORD(1, 1);

            err = WSAStartup(wVersionRequested, &wsaData);
            if (err != 0) {
                return FALSE;
            }


            if (LOBYTE(wsaData.wVersion) != 1 ||
                HIBYTE(wsaData.wVersion) != 1) {
                WSACleanup();
                return FALSE;
            }

            while (true)
            {
                SOCKET sockClient = socket(AF_INET, SOCK_STREAM, 0);

                SOCKADDR_IN addrSrv;
                addrSrv.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
                addrSrv.sin_family = AF_INET;
                addrSrv.sin_port = htons(4262);
                connect(sockClient, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));
                while (1)
                {
                    printf(".");
                    send(sockClient, "This is lisi", strlen("This is lisi") + 1, 0);
                }
                char recvBuf[100];
                recv(sockClient, recvBuf, 100, 0);
                printf("%s\n", recvBuf);

                closesocket(sockClient);
            }

            WSACleanup();