日期:2014-05-16  浏览次数:20741 次

阻塞读 真有硬伤?
本帖最后由 shouso888 于 2013-10-30 10:47:40 编辑
捣捣stevens的《Unix 网络编程》后,留下的疑问:

客户端 阻塞于 read; 服务器主机崩溃,来不及做close 发出 FIN。

问:阻塞read 会一直阻塞?而且完全没有任何可能让它返回?因为对端主机崩溃时,只有写操作才能引起
ETIMEOUT,如果是read就会一直阻塞,TCP也不会知道对端已经崩溃。那阻塞read就是个Bug啊,不知道对端崩
溃还一直傻傻的等,用它就是埋下隐患?


------解决方案--------------------
可以设置keepalive;也可以自己加心跳包;
------解决方案--------------------
就像你把网线拔了, socket并不知道这个事情的发生, 如果你什么动作都没做过的话.
------解决方案--------------------
网络不通,第一次可以写,第二次写立马弹出一个错误,而且如果拔网线,有时候会被发送信号,程序不处理,有可能被杀死。TCP对于长时间无影响的连接,我认为是会进入CLOSE_WAIT状态,很久很久以后就断开。
------解决方案--------------------
read是会阻塞,但是不会一直阻塞的!协议里会有一个超时的!
------解决方案--------------------
用阻塞的应用一般都会考虑超时的,例如用SO_RCVTIMEO or alarm等
灵活性强了不是bug
------解决方案--------------------
引用:
Quote: 引用:

阻塞读可以自己设置timeout,
struct timeval timeout = {20, 0 };
int result = setsockopt(connfd, SOL_SOCKET, SO_RCVTIMEO,
(char *) &timeout, sizeof(timeout));
设置20秒超时,楼主可以去试试

这个我知道,谢谢提醒。
我现在最想知道:阻塞read 不设置超时, 是不是会 一直阻塞。


man手册是这样说的
If  no messages are available at the socket, the receive calls wait for a message to arrive, unless the socket is non-blocking (see  fcntl(2)),
楼主不要纠结read是否一直阻塞的问题,阻塞的系统调用大都会被EINTR信号打断,当你阻塞的recv被意外返回时,你可以perror打出来看看
------解决方案--------------------
引用:
Quote: 引用:

如果不设置超时,也没有设置SO_KEEPALIVE,会一直阻塞。


我也是这么想的,但其他的版主怎么说“read是会阻塞,但是不会一直阻塞的!协议里会有一个超时的!”
哎,不就结了。我就笃定它是永远阻塞吧。

另外其实你说的SO_KEEPALIVE原理也是间歇性的与对端有交互数据,所以保持了链接(因为太久没动作的链
接会被防火墙什么的关闭)。相当于向对端写东西,如果一直收不到对方的TCP确认就置为自己机器的SO_ERROR,
进而使我的阻塞读返回 -1。

如果有防火墙或者是通过NAT连接出去的,我就不能确定了。
但是如果两台机器是直接连接的,并且也没有设置SO_KEEPALIVE的话,read永远不会返回的。
以下的测试代码可以说明这一点

/**
 * @file    demo.c
 * @brief   
 */


#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <netdb.h>

#include <unistd.h>
#include <signal.h>

#include <errno.h>
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>

int  init(void)
{
    FILE *fp;
    char path[PATH_MAX];

    daemon(0, 0);

    signal(SIGCHLD, SIG_IGN);

    close(STDOUT_FILENO);
    close(STDERR_FILENO);
    sprintf(path, "%s/log/demo.log", getenv("HOME"));
    fp = fopen(path, "a+b");
    dup2(STDOUT_FILENO, STDERR_FILENO);

    return 0;
}

int main(int argc, char *argv[])
{