0

我正在尝试在异步模式下使用 winsock2。我能够将消息从客户端发送到服务器，但不能从服务器发送到客户端。当我在客户端调用 recv 时，缓冲区中没有收到任何内容。

这是我的客户代码

ClientSocket::ClientSocket (HWND& pHwnd)
{   
    WSADATA     wsdata;

    vSzIncoming     =   0;

    int error = WSAStartup (MAKEWORD(2,2), &wsdata);

    vSocket = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);

    error = WSAAsyncSelect (vSocket, pHwnd, WM_SOCKET, (FD_CLOSE | FD_READ));

    vHwnd           =   pHwnd;
    vIsConnected    =   false;
}

bool ClientSocket::ConnectToServer () 
{       

SockAddr.sin_port           =   htons (20000);
SockAddr.sin_family         =   AF_INET;
SockAddr.sin_addr.s_addr    =   inet_addr ("127.0.0.1");

if(connect (vSocket, (LPSOCKADDR)(&SockAddr), sizeof (SockAddr)) == SOCKET_ERROR) {


    vIsConnected = false;
    return false;
}

vIsConnected = true;
return true;
}

void ClientSocket::SendMsg (const MessageGenerator& pMessageGenerator)
{   
    send(vSocket, pMessageGenerator.GetMessage ().Buffer (), pMessageGenerator.GetLength (), 0);
}

char * ClientSocket::ReceiveMsg ()
{   
char temp[1024];
ZeroMemory (temp, sizeof (temp));

int inDataLength = recv (vSocket,
                    (char*)temp,
                     sizeof (temp) / sizeof (temp [0]),
                     0);
return temp;
}

这是服务器代码

WSADATA WsaDat;
        int nResult=WSAStartup(MAKEWORD(2,2),&WsaDat);


        Socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);

        SOCKADDR_IN SockAddr;
        SockAddr.sin_port=htons(nPort);
        SockAddr.sin_family=AF_INET;
        SockAddr.sin_addr.s_addr=htonl(INADDR_ANY);

        if(bind(Socket,(LPSOCKADDR)&SockAddr,sizeof(SockAddr))==SOCKET_ERROR)
        {

        }

        nResult=WSAAsyncSelect(Socket,
                hWnd,
                WM_SOCKET,
                (FD_CLOSE|FD_ACCEPT|FD_READ));

        if(listen(Socket,(1))==SOCKET_ERROR)
        {

        }

//发送部分

String str ="1;yahoo;|";
send(Socket,str.Buffer(),str.GetLength(),0);

//接收部分

case WM_SOCKET:
    {
        switch(WSAGETSELECTEVENT(lParam))
        {
            case FD_READ:
            {
                char szIncoming[1024];
                ZeroMemory(szIncoming,sizeof(szIncoming));

                int inDataLength=recv(Socket,
                    (char*)szIncoming,
                    sizeof(szIncoming)/sizeof(szIncoming[0]),
                    0);

                String str(szIncoming);

                wcsncat(szHistory,str.GetTChar(),inDataLength);
                wcscat(szHistory,L"\r\n");


                SendMessage(hEditIn,
                    WM_SETTEXT,
                    sizeof(szIncoming)-1,
                    reinterpret_cast<LPARAM>(&szHistory));
            }

case FD_ACCEPT:
            {
                int size=sizeof(sockaddr);
                Socket=accept(wParam,&sockAddrClient,&size);                
            }

请帮我

4

1 回答 1

1

很难说你的问题出在哪里。最好的解决方案是系统地消除所有可能的障碍：

  • 检查 的返回值recv。如果出现错误，您的缓冲区不会被触及，因此会返回一个“空”字符串。
  • 如果使用了正确的客户端套接字，请检查您的服务器端。您使用“Socket”变量名的次数过多。最好是区分客户端套接字和服务器套接字。另外：您如何存储客户端套接字？这是在全局变量还是静态变量中？你确定这个值是正确的吗？（这一点主要是针对您的服务器端代码）
  • 使用日志记录扩展您的代码，以便您可以跟踪客户端和服务器端发生的事情。调试器也可能对此有所帮助。

还有一个相当大的错误，你应该在你的代码中立即纠正：

char * ClientSocket::ReceiveMsg ()
{   
    char temp[1024];
    ZeroMemory (temp, sizeof (temp));

    int inDataLength = recv (vSocket,
                        (char*)temp,
                         sizeof (temp) / sizeof (temp [0]),
                         0);
    return temp; // ** don't return a local memory "object" **
}

不要那样做。要么使用_strdup返回副本，要么使用并返回您的“字符串”对象。当然，如果您正在使用_strdup调用者，则必须使用适当的函数 ( ) 来释放内存free。啊，是的，第三种可能性是只期望缓冲区像 recv 一样作为参数给出。

于 2011-09-16T07:22:05.510 回答