| 网站首页 | 业界新闻 | 小组 | 威客 | 人才 | 下载频道 | 博客 | 代码贴 | 在线编程 | 编程论坛
欢迎加入我们,一同切磋技术
用户名:   
 
密 码:  
共有 897 人关注过本帖
标题:【IOCP】客户端连接后服务端没反映【四十分!!【可另开贴给分】!!求解决 ...
只看楼主 加入收藏
zxk112
Rank: 2
等 级:论坛游民
帖 子:11
专家分:26
注 册:2015-2-13
结帖率:100%
收藏
已结贴  问题点数:20 回复次数:7 
【IOCP】客户端连接后服务端没反映【四十分!!【可另开贴给分】!!求解决!!!!!!!!!!!!!】
困扰很长时间的一个问题。。一直没有解决。。就是。。服务端能监听端口, 也能与客户端建立连接。。 但是。客户端连接后。。怎么都没有反应
。。。我在ServerThreadFunc中的switch这句下一个断点。。断点只会在创建线程的时候被触发。。也不知道我说明白了没有。。

大体说就是:
服务端监听端口后。。客户端能连接。。但是服务端没有反应。。求解决。。


服务端代码- ServerThreadFunc
程序代码:
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();







[ 本帖最后由 zxk112 于 2015-2-14 16:58 编辑 ]
搜索更多相关主题的帖子: 服务端 客户端 断点 
2015-02-13 13:24
诸葛欧阳
Rank: 19Rank: 19Rank: 19Rank: 19Rank: 19Rank: 19
来 自:流年
等 级:贵宾
威 望:82
帖 子:2790
专家分:14619
注 册:2014-10-16
收藏
得分:7 
这个问题感觉叼炸天

一片落叶掉进了回忆的流年。
2015-02-13 14:29
zxk112
Rank: 2
等 级:论坛游民
帖 子:11
专家分:26
注 册:2015-2-13
收藏
得分:0 
回复 2楼 诸葛欧阳
救命啊。。。都好几天了。。一直没有解决。。还不知道问题处在那里。。求大神!!
2015-02-13 14:51
xzlxzlxzl
Rank: 15Rank: 15Rank: 15Rank: 15Rank: 15
来 自:湖北
等 级:贵宾
威 望:125
帖 子:1091
专家分:5825
注 册:2014-5-3
收藏
得分:7 
这是vc++里的问题吧,应该涉及mfc应用的。
我只会vb里面做tcp服务器、客户端连接,这里一头雾水啊!期望楼主问题得到解答。
2015-02-13 15:16
zxk112
Rank: 2
等 级:论坛游民
帖 子:11
专家分:26
注 册:2015-2-13
收藏
得分:0 
回复 4楼 xzlxzlxzl
IOCP的模型。。为啥会客户端连接一点反应都没有。

2015-02-13 17:24
zxk112
Rank: 2
等 级:论坛游民
帖 子:11
专家分:26
注 册:2015-2-13
收藏
得分:0 
都没有个人能帮忙么。。。
2015-02-14 11:34
tlliqi
Rank: 19Rank: 19Rank: 19Rank: 19Rank: 19Rank: 19
等 级:贵宾
威 望:204
帖 子:15453
专家分:65956
注 册:2006-4-27
收藏
得分:7 
牛人去哪了?  帮顶
2015-02-14 11:40
zxk112
Rank: 2
等 级:论坛游民
帖 子:11
专家分:26
注 册:2015-2-13
收藏
得分:0 
回复 7楼 tlliqi
谢楼上帮顶~~~唉。。牛人都去约情人了。。啊啊啊啊啊啊啊啊啊啊啊
2015-02-14 12:02
快速回复:【IOCP】客户端连接后服务端没反映【四十分!!【可另开贴给分】!!求 ...
数据加载中...
 
   



关于我们 | 广告合作 | 编程中国 | 清除Cookies | TOP | 手机版

编程中国 版权所有,并保留所有权利。
Powered by Discuz, Processed in 0.040668 second(s), 7 queries.
Copyright©2004-2024, BCCN.NET, All Rights Reserved