第3講 傳送-(1)流套接字編程

第3講流套接字編程Windows網(wǎng)絡(luò)編程基礎(chǔ)內(nèi)容提要1.TCP：傳輸控制協(xié)議2.流式套接字編程模型3.基本函數(shù)4.程序舉例5.程序運(yùn)行過程分析1.TCP：傳輸控制協(xié)議運(yùn)輸層協(xié)議TCPTranspotControlProtocol，傳輸控制協(xié)議面向連接提供高可靠性服務(wù)，用于一次傳輸要交換大量報(bào)文的情形。增加許多開銷：確認(rèn)、流量控制、計(jì)時(shí)器以及連接管理等。TCP的正常的連接建立和關(guān)閉SYN,SEQ=x客戶進(jìn)程服務(wù)器進(jìn)程LISTEN（被動(dòng)打開）(主動(dòng)打開)SYN_SENTSYN_RCVDESTABLISHEDESTABLISHED(主動(dòng)關(guān)閉)FIN_WAIT_1CLOSE_WAIT(被動(dòng)關(guān)閉)FIN_WAIT_2LAST_ACKTIME_WAITCLOSED（全雙工數(shù)據(jù)傳送階段）SYN,ACK,SEQ=y,ACK=x+1ACK,SEQ=x+1,ACK=y+1FIN,SEQ=uACK,SEQ=v,ACK=u+1FIN,ACK,SEQ=v,ACK=u+1ACK,SEQ=u+1,ACK=v+1TIME_WAITCLOSE_WAITSYN_RCVDESTABLISHEDTCP

的

有

限

狀

態(tài)

機(jī)CLOSEDESTABLISHEDLISTENCLOSE_WAITFIN_WAIT_1SYN_RCVDFIN_WAIT_2CLOSINGTIME_WAITSYN_SENTLAST_ACK主動(dòng)打開被動(dòng)打開被動(dòng)關(guān)閉主動(dòng)關(guān)閉起點(diǎn)被動(dòng)打開主動(dòng)打開發(fā)送SYN同時(shí)打開收到SYN，發(fā)送SYN,ACK收到ACK數(shù)據(jù)傳送階段

關(guān)閉發(fā)送FIN

關(guān)閉發(fā)送FIN

關(guān)閉發(fā)送FIN收到RST

收到SYN發(fā)送SYN,ACK

關(guān)閉或超時(shí)收到ACK

收到SYN,ACK發(fā)送ACK收到ACK收到ACK收到FIN發(fā)送ACK收到FIN,ACK

發(fā)送ACK收到FIN發(fā)送ACK同時(shí)關(guān)閉收到FIN發(fā)送ACK發(fā)送SYN定時(shí)經(jīng)過兩倍報(bào)文段壽命后關(guān)閉1.TCP：傳輸控制協(xié)議2.流式套接字編程模型1).流套接字編程模型基礎(chǔ)傳輸方式客戶機(jī)/服務(wù)器方式特點(diǎn)面向連接過程

服務(wù)器進(jìn)程和客戶端進(jìn)程在通信前必須創(chuàng)建各自的套接字，建立連接，然后對(duì)相應(yīng)的套接字進(jìn)行“讀”、“寫”操作，實(shí)現(xiàn)數(shù)據(jù)的傳輸。2).流套接字編程的適用場(chǎng)合適用場(chǎng)合：大數(shù)據(jù)量的數(shù)據(jù)傳輸應(yīng)用可靠性要求高的傳輸應(yīng)用3).通信過程服務(wù)器通信過程：①socket初始化；②創(chuàng)建套接字，指定使用TCP（可靠的傳輸服務(wù)）進(jìn)行通信；③指定本地地址和通信端口；④等待客戶端的連接請(qǐng)求；⑤進(jìn)行數(shù)據(jù)傳輸；⑥關(guān)閉套接字；⑦結(jié)束對(duì)windowssocketsdll的使用。客戶端通信過程：①socket初始化；②創(chuàng)建套接字，指定使用TCP（可靠的傳輸服務(wù)）進(jìn)行通信；③指定服務(wù)器地址和通信端口；④向服務(wù)器發(fā)送連接請(qǐng)求；⑤進(jìn)行數(shù)據(jù)傳輸；⑥關(guān)閉套接字；⑦結(jié)束對(duì)windowssocketsdll的使用。3).通信過程4).客戶－服務(wù)器交互模型socket()，建立流式套接字，返回套接字標(biāo)識(shí)s

bind()，使套接字s與本地地址相連listen()，在套接字s上偵聽連接請(qǐng)求accept()，準(zhǔn)備接收客戶連接；accept返回，創(chuàng)建新套接字ns，原套接字s仍處于偵聽狀態(tài)；socket()，建立流式套接字，返回套接字標(biāo)識(shí)s

connect()，s與服務(wù)器建立連接recv/send(),在ns上讀寫數(shù)據(jù)closesocket()，關(guān)閉s，通信結(jié)束closesocket()，關(guān)閉套接字nsclosesocket()，關(guān)閉套接字s，服務(wù)結(jié)束服務(wù)器客戶端recv/send(),在s上讀寫數(shù)據(jù)問題：server如何處理與多個(gè)client建立連接？ListeningserverTCPServerchildServerchildclientclientTCPTCPconnectionconnectionconnectionconnectionconnectionconnection5).流式套接字服務(wù)器工作原理1.TCP：傳輸控制協(xié)議2.流式套接字編程模型3.基本函數(shù)①創(chuàng)建套接字——socket函數(shù)定義：SOCKETsocket(intaf,inttype,intprotocol);輸入?yún)?shù)：

af：指定網(wǎng)絡(luò)地址類型，一般取AF_INET，表示該套接字在Internet域中進(jìn)行通信；

type：指定套接字類型，這里取SOCK_STREAM，表創(chuàng)建的套接字是流套接字；

protocol：指定網(wǎng)絡(luò)協(xié)議，取0表示默認(rèn)為TCP/IP協(xié)議。返回值：正確：創(chuàng)建的套接字句柄SOCKET

錯(cuò)誤：INVALID_SOCKET（WSAGetLastError）功能：創(chuàng)建一個(gè)套接字，用于以后的數(shù)據(jù)傳輸說明：該函數(shù)調(diào)用指定了五元組中的“協(xié)議”一元。服務(wù)器和客戶端都要?jiǎng)?chuàng)建，服務(wù)器總是先于客戶進(jìn)程啟動(dòng)。

①創(chuàng)建套接字——socketAF_XXX與PF_XXXAF_前綴表示地址族，PF_前綴表示協(xié)議族。目前頭文件（socket.h）中為一給定協(xié)議定義的PF_值總是與此協(xié)議的AF_值相等。盡管這種相等關(guān)系并不保證永遠(yuǎn)正確，若有人試圖給已有的協(xié)議改變這種約定，則許多現(xiàn)存代碼都將崩潰，目前兩個(gè)值混用現(xiàn)象比較多。②指定本地地址——bind函數(shù)定義：

intbind(SOCKETs,conststructsockaddr*name,intnamelen);輸入?yún)?shù)：

s：標(biāo)識(shí)一個(gè)未捆綁套接字的句柄，用來等待客戶機(jī)的連接；

name：賦予套接字的地址，由structsockaddr結(jié)構(gòu)表示；

namelen：name字段的值長(zhǎng)度，以字節(jié)為單位。返回值：正確：0

錯(cuò)誤：SOCKET_ERROR（WSAGetLastError）功能：將本地地址綁定到所創(chuàng)建的套接字上以在網(wǎng)絡(luò)上標(biāo)識(shí)該套接字。關(guān)于bind函數(shù)的幾點(diǎn)說明地址種類常規(guī)地址：特定主機(jī)地址，特定端口號(hào)通配地址：INADDR_ANY，0進(jìn)程指定結(jié)果IP地址端口通配地址0內(nèi)核選擇IP和端口通配地址非0內(nèi)核選擇IP，進(jìn)程指定端口本地IP地址0進(jìn)程指定IP，內(nèi)核選擇端口本地IP地址非0進(jìn)程指定IP和端口When？client端的socket是否需要關(guān)聯(lián)本地地址的？不建議connectsendto如果由系統(tǒng)選擇地址或端口，如何獲得套接字的雙方地址？Getsockname函數(shù)：獲得本地與套接字關(guān)聯(lián)的IP地址和端口號(hào)Getpeername函數(shù)：獲得通信對(duì)等端與套接字關(guān)聯(lián)的IP地址和端口號(hào)關(guān)于bind函數(shù)的幾點(diǎn)說明③監(jiān)聽連接——listen功能： 把一個(gè)未連接的套接字轉(zhuǎn)換成一個(gè)被動(dòng)套接字；規(guī)定了內(nèi)核相應(yīng)套接字排隊(duì)的最大連接個(gè)數(shù)。函數(shù)定義：intlisten(SOCKETs,intbacklog)輸入?yún)?shù)：

S：一個(gè)本地已建立的、尚未連接的套接字標(biāo)識(shí)；

backlog：表示請(qǐng)求隊(duì)列的最大長(zhǎng)度；返回值：正確：0

錯(cuò)誤：SOCKET_ERROR操作系統(tǒng)Web服務(wù)器2.bind(80)801.socket()3.listen()Listenqueue服務(wù)器初始化未完成連接隊(duì)列（SYN_RCVD狀態(tài)）已完成連接隊(duì)列（ESTABLISHED狀態(tài)）服務(wù)器TCP到達(dá)的SYN分節(jié)三次握手完成accept兩隊(duì)列之和不超過backlogSYN,SEQ=x客戶進(jìn)程服務(wù)器進(jìn)程(主動(dòng)打開)SYN_SENTSYN_RCVDESTABLISHEDESTABLISHEDSYN,ACK,SEQ=y,ACK=x+1ACK,SEQ=x+1,ACK=y+1SYN_RCVDESTABLISHED④建立套接字連接★

客戶機(jī)端——connect（）函數(shù)定義：intconnect（SOCKETs,structsockaddrFAR*name,intnamelen）輸入?yún)?shù)：

s：本地套接字標(biāo)識(shí)

name：要建立連接的遠(yuǎn)地地址和端口

namelen：指明name的長(zhǎng)度返回值：正確：0

錯(cuò)誤：SOCKET_ERROROS1.socket()Web服務(wù)器2.bind(80)3.listen()80Listenqueue客戶connect()Requestfrom(IP,port)建立與服務(wù)器的連接關(guān)于connect函數(shù)的幾點(diǎn)說明connect函數(shù)完成的功能：注冊(cè)服務(wù)器地址與遠(yuǎn)地服務(wù)器建立連接通過connect成功建立連接：服務(wù)器存在路徑可達(dá)返回值分析阻塞套接字：返回值表示連接是否成功；非阻塞套接字：返回SOCKET_ERROR,且錯(cuò)誤號(hào)為WSAEWOULDBLOCK時(shí)，表示連接不能立即完成。Connect函數(shù)常見的若干錯(cuò)誤ETIMEDOUT錯(cuò)誤：若TCP客戶重發(fā)幾次SYN請(qǐng)求后仍然沒有收到SYN分節(jié)的響應(yīng)。ECONNREFUSED錯(cuò)誤：若服務(wù)器對(duì)客戶的SYN響應(yīng)是RST，表示該服務(wù)器主機(jī)在客戶端指定的端口上沒有進(jìn)程提供服務(wù)。EHOSTUNREACH錯(cuò)誤或ENETUNREACH錯(cuò)誤：客戶端發(fā)出SYN后收到ICMP目的不可達(dá)報(bào)文，在重試若干次后無效。注意：若connect失敗，則套接口不再可用，必須關(guān)閉，再次調(diào)用connect函數(shù)是無效的。關(guān)于connect函數(shù)的幾點(diǎn)說明操作系統(tǒng)Web服務(wù)器80Listen隊(duì)列客戶1客戶3客戶2客戶請(qǐng)求在listen隊(duì)列中獲取先進(jìn)先出服務(wù)(排隊(duì))服務(wù)器忙④建立套接字連接★

服務(wù)器端——accept（）功能：服務(wù)器端調(diào)用該函數(shù)接收客戶進(jìn)程的連接。函數(shù)定義：SOCKETaccept(SOCKETs,structsockaddrFAR*addr,intFAR*addrlen)輸入?yún)?shù)：s：本地套接字標(biāo)識(shí)addr：存放客戶進(jìn)程的地址和端口號(hào)addrlen：指明addr的長(zhǎng)度返回值：用于與當(dāng)前客戶進(jìn)程通信的新套接字的標(biāo)識(shí)，這個(gè)套接字與原有套接字的特性相同。說明：必須在listen之后調(diào)用。操作系統(tǒng)Web服務(wù)器80Listen隊(duì)列客戶1客戶3客戶2客戶請(qǐng)求在listen隊(duì)列中奪取先進(jìn)先出服務(wù)accept()已連接的socketaccept()調(diào)用

accept函數(shù)的執(zhí)行情況阻塞套接字當(dāng)連接隊(duì)列上沒有等待的連接，accept進(jìn)入阻塞狀態(tài)非阻塞套接字當(dāng)連接隊(duì)列上沒有等待的連接，accept返回錯(cuò)誤WSAEWOULDBLOCK⑤數(shù)據(jù)傳輸——send和recv★

發(fā)送數(shù)據(jù)——send函數(shù)定義：intsend(SOCKETs,constcharFAR*buf,intlen,intflags)輸入?yún)?shù)：

s：套接字標(biāo)識(shí)

buf：存放發(fā)送數(shù)據(jù)的緩沖區(qū)

len：發(fā)送數(shù)據(jù)的字節(jié)總數(shù)

flags：對(duì)發(fā)送數(shù)據(jù)的處理方式

MSG_DONTROUTE：不要路由，MSG_OOB：帶外數(shù)據(jù)返回值：成功：發(fā)送的字節(jié)總數(shù)失?。篠OCKET_ERROR數(shù)據(jù)發(fā)送給誰(shuí)？關(guān)于send函數(shù)的幾點(diǎn)說明使用場(chǎng)合流式套接字已建立連接的數(shù)據(jù)報(bào)套接字發(fā)送長(zhǎng)度<套接字允許的最大長(zhǎng)度相關(guān)錯(cuò)誤：如果數(shù)據(jù)太長(zhǎng)無法自動(dòng)通過下層協(xié)議，則返回WSAEMSGSIZE錯(cuò)誤，數(shù)據(jù)不會(huì)被發(fā)送。問題1：發(fā)送成功是否意味著數(shù)據(jù)傳送到達(dá)？否問題2：在SOCKE_STREAM中，send函數(shù)如何獲知數(shù)據(jù)的目的主機(jī)地址？Server：accept函數(shù)獲得對(duì)方地址Client：connect函數(shù)注冊(cè)對(duì)方地址問題3：如果傳送數(shù)據(jù)的緩存區(qū)空間不夠保存需傳送的數(shù)據(jù)，如何處理？阻塞模式：等待非阻塞模式：實(shí)際寫的數(shù)據(jù)可能在1到所需大小之間，其值取決于本地和遠(yuǎn)端主機(jī)的緩沖區(qū)大小。通過異步處理確定何時(shí)能夠進(jìn)一步發(fā)送數(shù)據(jù)關(guān)于send函數(shù)的幾點(diǎn)說明關(guān)于send函數(shù)的幾點(diǎn)說明問題4：根據(jù)數(shù)據(jù)長(zhǎng)度、網(wǎng)絡(luò)允許最大長(zhǎng)度和系統(tǒng)緩存的情況，實(shí)際返回的發(fā)送長(zhǎng)度有哪些情況？

設(shè)待發(fā)送的數(shù)據(jù)長(zhǎng)度為X，實(shí)際發(fā)送的字節(jié)總數(shù)為X’，分以下幾種情況討論：1）X>最大長(zhǎng)度:error2）Sysbufsize<X<最大長(zhǎng)度:阻塞模式：等待，成功發(fā)送后X’=X非阻塞模式：X’=min{本地系統(tǒng)緩存大小，遠(yuǎn)端系統(tǒng)緩存大小}3）X<sysbuf:X’=X★

接收數(shù)據(jù)——recv函數(shù)定義：intrecv(SOCKETs,charFAR*buf,intlen,intflags)輸入?yún)?shù)：

s：套接字標(biāo)識(shí)

buf：接收數(shù)據(jù)的緩沖區(qū)

len：指明buf的字節(jié)數(shù)

flags：指定處理數(shù)據(jù)的方式；

MSG_OOB：處理帶外數(shù)據(jù)；MSG_PEEK：保留數(shù)據(jù)返回值：

成功：接收的字節(jié)總數(shù) 失敗：SOCKET_ERROR⑤數(shù)據(jù)