close函数的作用是关闭套接字,并终止TCP连接。unix网络编程这本书上是这样说的,我觉得这个解释有人会让人产生误解。close了某个socket,该socket就真的必须关闭吗?其实不是,close是将该套接字的引用计数减1,当某个套接字的引用计数为0时,该套接字就被关闭了;不为0,就不会被关闭。多进程并发服务器中会出现这种情况,我开始就误解了。

SO_LINGER套接字选项是用来设置close操作的。直接看代码吧。

[mapan@localhost test]$ ls
client.cpp  makefile  server.cpp
[mapan@localhost test]$ cat server.cpp
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <malloc.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/ioctl.h>
#include <stdarg.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#define MAXLINE 4096int main()
{int listenfd,acceptfd;socklen_t  clilen;struct sockaddr_in cliaddr,servaddr;listenfd=socket(AF_INET,SOCK_STREAM,0);servaddr.sin_family=AF_INET;servaddr.sin_port=htons(8888);servaddr.sin_addr.s_addr = inet_addr("127.0.0.1"); bind(listenfd,(struct sockaddr *)&servaddr,sizeof(struct sockaddr_in));listen(listenfd,5);acceptfd=accept(listenfd,(struct sockaddr *)NULL,NULL);char recvbuf[200000];while(1){getchar();read(acceptfd,recvbuf,sizeof(recvbuf));   }getchar();close(listenfd);return 0;
}
[mapan@localhost test]$ cat client.cpp
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <malloc.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/ioctl.h>
#include <stdarg.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#define MAXLINE 4096int main()
{int sockfd;struct sockaddr_in servaddr;sockfd=socket(AF_INET,SOCK_STREAM,0);bzero(&servaddr,sizeof(servaddr));servaddr.sin_family=AF_INET;servaddr.sin_port=htons(8888);servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");struct linger so_linger;so_linger.l_onoff=0;//so_linger.l_linger=20;setsockopt(sockfd,SOL_SOCKET,SO_LINGER,&so_linger,sizeof(so_linger));  int ret=connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));char sendbuf[200000];write(sockfd,sendbuf,sizeof(sendbuf));      close(sockfd);return 0;
}[mapan@localhost test]$ cat makefile
all:server clientserver.o:server.cppg++ -c server.cpp
client.o:client.cppg++ -c client.cpp
server:server.og++ -o server server.o
client:client.og++ -o client client.oclean:rm -f server client *.o
[mapan@localhost test]$ 

编译并运行,客户端需要打开另一个窗口执行。

[mapan@localhost test]$ make
g++ -c server.cpp
g++ -o server server.o
g++ -c client.cpp
g++ -o client client.o
[mapan@localhost test]$ ./server

运行客户端,并查看网络状态。

[mapan@localhost test]$ ./client
[mapan@localhost test]$ 
[mapan@localhost ~]$ netstat -na | grep 8888
tcp        0      0 127.0.0.1:8888              0.0.0.0:*                   LISTEN
tcp        0  61101 127.0.0.1:35260             127.0.0.1:8888              FIN_WAIT1
tcp   138900      0 127.0.0.1:8888              127.0.0.1:35260             ESTABLISHED
[mapan@localhost ~]$

可以看到的是close立即返回了,套接字关闭了,但客户端发送缓冲区中仍然还有数据。当服务端接收缓冲区有地方后,这些数据将会由系统自动发送给服务端,但是此时客户端讲不会管服务端是否已接收到数据。l_onoff=0,就是关闭这个套接字选项,默认close操作。注意观察,此时客户端的状态时FIN_WAIT1,就是客户单还没有把数据发送完毕,所以没有接到服务端协议栈返回的ACK,所以客户端为这个状态。

再改变客户端代码:

#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/ioctl.h>
#include <stdarg.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#define MAXLINE 4096int main()
{int sockfd;struct sockaddr_in servaddr;sockfd=socket(AF_INET,SOCK_STREAM,0);bzero(&servaddr,sizeof(servaddr));servaddr.sin_family=AF_INET;servaddr.sin_port=htons(8888);servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");struct linger so_linger;so_linger.l_onoff=1;so_linger.l_linger=0;setsockopt(sockfd,SOL_SOCKET,SO_LINGER,&so_linger,sizeof(so_linger));  int ret=connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));char sendbuf[200000];write(sockfd,sendbuf,sizeof(sendbuf));      getchar();close(sockfd);return 0;
}

还是按照上述操作,编译后启动服务端和客户端。此时会发现客户端卡在getchar()处,查看此时的网络状态。

[mapan@localhost ~]$ netstat -na | grep 8888
tcp        0      0 127.0.0.1:8888              0.0.0.0:*                   LISTEN
tcp   138900      0 127.0.0.1:8888              127.0.0.1:35262             ESTABLISHED
tcp        0  61100 127.0.0.1:35262             127.0.0.1:8888              ESTABLISHED
[mapan@localhost ~]$ 

客户端的发送缓冲区中还没有数据发送出去,如果是我们说的第一种情况,在客户端按下回车键之后,客户端应该FIN_WAIT1状态。好,我们在客户端按下回车键后看网络状态。

[mapan@localhost ~]$ netstat -na | grep 8888
tcp        0      0 127.0.0.1:8888              0.0.0.0:*                   LISTEN
[mapan@localhost ~]$

看,连接直接断开了。说明close调用后,会丢弃发送缓冲区的内存,并发送一个RST给服务端,从而断开连接,这也避免了time_wait的状态。这也是将 so_linger.l_onoff=1,so_linger.l_linger=0的close效果。

在看客户端代码:

[mapan@localhost test]$ cat client.cpp
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <malloc.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/ioctl.h>
#include <stdarg.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#define MAXLINE 4096int main()
{int sockfd;struct sockaddr_in servaddr;sockfd=socket(AF_INET,SOCK_STREAM,0);bzero(&servaddr,sizeof(servaddr));servaddr.sin_family=AF_INET;servaddr.sin_port=htons(8888);servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");struct linger so_linger;so_linger.l_onoff=1;so_linger.l_linger=10;setsockopt(sockfd,SOL_SOCKET,SO_LINGER,&so_linger,sizeof(so_linger));  int ret=connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));char sendbuf[200000];write(sockfd,sendbuf,sizeof(sendbuf));      //getchar();close(sockfd);return 0;
}

还是重复上述操作,编译运行查看网络状态,此时我将getchar()注释掉了。你会看到客户端会卡在那里,其原因是调用了close函数,但是它不会马上返回,close等待的时间是我们设置的超时时间。看此时的网络状态。

[mapan@localhost ~]$ netstat -na | grep 8888
tcp        0      0 127.0.0.1:8888              0.0.0.0:*                   LISTEN
tcp        0  61101 127.0.0.1:35266             127.0.0.1:8888              FIN_WAIT1
tcp   138900      0 127.0.0.1:8888              127.0.0.1:35266             ESTABLISHED
[mapan@localhost ~]$ 

当客户端发送缓冲区中的数据全部发送到服务端的协议栈,并且接收到了服务端的ACK,那么此时close就会返回,前提是在我们设置的超时时间之内。过了超时时间,close也会返回,那就和我们说的第一种情况一样了。

网络问题本应该用tcpdump抓包来看效果的,但是很遗憾,我正在测试的linux上没有root权限。

参考资料:unix网络编程卷一

close和SO_LINGER相关推荐

  1. 套接字选项SO_LINGER

    在说明套接字选项SO_LINGER之前,我们来先看一个问题.如果发送缓冲区中还有数据没有发送到对方协议栈,此时close发送端的socket会发生什么,下面代码给出答案. 服务端: #include ...

  2. java网络编程Socket中SO_LINGER选项的用法解读

    http://blog.sina.com.cn/s/blog_6b1990eb0101171o.html 1:设置该选项: public void setSoLinger(boolean on, in ...

  3. 异步socket优雅的关闭-CancelIO和SO_LINGER

    我们在利用IOCP(完成端口)进行程序设计的时候,经常要关闭一些不满足条件的套接字.假如我们直接采用closesocket方法进行关闭的话,绑定到IO端口的此套接字的未发送的数据就会丢失,这种情况是我 ...

  4. linux so_nosigpipe,TCP_NODELAY/SO_LINGER/SO_NOSIGPIPE/MSG_NOSIGNAL设置

    下面是TCP_NODELAY/SO_LINGER/SO_NOSIGPIPE/MSG_NOSIGNAL的设置方法: 其中由于平台的不同,区分SO_NOSIGPIPE和MSG_NOSIGNAL有所分区: ...

  5. Linux下高性能网络编程中的几个TCP/IP选项_SO_REUSEADDR、SO_RECVBUF、SO_SNDBUF、SO_KEEPALIVE、SO_LINGER、TCP_CORK、TCP_NODE

    最近在新的平台上测试程序,以前一些没有注意到的问题都成为了性能瓶颈,通过设置一些TCP/IP选项能够解决一部分问题,当然根本的解决方法是重构代码,重新设计服务器框架.先列出几个TCP/IP选项: 选项 ...

  6. 重学TCP协议(12)SO_REUSEADDR、SO_REUSEPORT、SO_LINGER

    1. SO_REUSEADDR 假如服务端出现故障,主动断开连接以后,需要等 2 个 MSL 以后才最终释放这个连接,而服务重启以后要绑定同一个端口,默认情况下,操作系统的实现都会阻止新的监听套接字绑 ...

  7. SO_LINGER和优雅关闭连接

    当调用closesocket关闭套接字时,SO_LINGER将决定系统如何处理残存在套接字发送队列中的数据.处理方式无非两种:丢弃或者将数据继续发送至对端,优雅关闭连接.事实上,SO_LINGER并不 ...

  8. TCP_NODELAY/SO_LINGER/SO_NOSIGPIPE/MSG_NOSIGNAL设置

    下面是TCP_NODELAY/SO_LINGER/SO_NOSIGPIPE/MSG_NOSIGNAL的设置方法: 其中由于平台的不同,区分SO_NOSIGPIPE和MSG_NOSIGNAL有所分区: ...

  9. linux so_linger,linux系统编程之getsockopt/setsockopt 函数

    最近看别人写的代码很多函数不知道啊,在研究分布式消息队列beanstalkd,遇到了很多东西.尤其是网络连接方面. 代码是这样的. setsockopt(fd, SOL_SOCKET, SO_REUS ...

最新文章

  1. 庆祝深圳.net俱乐部成立
  2. Visual Studio 智能提示消失解决办法
  3. 计算机考研英语什么时候考试,计算机考研:早期复习三大注意事项
  4. linux 文件指针,Linux中文件描述符fd与文件指针FILE*互相转换实例解析
  5. Airflow 中文文档:安全
  6. grDevices | 如何在图形中使用数学表达式作为标注文本
  7. java panel画椭圆_如何在Java 2D中绘制椭圆?
  8. 关于分块思想的个人理解
  9. MSCRM4.0商机移除价目表引起的问题
  10. C#中使用Dictionary实现Map数据结构
  11. 哥德巴赫猜想-中文维基百科
  12. android 自定义柱形图简书,android 自定义网状图
  13. 转载:ant自动构建
  14. 5000在线的服务器选择,支持负载5000人10000人在线的服务器的配置及其网络要求!!...
  15. 台式计算机怎么加一个硬盘,如何给台式机添加硬盘?给电脑添加硬盘的方法
  16. 【精品】居住证、工作居住证、北京户口区别有多大?
  17. 如何在邮件正文显示自己的简历
  18. 【大数据面试题】(五)Spark 相关面试题总结
  19. 面试官:hold住了八股和算法,扫码登录应该怎么实现你总不会了吧
  20. [HDU]1205 吃糖果 [抽屉原理]

热门文章

  1. 【Android RTMP】x264 图像数据编码 ( Camera 图像数据采集 | NV21 图像数据传到 Native 处理 | JNI 传输字节数组 | 局部引用变量处理 | 线程互斥 )
  2. git 避免重复输入用户名密码问题解决
  3. Mysql 8.0安装
  4. js实现创建二叉树+先序遍历
  5. 关于String函数
  6. PyQt5显示一个空白的窗口
  7. tomcat session 共享
  8. 算法:两种步长的希尔排序算法
  9. Matlab Robotic Toolbox V9.10工具箱(五):动力学简介
  10. JAVA学习之路 不走弯路,就是捷径