一道高频腾讯面试题tcp数据发送问题
问题引出
好几个读者私信说在腾讯面试过程中,被面试官问到了一个问题:"一个tcp服务端和一个tcp客户端,客户端和服务端建立连接后,服务端一直sleep,然后客户端一直发送数据会是什么现象"。
要回答这个问题,需要我们清楚tcp协议的特点和tcp发送数据的大体过程。
tcp发送数据过程
恐怕接触过网络的同学都知道tcp是面向连接的可靠传输协议,意味着客户端发送的数据服务端是一定能够收到的,那么对于上面的问题就不可能存在数据的丢弃。下面我们分析一下tcp的传输过程。
如图所示,tcp数据包的传输过程主要有如下几个步骤:
• 1.应用程序调用write系列函数发送数据 ,数据首先由应用程序缓冲区复制到发送端的内核中的 套接字发送缓冲区,然后write成功返回;需要特别注意的是write成功返回只是说明数据成功的由应用进程缓冲区复制到了套接字发送缓冲区,并不代表数据发送到了对端主机。• 2.内核协议栈将套接字发送缓冲区中的数据发送到对端主机,这个过程不受应用程序控制,而是发送端内核协议栈完成;• 3.数据到达接收端主机的套接字接收缓冲区,注意这个接收过程也不受应用程序控制,而是由接收端内核协议栈完成;• 4.数据由套接字接收缓冲区复制到接收端应用程序缓冲区,注意这个过程是由类似read等函数来完成。
清楚了tcp的传输过程,现在我们分情况来讨论上面的问题。
相关视频推荐
从websocket协议到tcp自定义协议,tcp分包与粘包
90分钟搞定tcp/ip协议栈
TCPIP协议栈,一次课开启你的网络之门
LinuxC++后台服务器开发架构师免费学习地址:C/C++Linux鏈嶅姟鍣ㄥ紑鍙 /鍚庡彴鏋舵瀯甯堛 愰浂澹版暀鑲层 -瀛︿範瑙嗛 鏁欑 -鑵捐 璇惧爞
【文章福利】:小编整理了一些个人觉得比较好的学习书籍、视频资料共享在群文件里面,有需要的可以自行添加哦!(需要视频资料后台私信"1"自取)
阻塞方式的情况
write系列函数的工作方式默认是阻塞方式:调用write函数时,内核从应用进程的缓冲区到套接字的发送缓冲区复制数据。如果其发送缓冲区中没有空间,进程将进入睡眠,直到有空间为止。
因此,阻塞方式下,如果服务端一直sleep不接收数据,而客户端一直write,也就是只能执行上述过程中的前三步,这样最后接收端的套接字接收缓冲区和发送端套接字发送缓冲区都被填满,这样write就无法继续将数据从应用程序复制到发送端的套接字发送缓冲区了,从而发送端进程进入睡眠。可以用下面的程序验证。
tcpClient.c是客户端代码用来发送数据,客户端每次write成功一次,将计数器count加1,同时输出本次write成功的字节数。count保存客户端write成功的次数。
#include #include #include #include #include #include #include #include #include #define PORT 8888 #define Buflen 1024 int main(int argc,char *argv[]) { struct sockaddr_in server_addr; int n,count=0; int sockfd; char sendline[Buflen]; sockfd= socket(AF_INET,SOCK_STREAM,0); memset(&server_addr,0,sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(PORT); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); server_addr.sin_addr.s_addr = inet_addr(argv[1]); connect(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)); //与服务器端进行通信 memset(sendline,"x",sizeof(Buflen)); while ( (n=write(sockfd,sendline,Buflen))>0 ) { count++; printf("already write %d bytes -- %d ",n,count); } if(n<0) perror("write error"); close(sockfd); }
下面的tcpServer.c是服务端程序,服务端并不接收数据。
#include #include #include #include #include #include #include #include #include #include #define PORT 8888 //定义通信端口 #define BACKLOG 5 //定义侦听队列长度 #define buflen 1024 int listenfd,connfd; int main(int argc,char *argv[]) { struct sockaddr_in server_addr; //存储服务器端socket地址结构 struct sockaddr_in client_addr; //存储客户端 socket地址结构 pid_t pid; listenfd = socket(AF_INET,SOCK_STREAM,0); memset(&server_addr,0,sizeof(server_addr)); server_addr.sin_family = AF_INET; //协议族 server_addr.sin_addr.s_addr = htonl(INADDR_ANY); //本地地址 server_addr.sin_port = htons(PORT); bind(listenfd,(struct sockaddr *)&server_addr,sizeof(server_addr)); listen(listenfd,BACKLOG); for(;;) { socklen_t addrlen = sizeof(client_addr); connfd = accept(listenfd,(struct sockaddr *)&client_addr,&addrlen); if(connfd<0) perror("accept error"); printf("receive connection "); if((pid = fork()) == 0) { close(listenfd); sleep(1000);//子进程不接收数据,sleep 1000秒 exit(0); } else { close(connfd); } } }
首先编译运行服务端,然后启动客户端,运行结果如下:
可以看到客户端write成功377次后就陷入了阻塞,注意这个时候不能说明发送端的套接字发送缓冲区一定是满的,只能说明套接字发送缓冲区的可用空间小于write请求写的自己数——1024。
非阻塞方式的情况
下面看一下非阻塞套接字情况下,write的工作方式:对于一个非阻塞的TCP套接字,如果发送缓冲区中根本没用空间,输出函数将立即返回一个EWOULDBLOCK错误。如果发送缓冲区中有一些空间,返回值将是内核能够复制到该缓冲区的字节数。这个字节数也成为"不足计数"。
这样就可以知道非阻塞情况下服务端一直sleep,客户端一直write数据的效果了:开始客户端write成功,随着客户端write,接收端的套接字接收缓冲区和发送端的套接字发送缓冲区会被填满。当发送端的套接字发送缓冲区的可用空间小于write请求写的字节数时,write立即返回-1,并将errno置为EWOULDBLOCK。
可以用下面的程序验证,其中,服务端程序代码和上面例子一样,我们只看客户端非阻塞模式代码:
#include #include #include #include #include #include #include #include #include #include #include #define PORT 8888 #define Buflen 1024 int main(int argc,char *argv[]) { struct sockaddr_in server_addr; int n,flags,count=0; int sockfd; char sendline[Buflen]; sockfd= socket(AF_INET,SOCK_STREAM,0); memset(&server_addr,0,sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(PORT); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); server_addr.sin_addr.s_addr = inet_addr(argv[1]); connect(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)); flags=fcntl(sockfd,F_GETFL,0); //将已连接的套接字设置为非阻塞模式 fcntl(sockfd,F_SETFL,flags|O_NONBLOCK); memset(sendline,"a",sizeof(Buflen)); while ( (n=write(sockfd,sendline,Buflen))>0 ) { count++; printf("already write %d bytes -- %d ",n,count); } if(n<0) { if(errno!=EWOULDBLOCK) perror("write error"); else printf("EWOULDBLOCK ERROR "); } close(sockfd); }
首先编译运行服务端,然后启动客户端,运行结果如下图所示。
编辑
可以看到客户端成功write 185次后就发生套接字发送缓冲区空间不足,从而返回EWOULDBLOCK错误。我们注意到每次write同样的字节数(1024)阻塞模式下能write成功377次,为什么非阻塞情况下要少呢?
这是因为阻塞模式下一直write到接收端的套接字接收缓冲区和发送端的套接字发送缓冲区都满的情况才会阻塞。而非阻塞模式情况下有可能是发送端发送过程的第二步较慢,造成发送端的套接字发送缓冲区很快写满,而接收端的套接字接收缓冲区还没有满,这样write就会仅仅因为发送端的套接字发送缓冲区满而返回错误。
原文地址:https://mp.weixin.qq.com/s/rpNTjTUt19Bbyx6IWm2-ig
膏方调养正当时丨山东省中医院2022年膏方推介化癥消积膏膏方,又称煎膏膏滋,是中医传统八种剂型膏丹丸散汤酒露锭之一。在临床中,医生根据患者病情体质,经中医辨证开出处方,然后采用道地药材精心熬制,再加蜂蜜或胶类提炼为便于服用的膏剂。冬季膏
牛皮癣的三大死穴,赶紧学起来牛皮癣很怕这三个穴位,有事没事按一按,在家不花一份钱。人类的经络是非常奇妙的,像缓解眼部疲劳可以做眼保健操,针对牛皮癣也有穴位可以治疗,今天给大家分享3个穴位,固本培元。第一个三阴
胃部经常不适,或与4类胃病有关,不同类型胃病,要针对性治疗很多患者在面对胃部疾病时,大多数都会感到束手无策,不知该从何下手。其实,针对不同类型的胃病,治疗的方法也会有所差别。今天就从四个常见的老胃病为切入点,详细的为大家分析关于胃病的症状
后溪穴统治所有颈肩腰椎病的奇效大穴后溪(输穴八脉交会穴通督脉)后溪穴为手太阳小肠经之输穴,为八脉交会穴,通督脉,输主体重节痛,故能主治颈椎腰椎肩关节病变。穴义小肠经气血由此上行督脉。名解1)后溪。后,与前相对,指穴
健康小贴士看电脑距离屏幕最好75厘米。你的眼睛会不会时常感觉疲劳?德国职业安全和卫生研究所在其最新宣传册中指出,那很可能是因为你离电脑屏幕大近了。不少人平时看电脑时距离屏幕仅50厘米左右,专
面对即将到来的更年期,你做好准备了吗?更年期是所有女性都会经历的一个阶段,是一个在女性一生中非常重要,而且必须要度过的阶段。它不分你是白领还是蓝领,不分你的职位高低,只要是女性,都要经历。聊起更年期,实事求是说对女性的
中医江志峰调脾不调肝,等于瞎胡干调脾不调肝,等于瞎胡干,为什么会这么说呢?我先得先知道,脾胃虚弱呀只是一个表现,但是真正的原因,很多人是由于肝气的郁结。很多的朋友说只注意到自己的消化不好,经常会出现胃痛胃胀,以为
德国瑞士奥地利游记(14)琉森湖光山色相互映衬的美丽城市今天我们去琉森(又称卢塞恩)。从因特拉肯到琉森约100公里,上午945分旅行车到了琉森。瑞士中部的琉森(又称卢塞恩,Luzern)是个依山傍水的美丽城市,瑞士最大的夏季避暑胜地之一
南铁记忆,广西南宁特色铁路主题文化公园来到南宁,有一个铁路主题文化公园南铁记忆最近很火,这里不仅可以跟老火车头合影,还可以在绿皮车厢里享受美食大餐,找寻流逝的年华,这里确定是个不错的选择。南铁记忆主题景观雕塑南铁记忆位
福安赛岐半山上的教室比过去强多了,曾经的我们只有怀念真爱永恒的鸡冠花雄赳赳地傲立于山坡草丛间,如一个仙女般眺望远方。在这个地方对于我们来说不陌生,甚至还仿佛如昨日场景浮现在眼前。这里曾经是我们小时候读过书的地方,所以才会印象特别深刻
骨传导耳机的天花板,南卡RunnerPro4初体验太上头了目前是年末大促的时间点,选择在此时分享数码产品体验感,着实很恰到好处。作为一名音乐发烧友,家里都摆满了马兰士安桥CAV哈曼卡顿等品牌的音乐设备,并且CD碟都花了几十个W,对于音乐的