怎样通过MSG_WAITALL设置阻塞时间，IO模式精细讲解： MSG_DONTWAIT 、 MSG_WAITALL

首先给出MSDN上一段设置阻塞超时的代码：（网址为http://social.msdn.microsoft.com/Forums/zh-SG/visualcpluszhchs/thread/3d9daec0-f000-4bf1-add1-3beab8e398eb）


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

您可以利用select模型来设置connect连接超时,当前之前需要调用

unsigned long ul = 1;

ioctlsocket(SOCKET, FIOBIO, (unsigned long*)&ul);

。。。

connect(...);

之后的就使用select()

下面有段网上的例子代码,您不妨参考一下：

 

WSADATA wsd;

SOCKET cClient;

int ret;

struct sockaddr_in server;

hostent *host=NULL;

 

if(WSAStartup(MAKEWORD(2,0),&wsd)){return 0;}

cClient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);

if(cClient==INVALID_SOCKET){return 0;}

//set Recv and Send time out

int TimeOut=6000; //设置发送超时6秒

if(::setsockopt(cClient,SOL_SOCKET,SO_SNDTIMEO,(char *)&TimeOut,sizeof(TimeOut))==SOCKET_ERROR){

return 0;

}

TimeOut=6000;//设置接收超时6秒

if(::setsockopt(cClient,SOL_SOCKET,SO_RCVTIMEO,(char *)&TimeOut,sizeof(TimeOut))==SOCKET_ERROR){

return 0;

}

//设置非阻塞方式连接

unsigned long ul = 1;

ret = ioctlsocket(cClient, FIONBIO, (unsigned long*)&ul);

if(ret==SOCKET_ERROR)return 0;

 

//连接

server.sin_family = AF_INET;

server.sin_port = htons(25);

server.sin_addr .s_addr = inet_addr((LPCSTR)pSmtp);

if(server.sin_addr.s_addr == INADDR_NONE){return 0;}

 

connect(cClient,(const struct sockaddr *)&server,sizeof(server));

 

//select 模型，即设置超时

struct timeval timeout ;

fd_set r;

 

FD_ZERO(&r);

FD_SET(cClient, &r);

timeout.tv_sec = 15; //连接超时15秒

timeout.tv_usec =0;

ret = select(0, 0, &r, 0, &timeout);

if ( ret <= 0 )

{

::closesocket(cClient);

return 0;

}

//一般非锁定模式套接比较难控制，可以根据实际情况考虑 再设回阻塞模式

unsigned long ul1= 0 ;

ret = ioctlsocket(cClient, FIONBIO, (unsigned long*)&ul1);

if(ret==SOCKET_ERROR){

::closesocket (cClient);

return 0;

}

 

基本概念：

阻塞IO::

socket 的阻塞模式意味着必须要做完IO 操作（包括错误）才会返回。

非阻塞IO::

非阻塞模式下无论操作是否完成都会立刻返回，需要通过其他方式来判断具体操作是否成功。

 

IO模式设置：
一般对于一个socket 是阻塞模式还是非阻塞模式有两种方式::

 方法1、fcntl 设置；

方法2、recv,send 系列的参数。(读取，发送时，临时将sockfd或filefd设置为非阻塞)

 

方法一、fcntl 函数可以将一个socket 句柄设置成非阻塞模式:
flags = fcntl(sockfd, F_GETFL, 0); //获取文件的flags值。

 fcntl(sockfd, F_SETFL, flags | O_NONBLOCK); //设置成非阻塞模式；

flags = fcntl(sockfd,F_GETFL,0);

fcntl(sockfd,F_SETFL,flags&~O_NUNBLOCK); //设置成阻塞模式；

设置之后每次的对于sockfd 的操作都是非阻塞的。

 

方法二、recv, send 函数的最后有一个flag 参数可以设置成MSG_DONTWAIT

临时将sockfd 设置为非阻塞模式,而无论原有是阻塞还是非阻塞。

recv(sockfd, buff, buff_size,MSG_DONTWAIT); //非阻塞模式的消息发送

send(scokfd, buff, buff_size, MSG_DONTWAIT); //非阻塞模式的消息接受

 

 

阻塞与非阻塞读的区别: //阻塞和非阻塞的区别在于没有数据到达的时候是否立刻返回．

读(read/recv/msgrcv):

读的本质来说其实不能是读,在实际中, 具体的接管数据不是由这些调用来进行,是由于系统底层自动完成的。read 也好,recv 也好只负责把数据从底层缓冲copy 到我们指定的位置.

对于读来说(read, 或者recv) ::

阻塞情况下::

在阻塞条件下，read/recv/msgrcv的行为::

1、如果没有发现数据在网络缓冲中会一直等待，

2、当发现有数据的时候会把数据读到用户指定的缓冲区，但是如果这个时候读到的数据量比较少，比参数中指定的长度要小，read 并不会一直等待下去，而是立刻返回。

read 的原则::是数据在不超过指定的长度的时候有多少读多少，没有数据就会一直等待。

所以一般情况下::我们读取数据都需要采用循环读的方式读取数据，因为一次read 完毕不能保证读到我们需要长度的数据，

read 完一次需要判断读到的数据长度再决定是否还需要再次读取。

非阻塞情况下::

在非阻塞的情况下，read 的行为::

1、如果发现没有数据就直接返回，

2、如果发现有数据那么也是采用有多少读多少的进行处理．

所以::read 完一次需要判断读到的数据长度再决定是否还需要再次读取。

 

对于读而言:: 阻塞和非阻塞的区别在于没有数据到达的时候是否立刻返回．
recv 中有一个MSG_WAITALL 的参数::

recv(sockfd, buff, buff_size, MSG_WAITALL),
在正常情况下recv 是会等待直到读取到buff_size 长度的数据，但是这里的WAITALL 也只是尽量读全，在有中断的情况下recv 还是可能会被打断，造成没有读完指定的buff_size的长度。

所以即使是采用recv + WAITALL 参数还是要考虑是否需要循环读取的问题，在实验中对于多数情况下recv (使用了MSG_WAITALL)还是可以读完buff_size，

所以相应的性能会比直接read 进行循环读要好一些。

 

注意:: //使用MSG_WAITALL时，sockfd必须处于阻塞模式下，否则不起作用。

//所以MSG_WAITALL不能和MSG_NONBLOCK同时使用。

要注意的是使用MSG_WAITALL的时候，sockfd 必须是处于阻塞模式下，否则WAITALL不能起作用。

 

 

阻塞与非阻塞写的区别: //
写(send/write/msgsnd)::

写的本质也不是进行发送操作,而是把用户态的数据copy 到系统底层去,然后再由系统进行发送操作,send，write返回成功，只表示数据已经copy 到底层缓冲,而不表示数据已经发出,更不能表示对方端口已经接管到数据.
对于write(或者send)而言，

阻塞情况下:: //阻塞情况下，write会将数据发送完。(不过可能被中断)

在阻塞的情况下，是会一直等待，直到write 完，全部的数据再返回．这点行为上与读操作有所不同。

原因::

读，究其原因主要是读数据的时候我们并不知道对端到底有没有数据，数据是在什么时候结束发送的，如果一直等待就可能会造成死循环，所以并没有去进行这方面的处理；

写，而对于write, 由于需要写的长度是已知的，所以可以一直再写，直到写完．不过问题是write 是可能被打断吗，造成write 一次只write 一部分数据, 所以write 的过程还是需要考虑循环write, 只不过多数情况下一次write 调用就可能成功.

 

非阻塞写的情况下:: //

非阻塞写的情况下，是采用可以写多少就写多少的策略．与读不一样的地方在于，有多少读多少是由网络发送的那一端是否有数据传输到为标准，但是对于可以写多少是由本地的网络堵塞情况为标准的，在网络阻塞严重的时候，网络层没有足够的内存来进行写操作，这时候就会出现写不成功的情况，阻塞情况下会尽可能(有可能被中断)等待到数据全部发送完毕， 对于非阻塞的情况就是一次写多少算多少,没有中断的情况下也还是会出现write 到一部分的情况.

时间： 2024-04-26 06:51:30

怎样通过MSG_WAITALL设置阻塞时间，IO模式精细讲解： MSG_DONTWAIT 、 MSG_WAITALL的相关文章

非阻塞IO模式原理

与阻塞模式对应的另一种模式叫非阻塞IO模式,在整个通信过程中读和写操作不会阻塞,当前处理线程不存在阻塞情况.从A机器到B机器它的通信过程是:A机器一条线程将通道设置为写事件后往下执行,而另外一条线程遍历到此通道有字节要写并往socket写数据,B机器一条线程遍历到此通道有字节要读,交给另外一条线程对socket读数据,处理完又把通道设置为写事件,遍历线程遍历到此通道有字节要写,又往socket写数据传往A机器,不断往下循环此操作直到完成通信.这个过程每台机器都有两类主要线程,一类是负责逻辑处理且

操作系统中的IO模式

1.概念说明 在进行解释之前,首先要说明几个概念: -用户空间和内核空间 -进程切换 -进程的阻塞 -文件描述符 -缓存 I/O 用户空间与内核空间 现在操作系统都是采用虚拟存储器,那么对32位操作系统而言,它的寻址空间(虚拟存储空间)为4G(2的32次方).操作系统的核心是内核(kernel),独立于普通的应用程序,可以访问受保护的内存空间,也有访问底层硬件设备的所有权限.为了保证用户进程不能直接操作内核,保证内核的安全,操作系统将虚拟空间划分为两部分,一部分为内核空间,一部分为用户空间.针对

调用webservice 设置超时时间

前段时间自己写了个程序,调用webservice,今天早上一执行,速度是相当的慢,一开始以为是程序的问题,后来跟踪一看,原来是调用webservice出现问题,放置webservice的服务器关掉了,导致程序访问速度慢,这样我们就要将webservice设置超时时间.如下   WebService超时设置 1. 服务器端设置超时 在 web.config 的 system.web 里添加如下配置项: < httpRuntime executionTimeout="30" />

如何设置FTP的主动模式和被动模式？

在使用ftp的时侯,经常遇到ftp链接后出现文件列表错误的情况,只是因为ftp的模式不正确,如何设置ftp的工作模式,什么是主动模式,什么又是被动模式,主动模式和被动模式有什么区别,今天搜集了相关资料和常用ftp软件工作模式的设置的方法: 一.什么是PASV和PORT方式 (1)PORT其实是Standard模式的另一个名字,又称为Active模式.中文意思是"主动模式. (2)PASV也就是Passive的简写.中文就是"被动模式. 二.两者不同 不同之处是由于PORT(主动)这个方

.net中设置系统时间

回复人: acptvb(微软全球技术中心 VB技术支持) ( ) 感谢您使用微软产品. .NET并没有提供可以修改系统时间的名字空间(namespace),您可以通过Win32 API的SetSystemTime API函数来设置系统时间: using System;using System.Runtime.InteropServices; [StructLayout(LayoutKind.Sequential)]public struct SystemTime{ public ushort w

MySQL datetime数据类型设置当前时间为默认值

环境:MySQL Sever 5.1 + MySQL命令行工具 问题:MySQL datetime数据类型设置当前时间为默认 值 解决: 方法一: 由于MySQL目前字段的默认值不支持函数,所以以create_time datetime default now() 的形式设置默认值是不可能的.代替的方案是使用TIMESTAMP类型代替DATETIME类 型. TIMESTAMP列类型自动地用当前的日期和时间标记INSERT或UPDATE的操作.如果有多个 TIMESTAMP列,只有第一个自动更新

怎么设置TP-LINK WR802N中继模式

  设置TP-LINK WR802N中继模式的方法 所谓中继模式,一般是指已经有了无线讯号(主无线路由器),而将此讯号延伸为更大的范围(覆盖信号弱的部位),通常架设在在多房间弱讯号处,接驳无线讯号. 2先查看路由器的背面铭牌,默记该路由器的名称为:TP-LINK_60B13C 3因为是中继模式(Reapte),所以只要接通微型路由器的电源,而无需插网线. 4事先需要确认前端路由器的无线用户名和密码(后面设置需要使用). 5先打开电脑寻找前端的无线信号(TP-LINK_60B13C )→连接. 在

怎么设置TP-Link TD-W89941N无线路由模式

  设置TP-Link TD-W89941N无线路由模式的方法 IPTV简介:IPTV是运商为用户提供的通过网络观看电视的业务,不同于网络电视,需要在对应的服务商开通业务方可观看. 步骤一:TD-W89941N安装 1.网线入户上网:把入户网线插在TD-W89941N的LAN 4/WAN接口;在准备一根网线,一头连接电脑,另一头连接TD-W89941N的LAN1接口,如下图所示: 2.光钎上网:请先准备2根较短的网线,一根用来连接光猫与TD-W89941N的LAN4/WAN接口;另一根网线,用来

TP-LINK路由器里怎么设置上网时间

  TP-LINK路由器里设置上网时间的方法 在浏览器地址栏中输入192.168.1.1回车,打开路由器登录对话框,在相应的用户名.密码框中输入相应数据,如:admin等 在打开的路由器管理页面中点击左面选项中的"网络参数". 点击"WAN口设置",在WAN口设置对话框中选中"定时连接,在开机和断开后自动连接"在连接时段中输入相应时间,如图:从5点到22点,然后点"保存" 再点击左侧的"系统工具".&quo