c - WM_SOCKET ... FD_READ 没有响应-6ren

c - WM_SOCKET ... FD_READ 没有响应

转载作者：太空宇宙更新时间：2023-11-04 02:11:26

我正在使用 WM_SOCKET。服务器和客户端运行良好。但是如果我关闭客户端并重新打开它，FD_READ 不响应只有 FD_CLOSE 和 FD_ACCEPT 工作正常。请有人帮助我……

服务器代码:

#include <winsock2.h>
#include <windows.h>

#pragma comment(lib,"ws2_32.lib")

#define IDC_EDIT_IN     101
#define IDC_EDIT_OUT        102
#define IDC_MAIN_BUTTON 103
#define WM_SOCKET       104

int nPort=5555;

HWND hEditIn=NULL;
HWND hEditOut=NULL;
SOCKET Socket=NULL;
char szHistory[10000];
sockaddr sockAddrClient;

LRESULT CALLBACK WinProc(HWND hWnd,UINT message,WPARAM wParam,LPARAM lParam);

int WINAPI WinMain(HINSTANCE hInst,HINSTANCE hPrevInst,LPSTR lpCmdLine,int nShowCmd)
{
    WNDCLASSEX wClass;
    ZeroMemory(&wClass,sizeof(WNDCLASSEX));
    wClass.cbClsExtra=NULL;
    wClass.cbSize=sizeof(WNDCLASSEX);
    wClass.cbWndExtra=NULL;
    wClass.hbrBackground=(HBRUSH)COLOR_WINDOW;
    wClass.hCursor=LoadCursor(NULL,IDC_ARROW);
    wClass.hIcon=NULL;
    wClass.hIconSm=NULL;
    wClass.hInstance=hInst;
    wClass.lpfnWndProc=(WNDPROC)WinProc;
    wClass.lpszClassName="Window Class";
    wClass.lpszMenuName=NULL;
    wClass.style=CS_HREDRAW|CS_VREDRAW;

    if(!RegisterClassEx(&wClass))
    {
        int nResult=GetLastError();
        MessageBox(NULL,
            "Window class creation failed\r\nError code:",
            "Window Class Failed",
            MB_ICONERROR);
    }

    HWND hWnd=CreateWindowEx(NULL,  "Window Class", "Winsock Async Server",
            WS_OVERLAPPEDWINDOW,  200,  200,    640, 480, NULL, NULL, hInst,
            NULL);

    if(!hWnd)
    {
        int nResult=GetLastError();

        MessageBox(NULL,
            "Window creation failed\r\nError code:",
            "Window Creation Failed",
            MB_ICONERROR);
    }

    ShowWindow(hWnd,nShowCmd);

    MSG msg;
    ZeroMemory(&msg,sizeof(MSG));

    while(GetMessage(&msg,NULL,0,0))
    {
        TranslateMessage(&msg);
        DispatchMessage(&msg);
    }

    return 0;
}

LRESULT CALLBACK WinProc(HWND hWnd,UINT msg,WPARAM wParam,LPARAM lParam)
{
    switch(msg)
    {
        case WM_COMMAND:
            switch(LOWORD(wParam))
            {
                case IDC_MAIN_BUTTON:
                {
                    char szBuffer[1024];
                    ZeroMemory(szBuffer,sizeof(szBuffer));

                    SendMessage(hEditOut,
                        WM_GETTEXT,
                        sizeof(szBuffer),
                        reinterpret_cast<LPARAM>(szBuffer));

                    send(Socket,szBuffer,strlen(szBuffer),0);

                    SendMessage(hEditOut,WM_SETTEXT,NULL,(LPARAM)"");
                }
                break;
            }
            break;
        case WM_CREATE: 
        {
            ZeroMemory(szHistory,sizeof(szHistory));

            // Create incoming message box
            hEditIn=CreateWindowEx(WS_EX_CLIENTEDGE,    "EDIT", "",                 WS_CHILD|WS_VISIBLE|ES_MULTILINE|ES_AUTOVSCROLL|ES_AUTOHSCROLL,
                50, 120,    400,    200,    hWnd,   (HMENU)IDC_EDIT_IN,
                GetModuleHandle(NULL),
                NULL);
            if(!hEditIn)
            {
                MessageBox(hWnd,
                    "Could not create incoming edit box.",
                    "Error",
                    MB_OK|MB_ICONERROR);
            }
            HGDIOBJ hfDefault=GetStockObject(DEFAULT_GUI_FONT);
            SendMessage(hEditIn,
                    WM_SETFONT,
                    (WPARAM)hfDefault,
                    MAKELPARAM(FALSE,0));
            SendMessage(hEditIn,
                    WM_SETTEXT,
                    NULL,
                    (LPARAM)"Waiting for client to connect...");

            // Create outgoing message box
            hEditOut=CreateWindowEx(WS_EX_CLIENTEDGE, "EDIT",
                        "", WS_CHILD|WS_VISIBLE|ES_MULTILINE|
                        ES_AUTOVSCROLL|ES_AUTOHSCROLL,
                        50,  50,    400,  60, hWnd,
                        (HMENU)IDC_EDIT_IN,
                        GetModuleHandle(NULL),
                        NULL);
            if(!hEditOut)
            {
                MessageBox(hWnd,
                    "Could not create outgoing edit box.",
                    "Error",
                    MB_OK|MB_ICONERROR);
            }

            SendMessage(hEditOut,
                    WM_SETFONT,
                    (WPARAM)hfDefault,
                    MAKELPARAM(FALSE,0));
            SendMessage(hEditOut,
                    WM_SETTEXT,
                    NULL,
                    (LPARAM)"Type message here...");

            // Create a push button
            HWND hWndButton=CreateWindow(    "BUTTON",
                        "Send",
                        WS_TABSTOP|WS_VISIBLE|
                        WS_CHILD|BS_DEFPUSHBUTTON,
                        50, 330,    75, 23,
                        hWnd,   (HMENU)IDC_MAIN_BUTTON,
                        GetModuleHandle(NULL),
                        NULL);

            SendMessage(hWndButton,
                WM_SETFONT,
                (WPARAM)hfDefault,
                MAKELPARAM(FALSE,0));

            WSADATA WsaDat;
            int nResult=WSAStartup(MAKEWORD(2,2),&WsaDat);
            if(nResult!=0)
            {
                MessageBox(hWnd,
                    "Winsock initialization failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            Socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
            if(Socket==INVALID_SOCKET)
            {
                MessageBox(hWnd,
                    "Socket creation failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            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)
            {
                MessageBox(hWnd,"Unable to bind socket","Error",MB_OK);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            nResult=WSAAsyncSelect(Socket,
                    hWnd,
                    WM_SOCKET,
                    (FD_CLOSE|FD_ACCEPT|FD_READ));
            if(nResult)
            {
                MessageBox(hWnd,
                    "WSAAsyncSelect failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            if(listen(Socket,(1))==SOCKET_ERROR)
            {
                MessageBox(hWnd,
                    "Unable to listen!",
                    "Error",
                    MB_OK);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }
        }
        break;

        case WM_DESTROY:
        {
            PostQuitMessage(0);
            shutdown(Socket,SD_BOTH);
            closesocket(Socket);
            WSACleanup();
            return 0;
        }
        break;

        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);

                    strncat(szHistory,szIncoming,inDataLength);
                    strcat(szHistory,"\r\n");

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

                case FD_CLOSE:
                {
                    MessageBox(hWnd,
                        "Client closed connection",
                        "Connection closed!",
                        MB_ICONINFORMATION|MB_OK);                           }
                break;

                case FD_ACCEPT:
                {
                    int size=sizeof(sockaddr);
                    Socket=accept(wParam,&sockAddrClient,&size);                
                    if (Socket==INVALID_SOCKET)
                    {
                        int nret = WSAGetLastError();
                        WSACleanup();
                    }
                    SendMessage(hEditIn,
                        WM_SETTEXT,
                        NULL,
                        (LPARAM)"Client connected!");
                }
                break;
                }   
            }
        }

    return DefWindowProc(hWnd,msg,wParam,lParam);
}

客户端代码:

#include <winsock2.h>
#include <windows.h>

#pragma comment(lib,"ws2_32.lib")

#define IDC_EDIT_IN     101
#define IDC_EDIT_OUT        102
#define IDC_MAIN_BUTTON     103
#define WM_SOCKET       104

char *szServer="localhost";
int nPort=5555;

HWND hEditIn=NULL;
HWND hEditOut=NULL;
SOCKET Socket=NULL;
char szHistory[10000];

LRESULT CALLBACK WinProc(HWND hWnd,UINT message,WPARAM wParam,LPARAM lParam);

int WINAPI WinMain(HINSTANCE hInst,HINSTANCE hPrevInst,LPSTR lpCmdLine,int nShowCmd)
{
    WNDCLASSEX wClass;
    ZeroMemory(&wClass,sizeof(WNDCLASSEX));
    wClass.cbClsExtra=NULL;
    wClass.cbSize=sizeof(WNDCLASSEX);
    wClass.cbWndExtra=NULL;
    wClass.hbrBackground=(HBRUSH)COLOR_WINDOW;
    wClass.hCursor=LoadCursor(NULL,IDC_ARROW);
    wClass.hIcon=NULL;
    wClass.hIconSm=NULL;
    wClass.hInstance=hInst;
    wClass.lpfnWndProc=(WNDPROC)WinProc;
    wClass.lpszClassName="Window Class";
    wClass.lpszMenuName=NULL;
    wClass.style=CS_HREDRAW|CS_VREDRAW;

    if(!RegisterClassEx(&wClass))
    {
        int nResult=GetLastError();
        MessageBox(NULL,
            "Window class creation failed\r\nError code:",
            "Window Class Failed",
            MB_ICONERROR);
    }

    HWND hWnd=CreateWindowEx(NULL,
            "Window Class",
            "Windows Async Client",
            WS_OVERLAPPEDWINDOW,
            200,
            200,
            640,
            480,
            NULL,
            NULL,
            hInst,
            NULL);

    if(!hWnd)
    {
        int nResult=GetLastError();

        MessageBox(NULL,
            "Window creation failed\r\nError code:",
            "Window Creation Failed",
            MB_ICONERROR);
    }

    ShowWindow(hWnd,nShowCmd);

    MSG msg;
    ZeroMemory(&msg,sizeof(MSG));

    while(GetMessage(&msg,NULL,0,0))
    {
        TranslateMessage(&msg);
        DispatchMessage(&msg);
    }

    return 0;
}

LRESULT CALLBACK WinProc(HWND hWnd,UINT msg,WPARAM wParam,LPARAM lParam)
{
    switch(msg)
    {
        case WM_CREATE:
        {
            ZeroMemory(szHistory,sizeof(szHistory));

            // Create incoming message box
            hEditIn=CreateWindowEx(WS_EX_CLIENTEDGE,
                "EDIT",
                "",
                WS_CHILD|WS_VISIBLE|ES_MULTILINE|
                ES_AUTOVSCROLL|ES_AUTOHSCROLL,
                50,
                120,
                400,
                200,
                hWnd,
                (HMENU)IDC_EDIT_IN,
                GetModuleHandle(NULL),
                NULL);
            if(!hEditIn)
            {
                MessageBox(hWnd,
                    "Could not create incoming edit box.",
                    "Error",
                    MB_OK|MB_ICONERROR);
            }
            HGDIOBJ hfDefault=GetStockObject(DEFAULT_GUI_FONT);
            SendMessage(hEditIn,
                WM_SETFONT,
                (WPARAM)hfDefault,
                MAKELPARAM(FALSE,0));
            SendMessage(hEditIn,
                WM_SETTEXT,
                NULL,
                (LPARAM)"Attempting to connect to server...");

            // Create outgoing message box
            hEditOut=CreateWindowEx(WS_EX_CLIENTEDGE,
                        "EDIT",
                        "",
                        WS_CHILD|WS_VISIBLE|ES_MULTILINE|
                        ES_AUTOVSCROLL|ES_AUTOHSCROLL,
                        50,
                        50,
                        400,
                        60,
                        hWnd,
                        (HMENU)IDC_EDIT_IN,
                        GetModuleHandle(NULL),
                        NULL);
            if(!hEditOut)
            {
                MessageBox(hWnd,
                    "Could not create outgoing edit box.",
                    "Error",
                    MB_OK|MB_ICONERROR);
            }

            SendMessage(hEditOut,
                WM_SETFONT,(WPARAM)hfDefault,
                MAKELPARAM(FALSE,0));
            SendMessage(hEditOut,
                WM_SETTEXT,
                NULL,
                (LPARAM)"Type message here...");

            // Create a push button
            HWND hWndButton=CreateWindow( 
                        "BUTTON",
                        "Send",
                        WS_TABSTOP|WS_VISIBLE|
                        WS_CHILD|BS_DEFPUSHBUTTON,
                        50, 
                        330,
                        75,
                        23,
                        hWnd,
                        (HMENU)IDC_MAIN_BUTTON,
                        GetModuleHandle(NULL),
                        NULL);

            SendMessage(hWndButton,
                WM_SETFONT,
                (WPARAM)hfDefault,
                MAKELPARAM(FALSE,0));

            // Set up Winsock
            WSADATA WsaDat;
            int nResult=WSAStartup(MAKEWORD(2,2),&WsaDat);
            if(nResult!=0)
            {
                MessageBox(hWnd,
                    "Winsock initialization failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            Socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
            if(Socket==INVALID_SOCKET)
            {
                MessageBox(hWnd,
                    "Socket creation failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            nResult=WSAAsyncSelect(Socket,hWnd,WM_SOCKET,(FD_CLOSE|FD_READ));
            if(nResult)
            {
                MessageBox(hWnd,
                    "WSAAsyncSelect failed",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            // Resolve IP address for hostname
            struct hostent *host;
            if((host=gethostbyname(szServer))==NULL)
            {
                MessageBox(hWnd,
                    "Unable to resolve host name",
                    "Critical Error",
                    MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }

            // Set up our socket address structure
            SOCKADDR_IN SockAddr;
            SockAddr.sin_port=htons(nPort);
            SockAddr.sin_family=AF_INET;
            SockAddr.sin_addr.s_addr=*((unsigned long*)host->h_addr);

            connect(Socket,(LPSOCKADDR)(&SockAddr),sizeof(SockAddr));
        }
        break;

        case WM_COMMAND:
            switch(LOWORD(wParam))
            {
                case IDC_MAIN_BUTTON:
                {
                    char szBuffer[1024];

                    int test=sizeof(szBuffer);
                    ZeroMemory(szBuffer,sizeof(szBuffer));

                    SendMessage(hEditOut,
                        WM_GETTEXT,
                        sizeof(szBuffer),
                        reinterpret_cast<LPARAM>(szBuffer));
                    send(Socket,szBuffer,strlen(szBuffer),0);
                    SendMessage(hEditOut,WM_SETTEXT,NULL,(LPARAM)"");
                }
                break;
            }
            break;

        case WM_DESTROY:
        {
            PostQuitMessage(0);
            shutdown(Socket,SD_BOTH);
            closesocket(Socket);
            WSACleanup();
            return 0;
        }
        break;

        case WM_SOCKET:
        {
            if(WSAGETSELECTERROR(lParam))
            {   
                MessageBox(hWnd,
                    "Connection to server failed",
                    "Error",
                    MB_OK|MB_ICONERROR);
                SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                break;
            }
            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);

                    strncat(szHistory,szIncoming,inDataLength);
                    strcat(szHistory,"\r\n");

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

                case FD_CLOSE:
                {
                    MessageBox(hWnd,
                        "Server closed connection",
                        "Connection closed!",
                        MB_ICONINFORMATION|MB_OK);
                    closesocket(Socket);
                    SendMessage(hWnd,WM_DESTROY,NULL,NULL);
                }
                break;
            }
        } 
    }

    return DefWindowProc(hWnd,msg,wParam,lParam);
}

最佳答案

您有多个问题。第一个是您在 FD_READ 和 FD_WRITE 事件的被动监听套接字上执行 WSAAsyncSelect。被动套接字不会接收这些事件。第二个是您没有在实际连接的套接字上执行WSAAsyncSelect。

还有其他问题，最严重的是您只为套接字保留一个变量。这意味着当你接受时你会松开“主”套接字，并且你不能有多个连接(每个新连接都会覆盖套接字变量)。您实际上也没有在 FD_CLOSE 上关闭套接字(它不是自动完成的)，而且可能还有更多我到目前为止还没有发现的东西。

关于c - WM_SOCKET ... FD_READ 没有响应，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/13505965/

文章推荐： c - 从文件中读取矩阵并计算行列式(C 语言)

文章推荐： python - Numpy 通过分组数组拆分数组

文章推荐： Python:使用函数导入多个变量

文章推荐： c - OS X 上的 vsprintf : EXC_BAD_ACCESS

php - Ajax 响应 HTML 响应
我正在尝试检查 Entry 中是否存在重复项，并使用内联消息提醒用户该数字存在。 $(document).ready(function(){ $("#con1").blur(function(
python - 如何在基于类的 View 中返回 JSON 响应，而不是 HTTP 响应
我有一个基于类的 View 。我在引导模式上使用 Ajax。为了避免页面刷新，我想使用此类基于 View 返回 JSON 响应而不是 HTTP 响应，但我只看到了如何为基于函数的 View 返回 JS
C# Hue Bridge PUT 发送 OK 响应。无 API 响应
关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。这个问题是由于错别字或无法再重现的问题引起的。虽然类似的问题可能是on-topi
http-status-codes - 根除 401 "Unauthorised"响应，然后是 200 "Ok"响应
我有一个大型内部企业基于 Web 的应用程序在 IIS6 上运行 ASP.NET 3.5，生成 401 个“未经授权”响应，然后是 200 个“Ok”响应(如 Fiddler 所述)。我知道为什么会发
javascript - Express 不会从一个 Controller 返回 HTTP 响应，但在其他 Controller 中会返回 HTTP 响应
感谢您研究我的问题。我有一个node/express服务器，配置了一个server.js文件，它调用urls.js，而urls.js又调用 Controller 来处理http请求，所有这些都配置相
node.js - Curl 正在获取 POST 响应，但 Node.js 未获取 POST 响应
当我使用以下命令时，我得到正确的 JSON 响应: $ curl --data "regno=&dob=&mobile=" https://vitacademics-rel.herokuapp.co
RESTful POST 响应
我有一个非常简单的 RESTful 服务，它通过 POST 接收一些表单数据，其目的是在云存储(Amazon S3、Azure Blob 存储等)中简单地保留文本主体(具有唯一 ID)作为一个文件..
sockets - UDP 响应
UDP 不发送任何 ack，但它会发送任何响应吗？我已经设置了客户端服务器UDP程序。如果我让客户端向不存在的服务器发送数据，那么客户端会收到任何响应吗？我的假设是；客户端 --> 广播服务器地
scala - 如何在电梯中记录请求/响应
我有一个电梯项目，其中有一个扩展 RestHelper 的类，看起来像这样 serve{ "api" / "mystuff" prefix { case a
Kong 自定义错误消息/响应
我们正在寻求覆盖 Kong 错误响应结构并编写自定义消息(即用我们的自定义消息替换“超出 API 速率限制”、“无效的身份验证凭据”等)。我们要找的错误响应结构(代码是自定义的内部错误代码，与HTT
iphone - 响应 EKEventStoreChangedNotification
我正在尝试监听 EKEventStoreChangedNotification 以检查当我的应用程序处于后台时日历是否已更改。我在 View Controller 的 initWithNibMeth
javascript - 响应.写入divIDE
我了解 javascript，并且正在学习 ASP.NET C# 我想要做什么(完成的是javascript): document.getElementById('divID-1'
java - 在Java中的BrowserMob中仅获取POST请求/响应
是否可以过滤所有 har 对象并仅获取 POST 请求/响应？也许在初始化 BrowserMobProxyServer 期间是这样做的方法？我需要将 har 对象保存到文件中并上传到 har 查看器。
php - Symfony2 响应
我正在尝试向 Oauth 的 API 发送响应。遗憾的是，Symfony2 文档在解释 $response->headers->set(...); 的所有不同部分方面做得很差。这是我的 OauthC
python 响应 - 并非所有请求都已执行
我正在尝试测试用例来模拟 api 调用，并使用 python 响应来模拟 api 调用。下面是我的模拟， with responses.RequestsMock() as rsps: url
haskell - 我将如何以可扩展的方式抽象命令/响应？
在尝试在 Haskell 中进行一些领域驱动设计时，我发现自己遇到了这个问题: data FetchAccessories = FetchAccessories data AccessoriesRes
java - 如何在项目reactor中设置阻塞异步请求/响应？
我正在与 ANT+ USB 棒连接，并用项目 react 器替换我自己天真的“MessageBus”，因为它看起来非常合适。 USB接口(interface)本质上是异步的(单独的输入/输出管道)，我
ios - 如何使用AFHTTPSessionManager记录每个请求/响应？
我正在将项目迁移到AFNetworking 2.0。使用AFNetworking 1.0时，我编写了代码来记录控制台中的每个请求/响应。这是代码: -(AFHTTPRequestOperation *
php - Ajax 响应
我有以下代码段。 ajaxRequest.onreadystatechange = function(){ if(ajaxRequest.readyState == 4){
来自帖子的 Jquery 响应
我有问题......我在 php 中有一个监听器脚本可以执行以下操作: if ($count != 1) {echo 'no';} else { echo "yes";} 因此它会回显"is"或“

太空宇宙

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

c - WM_SOCKET ... FD_READ 没有响应