Socket網(wǎng)絡(luò)高級(jí)編程

?　10.3 網(wǎng)絡(luò)高級(jí)編程
　　在實(shí)際情況中，人們往往遇到多個(gè)客戶端連接服務(wù)器端的情況。由于之前介紹的如connet（）、recv（）和send（）等都是阻塞性函數(shù)，如果資源沒(méi)有準(zhǔn)備好，則調(diào)用該函數(shù)的進(jìn)程將進(jìn)入睡眠狀態(tài)，這樣就無(wú)法處理I/O多路復(fù)用的情況了。本節(jié)給出了兩種解決I/O多路復(fù)用的解決方法，這兩個(gè)函數(shù)都是之前學(xué)過(guò)的fcntl（）和select（）（請(qǐng)讀者先復(fù)習(xí)第6章中的相關(guān)內(nèi)容）。可以看到，由于在Linux中把socket也作為一種特殊文件描述符，這給用戶的處理帶來(lái)了很大的方便。
　　1．fcntl（）
　　函數(shù)fcntl（）針對(duì)socket編程提供了如下的編程特性。
　　n 非阻塞I/O：可將cmd設(shè)置為F_SETFL，將lock設(shè)置為O_NONBLOCK。
　　n 異步I/O：可將cmd設(shè)置為F_SETFL，將lock設(shè)置為O_ASYNC。
　　下面是用fcntl（）將套接字設(shè)置為非阻塞I/O的實(shí)例代碼：
　　/* net_fcntl.c */
　　#include 《sys/types.h》
　　#include 《sys/socket.h》
　　#include 《sys/wait.h》
　　#include 《stdio.h》
　　#include 《stdlib.h》
　　#include 《errno.h》
　　#include 《string.h》
　　#include 《sys/un.h》
　　#include 《sys/time.h》
　　#include 《sys/ioctl.h》
　　#include 《unistd.h》
　　#include 《netinet/in.h》
　　#include 《fcntl.h》
　　#define PORT 1234
　　#define MAX_QUE_CONN_NM 5
　　#define BUFFER_SIZE 1024
　　int main（）
　　{
　　struct sockaddr_in server_sockaddr， client_sockaddr;
　　int sin_size， recvbytes， flags;
　　int sockfd， client_fd;
　　char buf［BUFFER_SIZE］;
　　if （（sockfd = socket（AF_INET， SOCK_STREAM， 0）） == -1）
　　{
　　perror（“socket”）;
　　exit（1）;
　　}
　　server_sockaddr.sin_family = AF_INET;
　　server_sockaddr.sin_port = htons（PORT）;
　　server_sockaddr.sin_addr.s_addr = INADDR_ANY;
　　bzero（&（server_sockaddr.sin_zero）， 8）;
　　int i = 1;/* 允許重復(fù)使用本地地址與套接字進(jìn)行綁定 */
　　setsockopt（sockfd， SOL_SOCKET， SO_REUSEADDR， &i， sizeof（i））;
　　if （bind（sockfd， （struct sockaddr *）&server_sockaddr，
　　sizeof（struct sockaddr）） == -1）
　　{
　　perror（“bind”）;
　　exit（1）;
　　}
　　if（listen（sockfd，MAX_QUE_CONN_NM） == -1）
　　{
　　perror（“l(fā)isten”）;
　　exit（1）;
　　}
　　printf（“Listening.。..\n”）;
　　/* 調(diào)用fcntl（）函數(shù)給套接字設(shè)置非阻塞屬性 */
　　flags = fcntl（sockfd， F_GETFL）;
　　if （flags 《 0 || fcntl（sockfd， F_SETFL， flags|O_NONBLOCK） 《 0）
　　{
　　perror（“fcntl”）;
　　exit（1）;
　　}
　　while（1）
　　{
　　sin_size = sizeof（struct sockaddr_in）;
　　if （（client_fd = accept（sockfd，
　　（struct sockaddr*）&client_sockaddr， &sin_size）） 《 0）
　　{
　　perror（“accept”）;
　　exit（1）;
　　}
　　if （（recvbytes = recv（client_fd， buf， BUFFER_SIZE， 0）） 《 0）
　　{
　　perror（“recv”）;
　　exit（1）;
　　}
　　printf（“Received a message： %s\n”， buf）;
　　} /*while*/
　　close（client_fd）;
　　exit（1）;
　　}
　　運(yùn)行該程序，結(jié)果如下所示：
　　$ 。/net_fcntl
　　Listening.。..
　　accept： Resource temporarily unavailable
　　可以看到，當(dāng)accept（）的資源不可用（沒(méi)有任何未處理的等待連接的