c# AcceptEx与完成端口(IOCP)结合的示例
作者:源之缘 发布时间:2023-07-29 01:46:24
前言
在windows平台下实现高性能网络服务器,iocp(完成端口)是唯一选择。编写网络服务器面临的问题有:
1 快速接收客户端的连接。
2 快速收发数据。
3 快速处理数据。本文主要解决第一个问题。
AcceptEx函数定义
BOOL AcceptEx(
SOCKET sListenSocket,
SOCKET sAcceptSocket,
PVOID lpOutputBuffer,
DWORD dwReceiveDataLength,
DWORD dwLocalAddressLength,
DWORD dwRemoteAddressLength,
LPDWORD lpdwBytesReceived,
LPOVERLAPPED lpOverlapped
);
为什么要用AcceptEx
传统的accept函数能满足大部分场景的需要;但在某些极端条件下,必须使用acceptEx来实现。两个函数的区别如下:
1)accept是阻塞的;在一个端口监听,必须启动一个专用线程调用accept。当然也可以用迂回的方式,绕过这个限制,处理起来会很麻烦,见文章单线程实现同时监听多个端口。acceptEx是异步的,可以同时对很多端口监听(监听端口的数量没有上限的限制)。采用迂回的方式,使用accept监听,一个线程最多监听64个端口。这一点可能不是AcceptEx最大优点,毕竟同时对多个端口监听的情况非常少见。
2)AcceptEx可以返回更多的数据。a)AcceptEx可以返回本地和对方ip地址和端口;而不需要调用函数getsockname和getpeername获取网络地址了。b)AcceptEx可以再接收到一段数据后,再返回。这种做法有利有弊,一般不建议这样做。
3)AcceptEx是先准备套接字(socket)后接收。为了应对突发的连接高峰,可以多次投放AcceptEx。accept是事后建立SOCKET,就是tcp三次握手完成后,accept调用才返回,再生成socket。生成套接字是相对比较耗时的操作,accept的方式无法及时处理突发连接。对于AcceptEx的处理方式为建议做如下处理:一个线程负责创建socket,一个线程负责处理AcceptEx返回。
以上仅仅通过文字说明了AcceptEx的特点。下面通过具体代码,逐一剖析。我将AcceptEx的处理封装到类IocpAcceptEx中。编写该类时,尽量做到高内聚低耦合,使该类可以方便的被其他模块使用。
IocpAcceptEx外部功能说明
class IocpAcceptEx
{
public:
IocpAcceptEx();
~IocpAcceptEx();
//设置回调接口。当accept成功,调用回调接口。
void SetCallback(IAcceptCallback* callback);
// 增加监听端口
void AddListenPort(UINT16 port);
//启动服务
BOOL Start();
void Stop();
。。。以下代码省略
}
#define POST_ACCEPT 1
//使用IocpAcceptEx类,必须实现该接口。接收客户端的连接
class IAcceptCallback
{
public:
virtual void OnAcceptClient(SOCKET hSocketClient, UINT16 nListenPort) = 0;
};
该类的调用函数很简单,对外接口也很明确。说明该类的职责很清楚,这也符合单一职责原则。
实现步骤说明
AcceptEx不但需要与监听端口绑定,还需要与完成端口绑定。所以程序的第一步是创建完成端口:
a)创建完成端口
m_hIocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, NULL, 0);
if (m_hIocp == NULL)
return FALSE;
b)监听端口创建与绑定
//生成套接字
SOCKET serverSocket = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP, NULL, 0, WSA_FLAG_OVERLAPPED);
if (serverSocket == INVALID_SOCKET)
{
return false;
}
//绑定
SOCKADDR_IN addr;
memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = INADDR_ANY ;
addr.sin_port = htons(port);
if (bind(serverSocket, (sockaddr *)&addr, sizeof(addr)) != 0)
{
closesocket(serverSocket);
serverSocket = INVALID_SOCKET;
return false;
}
//启动监听
if (listen(serverSocket, SOMAXCONN) != 0)
{
closesocket(serverSocket);
serverSocket = INVALID_SOCKET;
return false;
}
//监听端口与完成端口绑定
if (CreateIoCompletionPort((HANDLE)serverSocket, m_hIocp, (ULONG_PTR)this, 0) == NULL)
{
closesocket(serverSocket);
serverSocket = INVALID_SOCKET;
return false;
}
c)投递AcceptEx
struct AcceptOverlapped
{
OVERLAPPED overlap;
INT32 opType;
SOCKET serverSocket;
SOCKET clientSocket;
char lpOutputBuf[128];
DWORD dwBytes;
};
int IocpAcceptEx::NewAccept(SOCKET serverSocket)
{
//创建socket
SOCKET _socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
AcceptOverlapped *ov = new AcceptOverlapped();
ZeroMemory(ov,sizeof(AcceptOverlapped));
ov->opType = POST_ACCEPT;
ov->clientSocket = _socket;
ov->serverSocket = serverSocket;
//存放网络地址的长度
int addrLen = sizeof(sockaddr_in) + 16;
int bRetVal = AcceptEx(serverSocket, _socket, ov->lpOutputBuf,
0,addrLen, addrLen,
&ov->dwBytes, (LPOVERLAPPED)ov);
if (bRetVal == FALSE)
{
int error = WSAGetLastError();
if (error != WSA_IO_PENDING)
{
closesocket(_socket);
return 0;
}
}
return 1;
}
AcceptEx是非阻塞操作,调用会立即返回。当有客户端连接时,怎么得到通知。答案是通过完成端口返回。注意有一个步骤:监听端口与完成端口绑定,就是serverSocket与m_hIocp绑定,所以当有客户端连接serverSocket时,m_hIocp会得到通知。需要生成线程,等待完成端口的通知。
d)通过完成端口,获取通知
DWORD dwBytesTransferred;
ULONG_PTR Key;
BOOL rc;
int error;
AcceptOverlapped *lpPerIOData = NULL;
while (m_bServerStart)
{
error = NO_ERROR;
rc = GetQueuedCompletionStatus(
m_hIocp,
&dwBytesTransferred,
&Key,
(LPOVERLAPPED *)&lpPerIOData,
INFINITE);
if (rc == FALSE)
{
error = 0;
if (lpPerIOData == NULL)
{
DWORD lastError = GetLastError();
if (lastError == WAIT_TIMEOUT)
{
continue;
}
else
{
assert(false);
return lastError;
}
}
}
if (lpPerIOData != NULL)
{
switch (lpPerIOData->opType)
{
case POST_ACCEPT:
{
OnIocpAccept(lpPerIOData, dwBytesTransferred, error);
}
break;
}
}
else
{
}
}
return 0;
DWORD WINAPI IocpAcceptEx::AcceptExThreadPool(PVOID pContext)
{
ThreadPoolParam *param = (ThreadPoolParam*)pContext;
param->pIocpAcceptEx->NewAccept(param->ServeSocket);
delete param;
return 0;
}
int IocpAcceptEx::OnIocpAccept(AcceptOverlapped *acceptData, int transLen, int error)
{
m_IAcceptCallback->OnAcceptClient(acceptData->clientSocket, acceptData->serverSocket);
//当一个AcceptEx返回,需要投递一个新的AcceptEx。
//使用线程池好像有点小题大做。前文已说过,套接字的创建相对是比较耗时的操作。
//如果不在线程池投递AcceptEx,AcceptEx的优点就被抹杀了。
ThreadPoolParam *param = new ThreadPoolParam();
param->pIocpAcceptEx = this;
param->ServeSocket = acceptData->serverSocket;
QueueUserWorkItem(AcceptExThreadPool, this, 0);
delete acceptData;
return 0;
}
后记
采用完成端口是提高IO处理能力的一个途径(广义上讲,通讯操作也是IO)。为了提高IO处理能力,windows提供很多异步操作函数,这些函数都与完成端口关联,所以这一类处理的思路基本一致。学会了AcceptEx的使用,可以做到触类旁通的效果。
来源:https://www.cnblogs.com/yuanchenhui/p/acceptex_socket.html
猜你喜欢
- spring与IoCIoC:控制反转,将由代码操纵的对象控制权,交给第三方容器,反转给第三方容器。这种对象依赖的关系管理方式,称作IoC。I
- 1. 传统方式:在内存中读取文件内容读取文件行的标准方式是在内存中读取,Guava 和Apache Commons IO都提供了如下所示快速
- #line #line 使您可以修改编译器的行号以及(可选)错误和警告的文件名输出。下面的示例说明如何报告与行号关联的两个警告。#line
- 简介TreeMap使用红黑树存储元素,可以保证元素按key值的大小进行遍历。继承体系TreeMap实现了Map、SortedMap、Navi
- 一、前言最近做的项目由于引入第三方库导致在运行mvn clean package 打jar时,编译出来的 Jar 包很大(服务器多达500M
- 本文实例为大家分享了C#异步调用的具体代码,供大家参考,具体内容如下using System;using System.Collection
- 本文实例为大家分享了Java分页展示的具体代码,供大家参考,具体内容如下先上图吧,大致如图,也就提供个思路(ps:使用了SSH框架) 前台J
- 前情提要我们上节内容学习了如何创建\注册\读取bean我们发现bean对象操作十分的繁琐!所以我们这个章节,就带大家来了解更加简单的bean
- 一、引入pom<?xml version="1.0" encoding="UTF-8"?>
- 前言总是觉得对HashMap很熟悉,但最近连续被问到几个关于它的问题,才发现它其实并不简单。这里对关于它的一些问题做个总结,也希望能够大家一
- 前言该篇介绍的内容如题,就是利用redis实现接口的限流( 某时间范围内 最大的访问次数 ) 。正文 惯例,
- 前言最近测试给我提了一个bug,说我之前提供的一个批量复制商品的接口,产生了重复的商品数据。追查原因之后发现,这个事情没想象中简单,可以说一
- 前言说到对集合去重处理,第一时间想到的肯定是Linq的Distinct扩展方式,对于一般的值类型集合去重,很好处理,直接list.Disti
- 一、简介Mutex的突出特点是可以跨应用程序域边界对资源进行独占访问,即可以用于同步不同进程中的线程,这种功能当然这是以牺牲更多的系统资源为
- 利用Jconsole工具查看程序的资源占用请求。安装jdk时bin目录有jconsole.exe工具,或者通过 Win + R,输入jcon
- 1. 公共字段自动填充1.1 问题分析在新增员工时需要设置创建时间、创建人、修改时间、修改人等字段,在编辑员工时需要设置修改时间、修改人等字
- 我们知道,spring boot自动配置功能可以根据不同情况来决定spring配置应该用哪个,不应该用哪个,举个例子:Spring的Jdbc
- 一、重载 1、重载示意 重载(Overload)是重新加载的意思,指的是同一个类中同名,但是参
- 最近的项目中要实现一个聊天的功能,类似于斗鱼TV的聊天室功能,与服务器端人商量后决定用WebSocket来做,但是在这之前我只知道Socke
- java 获取字节码文件的几种方法总结在本文中,以Person类为例,将分别演示获取该类字节码文件的三种方式,其具体思想及代码如下所示:pu