ReadMe.md

WinsockTut

尝试使用不同的WindowsI/O多路复用模型编写网络测试代码。

这是我在阅读Windows网络编程后的实践项目

Overview

I/O Model	Source File	Description
select() poller	src/SelectPoller.cpp	Linux和Windows都支持的API，大多数的跨平台网络库都会采用
WSAAsyncSelect() poller	src/AsyncSelectPoller.cpp	网络事件挂接到HWND消息
WSAEventSelect() poller	src/AsyncEventPoller.cpp	通过事件对象接收网络事件通知，64限制
Alertable I/O	N/A	本代码尚未实现
Overlapped I/O	src/OverlappedIOService.cpp	重叠I/O，也是通过事件对象接收网络事件通知，也有64限制，鸡肋
I/O Completion Port	src/CompletionPortService.cpp	Windows下性能最好的网络I/O多路复用模型

Introduction

所有的网络多路复用根据使用方式分别采用Reactor和Proactor的方式，做了简单抽象，根据简单的参数应用层示例即可选择不同的模型。

Reactor

select, WSAAsyncSelect和WSAEventSelect采用了Reactor模型，API设计参考了zeromq 如下所示:

class PollerBase 
{
    int AddFd(SOCKET fd, IPollEvent* event);    // 添加一个套接字fd到事件循环
    void RemoveFd(SOCKET fd);                   // 从事件循环中删除一个套接字fd
    void SetPollIn(SOCKET fd);                  // 设置关注套接字的读事件
    void ResetPollIn(SOCKET fd);                // 设置取消关注套接字的读事件
    void SetPollOut(SOCKET fd);                 // 设置关注套接字的写事件
    void ResetPollOut(SOCKET fd);               // 设置取消关注套接字的写事件
    int Poll(int timeout);                      // 事件循环
}

Proactor

I/O Completion Port和Overlapped I/O采用Proactor模型，API设计参考了boost.asio

如下所示：

class IOServiceBase
{
    int AsyncConnect(OverlapContext* ctx, const addrinfo*); // 连接一个addrinfo指定的地址， ctx中指定回调
    int AsyncAccept(OverlapContext* ctx);                   // accpet一个新套接字fd， ctx中指定回调
    int AsyncRead(OverlapContext* ctx);                     // 异步读网络数据， ctx中指定回调
    int AsyncWrite(OverlapContext* ctx);                    // 异步写网络数据， ctx中指定回调
    int Run(int timeout);                                   // 事件循环
}

如何构建

• 安装Visual Studio
• 安装CMake
• 使用CMake生成Visual Studio工程文件
• 使用Visual Studio打开工程

Example

使用Reactor模型的echo示例

echo示例

使用Proactor模型的ping/pong示例

pingpong示例

测试

tests目录下是用golang实现的echo server和echo client

备注

本代码仅作学习参考或者教学目的