Winsocket入门教程二:非阻塞式服务器和客户端程序(TCP)
2010年06月06日
上次为大家介绍了阻塞式多线程服务端程序和阻塞式客户端程序的设计方法,但是在上文的最后也提到过,服务器程序会因为建立连接和关闭连接而频繁的创建和关闭线程会产生大量的内存碎片,从而导致服务端程序不能保证长时间的稳定运行。因此我在这里为大家介绍另外一种建立服务器和客户端程序的方法,即建立非阻塞式的服务器和客户端程序。
那什么是非阻塞呢?非阻塞是相对于阻塞而言,阻塞指的是在进行一个操作的时候,如服务器接收客户端的连接(accept),服务器或者客户端读写数据(read、write),如果该操作没有执行完成(成功或者失败都算是执行完成),则程序会一直阻塞在操作执行的地方,直到该操作返回一个明确的结果。而非阻塞式程序则不一样,非阻塞式程序会在产生阻塞操作的地方阻塞一定的时间(该时间可以由程序员自己设置)。如果操作没有完成,在到达所设置的时间之后,无论该操作成功与否,都结束该操作而执行程序下面的操作。
为了执行非阻塞操作,我们在创建了一个套接口后,需要将套接口设置为非阻塞的套接口。为了将套接口设置成为非阻塞套接口,我们需要调用ioctlsocket函数将套接口设置为非阻塞的套接口。ioctlsocket函数的定义如下: int ioctlsocket( SOCKETs, longcmd, u_long FAR *argp) 该函数的作用是控制套接口的I/O模式。
参数s表示要设置的套接口;参数cmd表示要对该套接口设置的命令,为了要将套接口设置成为非阻塞的,我们应该填写FIONBIO;argp表示填写命令的值,如我们要将套接口设置成非阻塞的,我们需要将值设置成为1,如果我们要将套接口设置成为非阻塞状态的话,我们将值设置成为0就是了。
为了进行非阻塞的操作,我们需要在进行操作之前调用select函数,select函数的定义如下:
int select(int nfds, fd_set FAR *readfds, fd_set FAR *writefds,
fd_set FAR *exceptfds,
const struct timeval FAR *timeout);
该函数设定一个或多个套接口的状态,并进行必要的等待,以便执行异步I/0(非阻塞)操作。
参数nfds被忽略,该参数的作用仅仅是为了与伯克利套接口相兼容;参数readfds表示要检测的可读套接口的集合(该参数可选,可为设置
为NULL);参数readfds表示要检测的可写套接口的集合(该参数可选,可为设置为NULL);参数exceptfds表示要检测的套接口的错误(该参数可选,可为设置为NULL);参数timeout表示执行该函数时需要等待的时间,如果为NULL则表示阻塞操作,为0则表示立即返回。
下面让我们来看看参数类型fd_set,fd_set表示套接字的集合。在使用select函数时,我们需要将相应的套接字加入到相应的集合中。如果集合中的套接字有信号,select函数的返回值即为集合中有信号的套接字数量。 我们用下面的几个宏来操作fd_set集合。我们可以使用FD_SET(s, *set)将套接字s加入到集合set中;我们可以使用FD_CLR(s, *set)将套接字s移除出集合set;我们可以使用FD_ZERO(*set)将集合set清空;最后,我们可以使用FD_ISSET(s, *set)来判断套接字s是否在集合中有信号。 接下来再让我们来看看select函数的三个集合参数readfds、writefds以及exceptfds。
readfds表示可读套接字的集合,可读套接字在三种情况下有信号出现:一、如果集合中有套接字处于监听状态,并且该套接字上有来自客户端的连接请求;二、如果集合中的套接字收到了send操作发送过来的数据;三、如果集合中的套接字被关闭、重置或者中断。
writefds表示可写套接字的集合,可写套接字在两种情况下有信号出现:一、集合中的套接字经过connect操作后,连接成功;二、可以用send操作向集合中的套接字写数据。
exceptfds表示错误套接字的集合,错误套接字在两种情况下有信号出现:一、集合中的套接字经过connect操作后,连接失败;二、有带外数据到来。
在我们了解了创建服务器和客户端程序的基础知识后,我们再来看看示例程序,以加深我们对知识的理解。
程序的运行结果如下所示:
下面是服务器程序的代码:
#include #include #include #include #pragma comment(lib, "ws2_32.lib") #define ASSERT assert using std::cin; using std::cout; using std::endl; using std::list; typedef list SocketList; typedef list::iterator SocketListIterator; static const int c_iPort = 10001; bool GraceClose(SOCKET *ps); int main() { int iRet = SOCKET_ERROR; // 初始化Winsocket,所有Winsocket程序必须先使用WSAStartup进行初始化 WSADATA data; ZeroMemory(&data, sizeof(WSADATA)); iRet = WSAStartup(MAKEWORD(2, 0), &data); ASSERT(SOCKET_ERROR != iRet); // 建立服务端程序的监听套接字 SOCKET skListen = INVALID_SOCKET; skListen = socket(AF_INET, SOCK_STREAM, 0); ASSERT(INVALID_SOCKET != skListen); // 初始化监听套接字地址信息 sockaddr_in adrServ; // 表示网络地址 ZeroMemory(&adrServ, sizeof(sockaddr_in)); adrServ.sin_family = AF_INET; // 初始化地址格式,只能为AF_INET adrServ.sin_port = htons(c_iPort); // 初始化端口,由于网络字节顺序和主机字节顺序相反,所以必须使用htons将主机字节顺序转换成网络字节顺序 adrServ.sin_addr.s_addr = INADDR_ANY; // 初始化IP,由于是服务器程序,所以可以将INADDR_ANY赋给该字段,表示任意的IP // 绑定监听套接字到本地 iRet = bind(skListen, (sockaddr*)&adrServ, sizeof(sockaddr_in)); ASSERT(SOCKET_ERROR != iRet); // 使用监听套接字进行监听 iRet = listen(skListen, FD_SETSIZE); // SOMAXCONN表示可以连接到该程序的最大连接数 ASSERT(SOCKET_ERROR != iRet); cout 0) { sockaddr_in adrClt; int iLen = sizeof(sockaddr_in); ZeroMemory(&adrClt, iLen); SOCKET s = accept(skListen, (sockaddr*)&adrClt,&iLen); ASSERT(INVALID_SOCKET != s); sl.push_back(s); cout socket is " 0) { for(SocketListIterator iter = sl.begin(); iter != sl.end(); ++iter) { // 如果有数据可读, 则遍历套接字列表中的所有套接字 // 检测出有数据可读的套接字 iRet = FD_ISSET(*iter, &fsRead); if(iRet > 0) { // 读取套接字上的数据 const int c_iBufLen = 512; char szBuf[c_iBufLen + 1] = {'\0'}; int iRead = SOCKET_ERROR; iRead = recv(*iter, szBuf, c_iBufLen, 0); if (0 >= iRead)// 读取出现错误或者对方关闭连接 { iRead == 0 ? cout socket " socket " socket " 发送数据 iRet = select(1, NULL, &fsWrite, NULL, &tv); if (0 socket " SOCKET *ps) { const int c_iBufLen = 512; char szBuf[c_iBufLen + 1] = {'\0'}; // 关闭该套接字的连接 int iRet = shutdown(*ps, SD_SEND); while(recv(*ps, szBuf, c_iBufLen, 0) > 0); if (SOCKET_ERROR == iRet) { return false; } // 清理该套接字的资源 iRet = closesocket(*ps); if (SOCKET_ERROR == iRet) { return false; } *ps = INVALID_SOCKET; return true; }
服务器程序的重点是我们需要将接受自客户端程序的套接字加入到一个链表中,以方便我们的管理。 FD_SET(skListen, &fsListen); iRet = select(1, &fsListen, NULL, NULL, &tv); if(iRet > 0) { sockaddr_in adrClt; int iLen = sizeof(sockaddr_in); ZeroMemory(&adrClt, iLen); SOCKET s = accept(skListen, (sockaddr*)&adrClt,&iLen); ASSERT(INVALID_SOCKET != s); sl.push_back(s); cout socket is " = iRead)// 读取出现错误或者对方关闭连接 { iRead == 0 ? cout socket " socket " #include #include #pragma comment(lib, "ws2_32.lib") #define ASSERT assert using std::cin; using std::cout; using std::endl; static const char c_szIP[] = "127.0.0.1"; static const int c_iPort = 10001; bool GraceClose(SOCKET *ps); int main() { int iRet = SOCKET_ERROR; // 初始化Winsocket,所有Winsocket程序必须先使用WSAStartup进行初始化 WSADATA data; ZeroMemory(&data, sizeof(WSADATA)); iRet = WSAStartup(MAKEWORD(2, 0), &data); ASSERT(SOCKET_ERROR != iRet); // 建立连接套接字 SOCKET skClient = INVALID_SOCKET; skClient = socket(AF_INET, SOCK_STREAM, 0); ASSERT(INVALID_SOCKET != skClient); // 初始化连接套接字地址信息 sockaddr_in adrServ; // 表示网络地址 ZeroMemory(&adrServ, sizeof(sockaddr_in)); adrServ.sin_family = AF_INET; // 初始化地址格式,只能为AF_INET adrServ.sin_port = htons(c_iPort); // 初始化端口,由于网络字节顺序和主机字节顺序相反,所以必须使用htons将主机字节顺序转换成网络字节顺序 adrServ.sin_addr.s_addr = inet_addr(c_szIP); // 初始化IP, 由于网络字节顺序和主机字节顺序相反,所以必须使用inet_addr将主机字节顺序转换成网络字节顺序 // 将套接口从阻塞状态设置到非阻塞状态 unsigned long ulEnable = 1; iRet = ioctlsocket(skClient, FIONBIO, &ulEnable); ASSERT(SOCKET_ERROR != iRet); fd_set fsWrite; TIMEVAL tv; tv.tv_sec = 1; tv.tv_usec = 0; cout 返回值总是为SOCKET_ERROR iRet = connect(skClient, (sockaddr*)&adrServ, sizeof(sockaddr_in)); int iErrorNo = SOCKET_ERROR; int iLen = sizeof(int); // 如果getsockopt返回值不为0,则说明有错误出现 if (SOCKET_ERROR == iRet && 0 != getsockopt(skClient, SOL_SOCKET, SO_ERROR, (char*)&iErrorNo, &iLen)) { cout 返回值大于0 iRet = select(1, NULL, &fsWrite, NULL, &tv); if (0 > szBuf; if(0 == strcmp("exit", szBuf)) { break; } FD_ZERO(&fsWrite); FD_SET(skClient, &fsWrite); // 如果集合fsWrite中的套接字有信号, 则可以用send操作写数据 iRet = select(1, NULL, &fsWrite, NULL, &tv); if (0 SOCKET *ps) { const int c_iBufLen = 512; char szBuf[c_iBufLen + 1] = {'\0'}; // 关闭该套接字的连接 int iRet = shutdown(*ps, SD_SEND); while(recv(*ps, szBuf, c_iBufLen, 0) > 0); if (SOCKET_ERROR == iRet) { return false; } // 清理该套接字的资源 iRet = closesocket(*ps); if (SOCKET_ERROR == iRet) { return false; } *ps = INVALID_SOCKET; return true; } 客户端程序比较简单,并且在代码中已经有十分详细的注释了,所以就不在这里详细说明了。
好了,非阻塞式服务器和客户端程序就介绍到这里,下一集中将向大家介绍一下使用Windows消息机制构建socket程序的方法。
发表评论
-
Memcache Protocol 翻译
2012-01-20 09:10 712Memcache Protocol 翻译 2010 ... -
《ASCE1885的网络编程》の套接字select模型
2012-01-20 09:10 713《ASCE1885的网络编程》 ... -
C#线程池
2012-01-20 09:10 717C#线程池 2011年06月23日 ... -
my.ini(my.cnf)与mysql优化指南
2012-01-19 14:14 736my.ini(my.cnf)与mysql优化指南 2011年 ... -
并行 .net 应用程序的过去、现在和未来
2012-01-19 14:14 575并行 .net 应用程序的过去、现在和未来 2011年08月 ... -
Grub4dos命令用法
2012-01-19 14:14 733Grub4dos命令用法 2010年06月01日 blo ... -
顶松数字称重显示器
2012-01-19 14:14 1329顶松数字称重显示器 2011年04月29日 杭州顶松自控 ... -
第一章第一节计算机语言C语言基础教程
2012-01-19 14:14 630第一章第一节计算机语言C语言基础教程 2012年01月02日 ... -
HP 蓝屏 STOP: 0x000000A5――the system is not fully ACPI compliant
2012-01-17 04:04 3723HP 蓝屏 STOP: 0x000000A5――the sys ... -
ARM经典100问
2012-01-17 04:04 871ARM经典100问 2011年03月13日 第1章 体系 ... -
MBR的反编译程序
2012-01-17 04:04 744MBR的反编译程序 2011年0 ... -
HOOK API 函数跳转详解
2012-01-17 04:04 2144HOOK API 函数跳转详解 20 ... -
黑莓8330、8830写号,上网,输入法,汉化
2012-01-17 04:03 1382黑莓8330、8830写号,上网,输入法,汉化 2011年1 ... -
粤语文化纵横谈
2012-01-16 02:52 644粤语文化纵横谈 2009年1 ... -
老广人为粤语---广州话写篇文章
2012-01-16 02:52 626老广人为粤语---广州话写篇文章 2011年07月06日 ... -
穗港同心,打响粤语保卫战!
2012-01-16 02:52 581穗港同心,打响粤语保卫战! 2010年07月15日 -
如何学好粤语
2012-01-16 02:51 587如何学好粤语 2010年06月04日 粤语会馆" ... -
写给粤语社的一封信
2012-01-16 02:51 719写给粤语社的一封信 20 ...
相关推荐
在之前的教程中,我们学习了阻塞式多线程服务器和客户端程序的设计方法,但是这种方法存在一些问题,例如服务器程序会因为建立连接和关闭连接而频繁的创建和关闭线程,从而产生大量的内存碎片,从而导致服务端程序不...
非阻塞式Winsock服务器和客户端程序设计是网络编程中的一种高效策略,它解决了阻塞式编程中因等待I/O操作完成而导致的程序暂停问题。本篇教程将深入讲解如何构建非阻塞TCP服务器和客户端。 首先,理解非阻塞模式的...
本入门教程将深入探讨如何使用Winsocket来构建TCP(传输控制协议)的多线程阻塞式服务器和客户端程序,以及非阻塞式服务器和客户端程序。 在第一部分“Winsocket入门教程一:多线程阻塞式服务器和阻塞式客户端程序...
在Winsocket入门教程中,我们通常会接触到两种基本的通信模型:服务器和客户端。服务器端始终处于监听状态,等待客户端的连接请求。当客户端发起连接请求时,服务器接受请求并建立连接。之后,客户端可以向服务器...
非阻塞tcp的服务器和客户端示例程序,详见链接:Winsocket 三:非阻塞server&client程序(tcp) http://blog.csdn.net/u013071074/article/details/26354781
在服务端应用程序的主线程中不停的调用accept操作,以使服务端程序能不停地接受客户端程序发送...详见链接:Winsocket 二:多线程阻塞服务器程序(tcp),http://blog.csdn.net/u013071074/article/details/26340707
在压缩包中的"winsocket"文件可能包含了服务器端和客户端的源代码,你可以通过阅读和运行这些代码来更好地理解TCP通信的流程。此外,理解错误处理和异常处理也是很重要的,因为网络通信中经常会出现各种不可预知的...
本教程将深入探讨如何使用Visual C++调用WinSocket API来创建TCP客户端和服务器的通信程序。 首先,我们来看`Client和Server通讯程序.cpp`和`.h`文件,这些文件包含了客户端和服务器的核心逻辑。在C++中,WinSocket...
【异步TCP网络聊天程序(客户端)】是一个基于TCP协议的聊天程序,它允许用户进行实时的文本交流。TCP(Transmission Control Protocol)是一种面向连接的、可靠的、基于字节流的传输层通信协议,它确保了数据包在...
在标题提到的通信程序中,我们有两个主要组件:服务器端(Server)和客户端(Client)。服务器端通常会监听特定的端口,等待客户端连接请求;客户端则向服务器发起连接,并在连接建立后发送和接收数据。 1. **...
本项目中,服务端和客户端均通过Socket进行TCP连接,TCP(Transmission Control Protocol)是一种面向连接的、可靠的传输协议,确保数据的正确性和顺序。 其次,**服务端** 的实现是系统的核心部分。它负责监听...
6. `send`/`recv`:分别用于发送和接收数据,支持阻塞和非阻塞模式。 7. `shutdown`:关闭套接字的发送或接收功能,或两者同时关闭。 8. `close`:关闭套接字,释放相关资源。 9. `WSACleanup`:停止使用Winsock库,...
在"TCP通信-使用winsocket"的例子中,开发者将使用Winsock库来创建服务器和客户端的socket,进行TCP通信。 3. 多线程: 在这个示例中,多线程技术被用来处理多个客户端连接。当服务器接收到新的连接请求时,会在新...
本文将深入探讨基于WinSocket的TCP聊天小工具的实现,包括客户端与服务器的交互、好友列表的实时更新以及字符串处理等关键技术。 首先,TCP(Transmission Control Protocol)是一种面向连接的、可靠的传输协议,它...
本示例主要介绍如何使用Visual Basic(VB)来实现TCP通信,包括服务端(Server)和客户端(Client)的编程。 TCP通信的基础是建立一个可靠的连接,它在数据传输前会通过三次握手建立连接,并在传输后通过四次挥手...
在聊天室程序中,winSocket扮演着核心角色,负责处理客户端和服务器之间的数据传输。客户端通过winSocket向服务器发送消息,并接收来自其他客户端或服务器的响应。服务器端则监听来自客户端的连接请求,建立连接后,...
本项目“WinSocket-TCP”很可能包含了一个简单的服务器程序和一个客户端程序,它们分别实现了上述功能。通过查看源代码,我们可以深入理解TCP通信的整个流程,以及如何在VC++环境中利用WinSocket API实现这一过程。...
在本项目中,服务器端和客户端被集成到同一个程序中,这意味着用户可以在同一台计算机上同时启动服务器和客户端,模拟局域网内的通信。这有助于开发者更好地理解服务器和客户端之间的交互过程,以及如何处理连接请求...
下面我们将深入探讨如何使用WinSocket API在IPv6环境下实现TCP服务器。 首先,我们需要了解WinSocket的基本概念。WinSocket是Microsoft Windows操作系统中对Berkeley Sockets接口的实现,它为开发者提供了一种标准...
winsocket编程实现客户端与服务器端通信,熟悉UDP和TCP的socket编程