windows网络编程模型

消息，事件，完成端口

// 00.TCP_CLIENT.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
// 1. 包含头文件及库  要写在其他头文件(类似windows.h)之前
#include <WinSock2.h>
#pragma comment(lib,"Ws2_32.lib")
DWORD WINAPI RecvThread(LPVOID lParam) {
    SOCKET sClient = (SOCKET)lParam;
    while (true)
    {
        char buf[1024] = {};
        int nRet = recv(sClient, buf, 1024, NULL);
        if (nRet == SOCKET_ERROR) {
            printf("服务器关闭\n");
            exit(0);
            return 0; 
        }
        printf("%s\n", buf);
    }
    return 0;
}
int main()
{   // 1. 信号检测
    WSADATA wsd = {};
    WSAStartup(MAKEWORD(2, 2), &wsd);
    if (LOBYTE(wsd.wVersion) != 2 ||
        HIBYTE(wsd.wVersion) != 2)
    {
        printf("库版本不支持\n");
        return 0;
    }
    // 2. 买手机
    SOCKET sClient = socket(
        AF_INET,// IP4协议
        SOCK_STREAM,// 流式套接字
        IPPROTO_TCP);// 协议类型(TCP)
    if (sClient == INVALID_SOCKET)
    {
        printf("创建socket失败！\n");
        WSACleanup();
        return 0;
    }
    // 3. 办卡
    SOCKADDR_IN addrSer = {};
    addrSer.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    addrSer.sin_port = htons(0x1234);// host to net short
    addrSer.sin_family = AF_INET;
    int nLen = sizeof(SOCKADDR_IN);
    // 绑定+通讯  直接和服务器通讯，自动绑定
    int nRet = connect(sClient, (SOCKADDR*)&addrSer, nLen);
    if (nRet == SOCKET_ERROR) { /*清理环境 关闭套接字*/return 0; }
    CreateThread(NULL, NULL, RecvThread, (LPVOID)sClient, NULL, NULL);
    while (true)
    {
        char buf[1024] = {};
        scanf_s("%s", buf, 1024);
        nRet = send(sClient, buf, 1024, NULL);
        if (nRet == SOCKET_ERROR)
        {
            closesocket(sClient);
            WSACleanup();
            return 0;
        }
    }
    return 0;
}

===================

#pragma once
#include <WinSock2.h>
#pragma comment(lib,"Ws2_32.lib")
#include <vector>
using std::vector;
class CMyTCP
{
public:
    CMyTCP();
    ~CMyTCP();
    SOCKET m_socket;
    vector<SOCKET> m_vecSocket;
    SOCKET TcpAccept();
    int TcpRecv(SOCKET s,char*buf,int nLen);
    bool InitServer(char* pIp="127.0.0.1",short port=0x1234);
    bool TcpClientExit(SOCKET s);
};

#include "stdafx.h"
#include "MyTCP.h"


CMyTCP::CMyTCP()
{
}


CMyTCP::~CMyTCP()
{
}

SOCKET CMyTCP::TcpAccept()
{
    SOCKADDR addr = {};
    int nLen = sizeof(SOCKADDR);
    SOCKET s = accept(m_socket, &addr, &nLen);
    if (s == INVALID_SOCKET)
    {
        return INVALID_SOCKET;
    }
    m_vecSocket.push_back(s);
    return s;
}



int CMyTCP::TcpRecv(SOCKET s, char*buf, int nLen)
{
    int nRet = recv(s, buf, nLen,NULL);
    if (nRet == SOCKET_ERROR) return nRet;
    for (auto &each:m_vecSocket)
    {
        if(each == s) continue;
        send(each, buf, nLen, NULL);
    }
    return nRet;
}

bool CMyTCP::InitServer(char* pIp/*="127.0.0.1"*/, short port/*=0x1234*/)
{
    // 1. 信号检测
    WSADATA wsd = {};
    WSAStartup(MAKEWORD(2, 2), &wsd);
    if (LOBYTE(wsd.wVersion) != 2 ||
        HIBYTE(wsd.wVersion) != 2)
    {
        printf("库版本不支持\n");
        return 0;
    }
    // 2. 买手机
    m_socket = socket(
        AF_INET,// IP4协议
        SOCK_STREAM,// 流式套接字
        IPPROTO_TCP);// 协议类型(TCP)
    if (m_socket == INVALID_SOCKET)
    {
        printf("创建socket失败！\n");
        WSACleanup();
        return 0;
    }
    // 3. 办卡
    SOCKADDR_IN addrSer = {};
    addrSer.sin_addr.S_un.S_addr = inet_addr(pIp);
    addrSer.sin_port = htons(port);// host to net short
    addrSer.sin_family = AF_INET;
    int nLen = sizeof(SOCKADDR_IN);
    int nRet = bind(m_socket, (SOCKADDR*)&addrSer, nLen);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    // 4. 监听
    nRet = listen(m_socket, SOMAXCONN);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    return true;
}

bool CMyTCP::TcpClientExit(SOCKET s)
{
    for (int i=0;i<m_vecSocket.size();i++)
    {
        if (m_vecSocket[i] == s)
        {
            m_vecSocket.erase(m_vecSocket.begin() + i);
            closesocket(s);
            return true;
        }
    }
    return false;
}

#pragma once
#include <WinSock2.h>
#pragma comment(lib,"Ws2_32.lib")
#include <vector>
using std::vector;
class CMyTCP
{
public:
    CMyTCP();
    ~CMyTCP();
    SOCKET m_socket;
    vector<SOCKET> m_vecSocket;
    SOCKET TcpAccept();
    int TcpRecv(SOCKET s,char*buf,int nLen);
    bool InitServer(char* pIp="127.0.0.1",short port=0x1234);
    bool TcpClientExit(SOCKET s);
};

#include "stdafx.h"
#include "MyTCP.h"


CMyTCP::CMyTCP()
{
}


CMyTCP::~CMyTCP()
{
}

SOCKET CMyTCP::TcpAccept()
{
    SOCKADDR addr = {};
    int nLen = sizeof(SOCKADDR);
    SOCKET s = accept(m_socket, &addr, &nLen);
    if (s == INVALID_SOCKET)
    {
        return INVALID_SOCKET;
    }
    m_vecSocket.push_back(s);
    return s;
}



int CMyTCP::TcpRecv(SOCKET s, char*buf, int nLen)
{
    int nRet = recv(s, buf, nLen,NULL);
    if (nRet == SOCKET_ERROR) return nRet;
    for (auto &each:m_vecSocket)
    {
        if(each == s) continue;
        send(each, buf, nLen, NULL);
    }
    return nRet;
}

bool CMyTCP::InitServer(char* pIp/*="127.0.0.1"*/, short port/*=0x1234*/)
{
    // 1. 信号检测
    WSADATA wsd = {};
    WSAStartup(MAKEWORD(2, 2), &wsd);
    if (LOBYTE(wsd.wVersion) != 2 ||
        HIBYTE(wsd.wVersion) != 2)
    {
        printf("库版本不支持\n");
        return 0;
    }
    // 2. 买手机
    m_socket = socket(
        AF_INET,// IP4协议
        SOCK_STREAM,// 流式套接字
        IPPROTO_TCP);// 协议类型(TCP)
    if (m_socket == INVALID_SOCKET)
    {
        printf("创建socket失败！\n");
        WSACleanup();
        return 0;
    }
    // 3. 办卡
    SOCKADDR_IN addrSer = {};
    addrSer.sin_addr.S_un.S_addr = inet_addr(pIp);
    addrSer.sin_port = htons(port);// host to net short
    addrSer.sin_family = AF_INET;
    int nLen = sizeof(SOCKADDR_IN);
    int nRet = bind(m_socket, (SOCKADDR*)&addrSer, nLen);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    // 4. 监听
    nRet = listen(m_socket, SOMAXCONN);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    return true;
}

bool CMyTCP::TcpClientExit(SOCKET s)
{
    for (int i=0;i<m_vecSocket.size();i++)
    {
        if (m_vecSocket[i] == s)
        {
            m_vecSocket.erase(m_vecSocket.begin() + i);
            closesocket(s);
            return true;
        }
    }
    return false;
}

// 02.TCP_SER_EVENT.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include "MyTCP.h"

int main()
{
    vector<HANDLE> m_vecEvent;
    vector<SOCKET> m_vecSocket;
    CMyTCP tcp;
    tcp.InitServer();
    HANDLE hEvent = WSACreateEvent();
    m_vecEvent.push_back(hEvent);
    // 当m_socket需要响应FD_ACCEPT | FD_CLOSE事件时
    // 系统会激活hEvent，把它变成有信号状态
    WSAEventSelect(tcp.m_socket, hEvent, FD_ACCEPT | FD_CLOSE);
    m_vecSocket.push_back(tcp.m_socket);
    while (true)
    {
        int nCount = m_vecEvent.size();
        // nCount不能超过64
        int nRet = WSAWaitForMultipleEvents(
            nCount,// 等待的事件个数 HEVENT
            &m_vecEvent[0], // 等待的多个事件的数组地址
            FALSE, // 是否等待所有事件都被激活
            INFINITE,// 等待超时时间
            FALSE);// 是否可警醒
        if (nRet == WSA_WAIT_FAILED) continue;
        int nIndex = nRet - WSA_WAIT_EVENT_0;
        // 获取被激活的事件对应的socket的网络事件
        WSANETWORKEVENTS we = {};
        WSAEnumNetworkEvents(m_vecSocket[nIndex], m_vecEvent[nIndex], &we);
        if (we.lNetworkEvents & FD_ACCEPT)
        {
            SOCKET s = tcp.TcpAccept();
            HANDLE hEvent2 = WSACreateEvent();
            m_vecEvent.push_back(hEvent2);
            // 当m_socket需要响应FD_ACCEPT | FD_CLOSE事件时
            // 系统会激活hEvent，把它变成有信号状态
            WSAEventSelect(s, hEvent2, FD_READ | FD_CLOSE);
            m_vecSocket.push_back(s);
        }
        if (we.lNetworkEvents & FD_READ)
        {
            char buf[1024] = {};
            tcp.TcpRecv(m_vecSocket[nIndex], buf, 1024);
            printf("%s\n", buf);
        }
        if (we.lNetworkEvents & FD_CLOSE)
        {
            if (we.iErrorCode[FD_CLOSE_BIT] != 0)
                printf("客户端流氓式关闭\n");
            else
            {
                printf("客户端退出\n");
            }
            tcp.TcpClientExit(m_vecSocket[nIndex]);
        }
    }
    return 0;
}

=========================

#pragma once
#include <WinSock2.h>
#pragma comment(lib,"Ws2_32.lib")
#include <vector>
using std::vector;
class CMyTCP
{
public:
    CMyTCP();
    ~CMyTCP();
    SOCKET m_socket;
    vector<SOCKET> m_vecSocket;
    SOCKET TcpAccept();
    int TcpRecv(SOCKET s,char*buf,int nLen);
    bool InitServer(char* pIp="127.0.0.1",short port=0x1234);
    bool TcpClientExit(SOCKET s);
};

#include "stdafx.h"
#include "MyTCP.h"


CMyTCP::CMyTCP()
{
}


CMyTCP::~CMyTCP()
{
}

SOCKET CMyTCP::TcpAccept()
{
    SOCKADDR addr = {};
    int nLen = sizeof(SOCKADDR);
    SOCKET s = accept(m_socket, &addr, &nLen);
    if (s == INVALID_SOCKET)
    {
        return INVALID_SOCKET;
    }
    m_vecSocket.push_back(s);
    return s;
}



int CMyTCP::TcpRecv(SOCKET s, char*buf, int nLen)
{
    for (auto &each:m_vecSocket)
    {
        if(each == s) continue;
        send(each, buf, nLen, NULL);
    }
    return true;
}

bool CMyTCP::InitServer(char* pIp/*="127.0.0.1"*/, short port/*=0x1234*/)
{
    // 1. 信号检测
    WSADATA wsd = {};
    WSAStartup(MAKEWORD(2, 2), &wsd);
    if (LOBYTE(wsd.wVersion) != 2 ||
        HIBYTE(wsd.wVersion) != 2)
    {
        printf("库版本不支持\n");
        return 0;
    }
    // 2. 买手机
    m_socket = socket(
        AF_INET,// IP4协议
        SOCK_STREAM,// 流式套接字
        IPPROTO_TCP);// 协议类型(TCP)
    if (m_socket == INVALID_SOCKET)
    {
        printf("创建socket失败！\n");
        WSACleanup();
        return 0;
    }
    // 3. 办卡
    SOCKADDR_IN addrSer = {};
    addrSer.sin_addr.S_un.S_addr = inet_addr(pIp);
    addrSer.sin_port = htons(port);// host to net short
    addrSer.sin_family = AF_INET;
    int nLen = sizeof(SOCKADDR_IN);
    int nRet = bind(m_socket, (SOCKADDR*)&addrSer, nLen);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    // 4. 监听
    nRet = listen(m_socket, SOMAXCONN);
    if (nRet == SOCKET_ERROR) {/*关闭套接字，清理环境*/return 0; }
    return true;
}

bool CMyTCP::TcpClientExit(SOCKET s)
{
    for (int i=0;i<m_vecSocket.size();i++)
    {
        if (m_vecSocket[i] == s)
        {
            m_vecSocket.erase(m_vecSocket.begin() + i);
            closesocket(s);
            return true;
        }
    }
    return false;
}

// 03.TCP_SER_IOCP.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include "MyTCP.h"
#include <windows.h>
CMyTCP g_tcp;

typedef struct _MYOVERLAPPED
{
    OVERLAPPED ol;
    WSABUF wsa;
    char buf[1024];
}MYOVERLAPPED,*PMYOVERLAPPED;

DWORD WINAPI IOCP_Thread(LPVOID lParam) {
    HANDLE hIOCP = lParam;
    while (true)
    {
        DWORD dwTransfered = 0;// 传输的字节数
        DWORD dwCompleteKey = 0;// 完成键
        PMYOVERLAPPED mol = 0;
        int nRet = GetQueuedCompletionStatus(
            hIOCP, &dwTransfered, &dwCompleteKey, (LPOVERLAPPED*)&mol, INFINITE);
        if (nRet == NULL && GetLastError() == ERROR_ABANDONED_WAIT_0)
        {
            printf("完成端口被关闭\n");
            return 0;
        }
        if (nRet == NULL && dwCompleteKey)
        {
            g_tcp.TcpClientExit(dwCompleteKey);
            printf("客户端退出\n");
            continue;
        }
        // 处理recv
        g_tcp.TcpRecv(dwCompleteKey, mol->buf, 1024);
        printf("%s\n", mol->buf);
        ZeroMemory(mol, sizeof(MYOVERLAPPED));
        mol->wsa.buf = mol->buf;
        mol->wsa.len = 1024;
        DWORD dwFlags = 0;
        WSARecv(
            dwCompleteKey,
            &mol->wsa,//读取的数据放在哪
            1,// 伪大小，把recv操作交给完成端口
            NULL,// 实际读取的大小，有OVERLAPPED不需要它
            &dwFlags,
            (LPOVERLAPPED)mol, NULL);
    }
    return 0;
}
int main()
{
    // 1 准备好完成端口
    SYSTEM_INFO si = {};
    GetSystemInfo(&si);
    HANDLE hIOCP = CreateIoCompletionPort(
        INVALID_HANDLE_VALUE, NULL, NULL, si.dwNumberOfProcessors);
    // 2. 完成端口的服务线程
    for (int i = 0; i < si.dwNumberOfProcessors*2; i++)
    {
        CreateThread(
            NULL, NULL, IOCP_Thread, hIOCP, NULL, NULL);
    }
    // 3. 绑定设备(socket)
    g_tcp.InitServer();
    while (true)
    {
        SOCKET sClient = g_tcp.TcpAccept();
        if (sClient == INVALID_SOCKET) return 0;
        // 把客户端socket和完成端口绑定
        CreateIoCompletionPort((HANDLE)sClient, hIOCP, sClient, NULL);
        PMYOVERLAPPED mol = new MYOVERLAPPED{};
        mol->wsa.buf = mol->buf;
        mol->wsa.len = 1024;
        DWORD dwFlags = 0;
        WSARecv(
            sClient,
            &mol->wsa,//读取的数据放在哪
            1,// 伪大小，把recv操作交给完成端口
            NULL,// 实际读取的大小，有OVERLAPPED不需要它
            &dwFlags,
            (LPOVERLAPPED)mol, NULL);
    }
    return 0;
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 202,607评论 5赞 476
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,047评论 2赞 379
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 149,496评论 0赞 335
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,405评论 1赞 273
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,400评论 5赞 364
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,479评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,883评论 3赞 395
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,535评论 0赞 256
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,743评论 1赞 295
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,544评论 2赞 319
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,612评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,309评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,881评论 3赞 306
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,891评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,136评论 1赞 259
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,783评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,316评论 2赞 342

推荐阅读更多精彩内容

  • 用c/c++语言在IPv6下的socket通信编程
    下面为Daytime这个服务的源代码例子，同时兼容IPV6和IPV4的地址，最后部分有更多说明。 单播模式下的Se...
    天楚锐齿阅读 5,559评论 0赞 2
  • iOS Socket
    大纲 一.Socket简介 二.BSD Socket编程准备 1.地址 2.端口 3.网络字节序 4.半相关与全相...
    VD2012阅读 2,257评论 0赞 5
  • 七、linux网络编程
    网络编程基础网络编程，首先了解计算机网络体系结构是有必要的，着重掌握TCP、IP协议，理解socket的概念，理解...
    zhile_doing阅读 1,853评论 0赞 1
  • 18、python网络编程
    网络编程 一.楔子 你现在已经学会了写python代码，假如你写了两个python文件a.py和b.py，分别去运...
    go以恒阅读 1,982评论 0赞 6
  • 唱歌没出息，你说的对
    许梦瑶打了男友许褚一巴掌，怒吼道：“你凭什么说以后唱歌没出息？” 男友也蒙了，自己好好地聊着，许梦瑶说以后自己能当...
    朱拉IT学长阅读 639评论 0赞 2