[導讀]今天又是被傾盆的需求淹沒的一天。有沒有人知道，那種“我用3句話，就讓產品為我砍了18個需求”的雞湯課在哪報名，想報。"聽懂掌聲"的那種課就算了，太費手了。扯遠了，回到我們今天的正題，我們了解下這篇文的目錄。目錄代碼執(zhí)行send成功后，數(shù)據(jù)就發(fā)出去了嗎？回答這個問題之前，需要了解什么是Socket緩沖區(qū)。Socket緩沖區(qū)什么是socket緩沖區(qū)編程的時候，如果要跟某個IP建立連接，我們需要調用操作系統(tǒng)提供的socketAPI。socket在操作系統(tǒng)層面，可以理解為一個文件。我們可以對這個文件進行一些方法操作。用listen方法，可以讓程序作為服務器監(jiān)聽其他客戶端的連接。用connect，可以作...
今天又是被傾盆的需求淹沒的一天。有沒有人知道，那種“我用3句話，就讓產品為我砍了18個需求”的雞湯課在哪報名，想報。"聽懂掌聲"的那種課就算了，太費手了。目錄
socket_api 一個socket有兩個緩沖區(qū)
tcp_sendmsg 邏輯
send阻塞 send非阻塞
Socket 緩沖區(qū)
什么是 socket 緩沖區(qū)
編程的時候，如果要跟某個IP建立連接，我們需要調用操作系統(tǒng)提供的socket API。socket 在操作系統(tǒng)層面，可以理解為一個文件。我們可以對這個文件進行一些方法操作。用listen方法，可以讓程序作為服務器監(jiān)聽其他客戶端的連接。用connect，可以作為客戶端連接服務器。用send或write可以發(fā)送數(shù)據(jù)，recv或read可以接收數(shù)據(jù)。在建立好連接之后，這個 socket 文件就像是遠端機器的 "代理人" 一樣。比如，如果我們想給遠端服務發(fā)點什么東西，那就只需要對這個文件執(zhí)行寫操作就行了。怎么觀察 socket 緩沖區(qū)
如果想要查看 socket 緩沖區(qū)，可以在linux環(huán)境下執(zhí)行netstat -nt 命令。#?netstat?-nt
Active?Internet?connections?(w/o?servers)
Proto?Recv-Q?Send-Q?Local?Address???????????Foreign?Address?????????State??????
tcp????????0?????60?172.22.66.69:22?????????122.14.220.252:59889????ESTABLISHED
這上面表明了，這里有一個協(xié)議（Proto）類型為 TCP 的連接，同時還有本地（Local Address）和遠端（Foreign Address）的IP信息，狀態(tài)（State）是已連接。還有Send-Q 是發(fā)送緩沖區(qū)，下面的數(shù)字60是指，當前還有60 Byte在發(fā)送緩沖區(qū)中未發(fā)送。而 Recv-Q 代表接收緩沖區(qū)， 此時是空的，數(shù)據(jù)都被應用進程接收干凈了。TCP部分
【動圖緩沖區(qū)的收發(fā)流程，TCP執(zhí)行發(fā)收的流程】我們在使用TCP建立連接之后，一般會使用 send 發(fā)送數(shù)據(jù)。int?main(int?argc,?char?*argv[])
{
????//?創(chuàng)建socket
????sockfd=socket(AF_INET,SOCK_STREAM,?0))
????//?建立連接??
????connect(sockfd,?服務器ip信息,?sizeof(server))??
????//?執(zhí)行?send?發(fā)送消息
????send(sockfd,str,sizeof(str),0))??
????//?關閉?socket
????close(sockfd);
????return?0;
}
上面是一段偽代碼，僅用于展示大概邏輯，我們在建立好連接后，一般會在代碼中執(zhí)行 send 方法。那么此時，消息就會被立刻發(fā)到對端機器嗎？執(zhí)行 send 發(fā)送的字節(jié)，會立馬發(fā)送嗎？
答案是不確定！執(zhí)行 send 之后，數(shù)據(jù)只是拷貝到了socket 緩沖區(qū)。至 什么時候會發(fā)數(shù)據(jù)，發(fā)多少數(shù)據(jù)，全聽操作系統(tǒng)安排。//?net/ipv4/tcp.c
//?以下省略了大量邏輯
int?tcp_sendmsg()
{??
??//?如果還有可以放數(shù)據(jù)的空間
??if?(skb_availroom(skb)?>?0)?{
????//?嘗試拷貝待發(fā)送數(shù)據(jù)到發(fā)送緩沖區(qū)
????err?=?skb_add_data_nocache(sk,?skb,?from,?copy);
??}??
??//?下面是嘗試發(fā)送的邏輯代碼,先省略?????
}
在 tcp_sendmsg 中， 核心工作就是將待發(fā)送的數(shù)據(jù)組織按照先后順序放入到發(fā)送緩沖區(qū)中， 然后根據(jù)實際情況（比如擁塞窗口等）判斷是否要發(fā)數(shù)據(jù)。如果不發(fā)送數(shù)據(jù)，那么此時直接返回。如果緩沖區(qū)滿了會怎么辦
前面提到的情況里是，發(fā)送緩沖區(qū)有足夠的空間，可以用于拷貝待發(fā)送數(shù)據(jù)。如果發(fā)送緩沖區(qū)空間不足，或者滿了，執(zhí)行發(fā)送，會怎么樣？
這里分兩種情況。首先，socket在創(chuàng)建的時候，是可以設置是阻塞的還是非阻塞的。int?s?=?socket(AF_INET,?SOCK_STREAM?|?SOCK_NONBLOCK,?IPPROTO_TCP);
比如通過上面的代碼，就可以將 socket 設置為非阻塞 （SOCK_NONBLOCK）。當發(fā)送緩沖區(qū)滿了，如果還向socket執(zhí)行send- 如果此時 socket 是阻塞的，那么程序會在那干等、死等，直到釋放出新的緩存空間，就繼續(xù)把數(shù)據(jù)拷進去，然后返回。
- 如果此時 socket 是非阻塞的，程序就會立刻返回一個
EAGAIN錯誤信息，意思是 ?Try again, 現(xiàn)在緩沖區(qū)滿了，你也別等了，待會再試一次。
tcp_sendmsg 發(fā)送方法中。int?tcp_sendmsg()
{??
??if?(skb_availroom(skb)?>?0)?{
????//?..如果有足夠緩沖區(qū)就執(zhí)行balabla
??}?else?{
????//?如果發(fā)送緩沖區(qū)沒空間了，那就等到有空間，至于等的方式，分阻塞和非阻塞
????if?((err?=?sk_stream_wait_memory(sk,? 
下載文檔
