【正文】 r Socket() Bind() Recvfrom() Blocks until data received Process request Sendto() Client Socket() Bind() Sendto() Blocks until data received Process reply recvfrom() close() close() 8/18/2022 59 創(chuàng)建 UDP socket SOCKET socket(int family,int type,int protocol)。 SOCKET sock。 sock = socket( AF_INET, SOCK_DGRAM, 0)。 8/18/2022 60 服務(wù)器綁定地址 SOCKET s。 sockaddr_in addr。 s = socket(AF_INET, SOCK_DGRAM, 0)。 = AF_INET。 = htons(2022)。 = htonl(INADDR_ANY)。 if (bind(s, (sockaddr*)amp。addr, sizeof(addr)) == SOCKET_ERROR) { // 錯誤處理 } Fill in addr 8/18/2022 61 Basic Socket Calls (sendto) // Berkeley form int sendto(int s, const char* bytesToSend, int nBytes, int flags, struct sockaddr *to, int sizeOfSockaddr)。 // WinSock form int sendto(SOCKET s, const char* bytesToSend, int nBytes, int flags, struct sockaddr *to, int sizeOfSockaddr)。 8/18/2022 62 sendto (續(xù) ) int sendto (SOCKET s, const char* bytesToSend, int nBytes, int flags struct sockaddr *to, int sizeOfSockaddr)。 ? to是指向接收者地址的指針 ? sizeOfSockaddr is sizeof(struct sockaddr_in) ? 當調(diào)用成功， sendto()返回被成功發(fā)送的字節(jié)數(shù)；當調(diào)用失敗，返回 SOCKET_ERROR ? 需要說明兩點：第一，由于 UDP是不可靠的，因此 sendto()的成功返回并不代表數(shù)據(jù)被成功發(fā)送到了目標地址，甚至不能保證數(shù)據(jù)已經(jīng)從本機發(fā)出；第二， sendto()一次發(fā)送的數(shù)據(jù)大小是有上限的，至少要小于 IP包的大小（約 64K） 8/18/2022 63 sendto()的典型用法 ? define BUFSIZE 1024 ? SOCKET s。 ? sockaddr_in addr。 ? char buf[BUFSIZE]。 ? int bufLen。 ? int bytesSent。 ? s = socket(AF_INET, SOCK_DGRAM, 0)。 ? if (s == INVALID_SOCKET) ? { ? //錯誤處理 ... ? } ? else ? { ? // 填充接收者的地址 ? = AF_INET。 ? = htons(2022)。 ? = i_addr()。 ? // 填充待發(fā)數(shù)據(jù)到緩沖區(qū) ? strcpy(buf, Hello, World!)。 ? bufLen = strlen(buf)。 ? // 發(fā)送數(shù)據(jù)報 ? bytesSent = sendto(s, buf, bufLen, 0, (sockaddr*)amp。addr, sizeof(addr))。 ? if (bytesSent == SOCKET_ERROR) ? { ? //錯誤處理 ... ? } ? closesocket(s)。 ? } 8/18/2022 64 Basic Socket Calls (recvfrom) // Berkeley form int recvfrom(int s char* receivedData, int nBytes, int flags, struct sockaddr *from, int sizeOfSockaddr)。 // WinSock form int recvfrom(SOCKET s, char* receivedBytes, int nBytes, int flags, struct sockaddr *from, int sizeOfSockaddr)。 8/18/2022 65 recvfrom (續(xù) ) int recvfrom (SOCKET s, char* receivedData, int nBytes, int flags struct sockaddr *from, int sizeOfSockaddr)。 ? from是指向數(shù)據(jù)發(fā)送者地址的指針 ? sizeOfSockaddr is sizeof(struct sockaddr_in) ? 當調(diào)用成功， recvfrom()返回被接收的字節(jié)數(shù)；當調(diào)用失敗，返回 SOCKET_ERROR。這里要說明，如果返回 0，并不說明有錯誤發(fā)生，而是讀取了一個純 UDP報文頭。如果接收到的數(shù)據(jù)報比提供的接收緩沖區(qū)要大，那么會出現(xiàn)WSAEMSGSIZE錯誤。 8/18/2022 66 recvfrom()的典型用法 ? define BUFSIZE 1024 ? SOCKET s。 ? sockaddr_in addr。 // 本 Socket地址結(jié)構(gòu) ? char buf[BUFSIZE]。 // 接收緩沖區(qū) ? int bytesRecv。 ? sockaddr_in addrFrom。 // 發(fā)送方地址結(jié)構(gòu) ? int addrFromLen = sizeof(addrFrom)。 // 發(fā)送方地址結(jié)構(gòu)長度 ? in_addr inFrom。 // 發(fā)送方 IP地址 ? s = socket(AF_INET, SOCK_DGRAM, 0)。 ? if (s == INVALID_SOCKET) ? { ? //錯誤處理 ... ? } 8/18/2022 67 ? else ? { ? // 填充本地地址結(jié)構(gòu)以便從中讀取數(shù)據(jù) ? = AF_INET。 ? = htons(2022)。 ? = htonl(INADDR_ANY)。 ? // 綁定 socket ? if (bind(s, (sockaddr*)amp。addr, sizeof(addr)) == SOCKET_ERROR) ? { ? //錯誤處理 ... ? } ? else ? { ? bytesRecv = recvfrom(s, buf, BUFSIZE, 0, ? (sockaddr*)amp。addrFrom, amp。addrFromLen)。 ? if (bytesRecv == SOCKET_ERROR) ? { ? //錯誤處理 ... ? } ? else ? { ? // 處理得到的數(shù)據(jù) ... ? memcpy(amp。inFrom, amp。, 4)。 ? printf(服務(wù)器從地址 %s, 端口為 %d 的客戶端收到字節(jié)數(shù) %d , ? i_ntoa(inFrom), ntohs(), bytesRecv)。 ? } ? } ? closesocket(s)。 ? } 8/18/2022 68 Example ? 使用的是無連接的數(shù)據(jù)報 socket完成和 示例同樣的功能。 8/18/2022 69 實例 — 從 Web服務(wù)器下載文件 Method URL CR LF Sp CR LF 簡單 HTTP請求的格式