分享一下我老师大神的人工智能教程!零基础,通俗易懂!http://blog.csdn.net/jiangjunshow

也欢迎大家转载本篇文章。分享知识,造福人民,实现我们中华民族伟大复兴!

我想用UDP阻塞模式给硬件设备发包,然后收包。因为网络的问题,经常丢包,也就是发了之后没有响应。这样的话,recvfrom会一直停在那里,死机了一样。能不能设成超时自动返回,或者其它什么解决办法,谢谢!我不想用非阻塞模式,据说比较耗资源。
//连接超时
//--------------------------------------------------------------------------  
//设置为非阻塞方式连接
unsigned   long   ul   =   1;  
int   ret   =   ioctlsocket(m_sSocket,   FIONBIO,   (unsigned   long*)&ul);  
if(ret   ==   SOCKET_ERROR)  
{  
err   =   WSAGetLastError();  
closesocket(m_sSocket);  
m_sSocket   =   NULL;  
return   FALSE;  
}  
Struct timeval   timeout   ;     //   超时结构
fd_set  r;                                              
FD_ZERO(&r);  
FD_SET(m_sSocket,   &r);  
timeout.tv_sec   =   iTimeout;       //   连接超时设置
timeout.tv_usec   =0;  
connect(m_sSocket,(LPSOCKADDR)&server,sizeof(SOCKADDR));  
ret   =   select(0,   0,   &r,   0,   &timeout);      
if   (   ret   <=   0   )  
{  
err   =   WSAGetLastError();  
closesocket(m_sSocket);  
m_sSocket   =   NULL;  
return   FALSE;  
}  
//设回阻塞模式
ul   =   0   ;  
ret   =   ioctlsocket(m_sSocket,   FIONBIO,   (unsigned   long*)&ul);  
//--------------------------------------------------------------------------  
//接收超时
//-------------------------------------------  
//接收超时设置
struct                   timeval   outtime   ;     //   超时结构
FD_SET   fdr   =   {1,   m_sSocket};    
outtime.tv_sec   =   timeout;      
outtime.tv_usec   =0;  
int   nSelectRet;  
//------------------------------------------------------------  
//网络只认单字节串,而EVC里多字节;发送的UNICODE串转换成单字节串
UINT   nLen   =   len   *   2;  
char   *pByte   =   new   char[nLen+1];  
memset(pByte,   0,   nLen+1);  
WideCharToMultiByte(CP_ACP,   NULL,   buf,   wcslen(buf),pByte,   nLen,   NULL,   NULL);  
int   nRet;  
nSelectRet=::select(0,   &fdr,   NULL,   NULL,   &outtime);   //检查可读状态
if(SOCKET_ERROR==nSelectRet)    
{  
err   =   WSAGetLastError();  
closesocket(m_sSocket);  
m_sSocket   =   NULL;  
return   -1;  
}  
if(nSelectRet==0)   //超时发生,无可读数据
{  
AfxMessageBox(L"接收超时");  
err   =   WSAGetLastError();  
closesocket(m_sSocket);  
m_sSocket   =   NULL;  
return   -1;  
}  
else    
{  
//接收数据
nRet   =   recv(m_sSocket,   pByte,   nLen,   0);  
if(nRet   ==   SOCKET_ERROR)  
{  
err   =   WSAGetLastError();  
}  
}  
//-------------------------------------------  
MultiByteToWideChar(CP_ACP,   NULL,   pByte,   nLen,   buf,   len);  
delete   []   pByte;  
pByte   =   NULL;  
不知道大家有没有遇到过这种情况,当socket进行TCP连接的时候(也就是调用connect时),一旦网络不通,或者是ip地址无效,就可能使整个线程阻塞。一般为30秒(我测的是20秒)。如果设置为非阻塞模式,能很好的解决这个问题,我们可以这样来设置非阻塞模式:调用ioctlsocket函数:unsigned long flag=1; if (ioctlsocket(sock,FIONBIO,&flag)!=0) { closesocket(sock); return false; } 以下是对ioctlsocket函数的相关解释:int PASCAL FAR ioctlsocket( SOCKET s, long cmd, u_long FAR* argp); s:一个标识套接口的描述字。cmd:对套接口s的操作命令。argp:指向cmd命令所带参数的指针。注释:本函数可用于任一状态的任一套接口。它用于获取与套接口相关的操作参数,而与具体协议或通讯子系统无关。支持下列命令:FIONBIO:允许或禁止套接口s的非阻塞模式。argp指向一个无符号长整型。如允许非阻塞模式则非零,如禁止非阻塞模式则为零。当创建一个套接口时,它就处于阻塞模式(也就是说非阻塞模式被禁止)。这与BSD套接口是一致的。WSAAsynSelect()函数将套接口自动设置为非阻塞模式。如果已对一个套接口进行了WSAAsynSelect() 操作,则任何用ioctlsocket()来把套接口重新设置成阻塞模式的试图将以WSAEINVAL失败。为了把套接口重新设置成阻塞模式,应用程序必须首先用WSAAsynSelect()调用(IEvent参数置为0)来禁至WSAAsynSelect()。FIONREAD:确定套接口s自动读入的数据量。argp指向一个无符号长整型,其中存有ioctlsocket()的返回值。如果s是SOCKET_STREAM类型,则FIONREAD返回在一次recv()中所接收的所有数据量。这通常与套接口中排队的数据总量相同。如果S是SOCK_DGRAM 型,则FIONREAD返回套接口上排队的第一个数据报大小。SIOCATMARK:确实是否所有的带外数据都已被读入。这个命令仅适用于SOCK_STREAM类型的套接口,且该套接口已被设置为可以在线接收带外数据(SO_OOBINLINE)。如无带外数据等待读入,则该操作返回TRUE真。否则的话返回FALSE假,下一个recv()或recvfrom()操作将检索“标记”前一些或所有数据。应用程序可用SIOCATMARK操作来确定是否有数据剩下。如果在“紧急”(带外)数据前有常规数据,则按序接收这些数据(请注意,recv()和recvfrom()操作不会在一次调用中混淆常规数据与带外数据)。argp指向一个BOOL型数,ioctlsocket()在其中存入返回值。此时已经设置非阻塞模式,但是并没有设置connect的连接时间,我们可以通过调用select语句来实现这个功能。以下代码设定了是连接时间为5秒,如果还未能连上,则直接返回。struct timeval timeout ; fd_set r; int ret; connect( sock, (LPSOCKADDR)sockAddr, sockAddr.Size()); FD_ZERO(&r); FD_SET(sock,&r); timeout.tv_sec = 5; timeout.tv_usec =0; ret = select(0,0,&r,0,&timeout); if ( ret <= 0 ) { closesocket(sock); return false; } 以下是对select函数的解释:int select ( int nfds, fd_set FAR * readfds, fd_set FAR * writefds, fd_set FAR * exceptfds, const struct timeval FAR * timeout ); 第一个参数nfds沒有用,仅仅为与伯克利Socket兼容而提供。readfds指定一個Socket数组(应该是一个,但这里主要是表现为一个Socket数组),select检查该数组中的所有Socket。如果成功返回,则readfds中存放的是符合‘可读性’条件的数组成员(如缓冲区中有可读的数据)。writefds指定一个Socket数组,select检查该数组中的所有Socket。如果成功返回,则writefds中存放的是符合‘可写性’条件的数组成员(如连接成功)。exceptfds指定一个Socket数组,select检查该数组中的所有Socket。如果成功返回,则cxceptfds中存放的是符合‘有异常’条件的数组成员(如连接接失败)。timeout指定select执行的最长时间,如果在timeout限定的时间内,readfds、writefds、exceptfds中指定的Socket沒有一个符合要求,就返回0。如果对Connect 进行非阻塞调用,则可读意味着已经成功连接,连接不成功则不可读。所以通过这样的设定,我们就能够实现对connect连接时间的修改。但是,应该注意,这样的设置并不能保证在限定时间内连接不上就说明网络不通。比如我们设的时间是5秒,但是由于种种原因,可能第6秒就能连接上,但是函数在5秒后就返回了。
非阻塞recvfrom的设置
int iMode = 1; //0:阻塞
ioctlsocket(socketc,FIONBIO, (u_long FAR*) &iMode);//非阻塞设置
rs=recvfrom(socketc,rbuf,sizeof(rbuf),0,(SOCKADDR*)&addr,&len);
int ioctlsocket (
SOCKET s,        
long cmd,        
u_long FAR* argp 
);
s
[in] A descriptor identifying a socket.
cmd
[in] The command to perform on the socket s.
argp
[in/out] A pointer to a parameter for cmd.

给我老师的人工智能教程打call!http://blog.csdn.net/jiangjunshow

非阻塞recvfrom的设置相关推荐

  1. 非阻塞recvfrom卡住

    背景 多线程模式下,偶尔会遇到recvfrom在非阻塞模式下不能正常返回的情况,使得系统出现假死锁,从而导致整个系统不能提供服务. 剖析 在上图中,如果threadB在进行recvfrom调用时,so ...

  2. php socket非阻塞,php stream_set_blocking设置非阻塞模式,php stream_set_blocking影响函数fgets()和fread()...

    stream_set_blocking函数可以将资源流设置为阻塞模式或者非阻塞模式,主要影响的函数分别是fgets,fread,其他的手册没有说. 在socket编程中,如果一个socket连接上了, ...

  3. 认识 fcntl 接口函数(文件非阻塞设置)

    目录 一.fcntl函数的作用 二.fcntl 函数的声明 1.参数解析 2.返回值解析 三.使用fcntl 将文件描述符设置为非阻塞 1.设置非阻塞模式实现 2.代码测试 一.fcntl函数的作用 ...

  4. epoll 边沿触发 非阻塞 IO 服务器

    在之前的文章中提到过Readn 函数: ssize_t Readn(int fd, void *vptr, size_t n) 试想这样一种情况: 1.server 循环使用 epoll_wait,监 ...

  5. Qt:Qt实现Winsock网络编程—非阻塞模式下的简单远程控制的开发(WSAAsyncSelect)

    Qt实现Winsock网络编程-非阻塞模式下的简单远程控制的开发(WSAAsyncSelect) 前言 这边博客应该是 Qt实现Winsock网络编程-TCP服务端和客户端通信(多线程) 的姐妹篇,上 ...

  6. IO模型_阻塞_非阻塞_多路复用

    在了解IO模型前,先了解什么叫IO,IO得操作是怎么样的? IO既输入输出,指的是一切操作程序或设备与计算机之间发生的数据传输的过程.它分为IO设备和IO接口两个部分. IO设备:就是指可以与计算机进 ...

  7. 高级 IO(非阻塞、多路复用、异步、存储映射、文件锁)

    目录 非阻塞I/O 阻塞I/O 与非阻塞I/O 读文件 阻塞I/O 的优点与缺点 使用非阻塞I/O实现并发读取 I/O 多路复用 何为I/O多路复用 select()函数 poll()函数 总结 异步 ...

  8. 嵌入式驱动初级-阻塞与非阻塞

    文章目录 前言 一.五种IO模型 二.阻塞与非阻塞 三.多路复用 四.信号驱动 前言 记录嵌入式驱动学习笔记 一.五种IO模型 当应用程序对设备驱动进行操作的时候,如果不能获取到设备资源,那么阻塞式 ...

  9. UDP socket 设置为的非阻塞模式

    UDP socket 设置为的非阻塞模式  Len = recvfrom(SocketFD, szRecvBuf, sizeof(szRecvBuf), MSG_DONTWAIT, (struct s ...

最新文章

  1. ML基石_9_LinearRegression
  2. MySQL的btree索引和hash索引的区别
  3. python简单编程例子-中文方便就用中文编程!Python图形界面开发实例
  4. Lambda-函数式接口(1)
  5. 加载文件流_未关闭的文件流会引起内存泄露么?
  6. 培训时常犯的学习误区与应对方法
  7. [深度学习-实践]GAN基于手写体Mnist数据集生成新图片
  8. Jenkins 在Windows下插件无法安装问题解决
  9. python基础知识点汇总_Python基础知识梳理
  10. FFA 2021 专场解读 - Flink 核心技术
  11. 分享Echarts饼状图显示信息,内容,值,百分比都显示的代码
  12. 计算机网络按传输介质分为哪几类,计算机网络按传输介质可分为哪三类?
  13. 给普通人的Python——第四章
  14. 计算机主机配置图示,2020台式电脑组装配置单图
  15. Linux/ Unix 键盘检测程序
  16. 如何pull gcr上的镜像
  17. JPEG图像压缩解压算法——C++实现
  18. 哥谭第一季/全集Gotham迅雷下载
  19. net6支持的windows版本
  20. 猛犸Winform分页控件

热门文章

  1. 碳排放权、碳交易日度数据分部门、能源碳排放面板数据
  2. h264解码之环路滤波
  3. spring事物 设计模式_是什么使事物变得美丽,以及如何在设计中使用它
  4. mysql(十)条件语句、循环语句、动态执行SQL语句
  5. shell怎样循环遍历字符串数组
  6. 敏涵控股集团董事长刘敏:唱响敏涵之歌 打造世界敏涵
  7. 仿微信朋友圈,文字展开全文,全文收起功能
  8. 一个有用的命令jcmd
  9. Python图像识别-Opencv01
  10. 给打算找技术工作的毕业生几点建议