1 常用函数
1.1 socket()
int socket(int family, int type, int protocol);
socket()打开一个网络通讯端口,如果成功的话,返回一个文件描述符,应用程序可以像读写文件一样用read/write在网络上收发数据,如果socket()调用出错则返回-1。对于IPv4,family参数指定为AF_INET。对于TCP协议,type参数指定为SOCK_STREAM,表示面向流的传输协议。如果是UDP协议,则type参数指定为SOCK_DGRAM,表示面向数据报的传输协议。protocol参数的介绍从略,指定为0即可。
1.2 bind()
int bind(int sockfd, const struct sockaddr *myaddr, socklen_t addrlen);
服务器程序所监听的网络地址和端口号通常是固定不变的,客户端程序得知服务器程序的地址和端口号后就可以向服务器发起连接,因此服务器需要调用bind绑定一个固定的网络地址和端口号。bind()成功返回0,失败返回-1。bind()的作用是将参数sockfd和myaddr绑定在一起,使sockfd这个用于网络通讯的文件描述符监听myaddr所描述的地址和端口号。前面讲过,struct sockaddr *是一个通用指针类型,myaddr参数实际上可以接受多种协议的sockaddr结构体,而它们的长度各不相同,所以需要第三个参数addrlen指定结构体的长度
1.3 listen()
int listen(int sockfd, int backlog);// backlog取值0~5.
典型的服务器程序可以同时服务于多个客户端,当有客户端发起连接时,服务器调用的accept()返回并接受这个连接,如果有大量的客户端发起连接而服务器来不及处理,尚未accept的客户端就处于连接等待状态,listen()声明sockfd处于监听状态,并且最多允许有backlog个客户端处于连接待状态,如果接收到更多的连接请求就忽略。listen()成功返回0,失败返回-1。
1.4 accept()
int accept(int sockfd, struct sockaddr *cliaddr, socklen_t *addrlen);
三方握手完成后,服务器调用accept()接受连接,如果服务器调用accept()时还没有客户端的连接请求,就阻塞等待直到有客户端连接上来。cliaddr是一个传出参数,accept()返回时传出客户端的地址和端口号。addrlen参数是一个传入传出参数(value-result argument),传入的是调用者提供的缓冲区cliaddr的长度以避免缓冲区溢出问题,传出的是客户端地址结构体的实际长度(有可能没有占满调用者提供的缓冲区)。如果给cliaddr参数传NULL,表示不关心客户端的地址。
2 简单实现服务器编程(C语言)
1 unsigned char TcpRecvBuf[1520]; /* 接收缓冲区 */ 2 static void Task_WebServer (void *pdata) 3 { 4 struct sockaddr_in server, client; 5 int sock, client_socket; 6 socklen_t len; 7 8 server.sin_family = AF_INET; /* 地址类型为IPv4 */ 9 server.sin_port = htons( 80 ); /* 设置服务器的端口:80端口 */ 10 server.sin_addr.s_addr = htonl( INADDR_ANY ); /* 监听本地任意网卡 */ 11 sock = socket( AF_INET, SOCK_STREAM, 0 ); /* 使用TCP连接 */ 12 bind( sock, (struct sockaddr *)&server, sizeof( server ) );/* 绑定本地接口 */ 13 listen( sock, 5 ); /* 进入监听模式 */ 14 while(1) { 15 len = sizeof(client); 16 client_socket = accept( sock, (struct sockaddr *)&client, &len );/* 接受一个连接,会阻塞程序 */ 17 if(client_socket != -1) { 18 /* 19 * 接收数据,将会阻塞程序 20 */ 21 if ((read(client_socket, TcpRecvBuf, sizeof(TcpRecvBuf))) > 0) { 22 /* 23 * 简单的检查数据是否符合HTTP协议,数据内容开头是“GET /” 24 */ 25 if(TcpRecvBuf[0] == ‘G‘ && TcpRecvBuf[1] == ‘E‘ && 26 TcpRecvBuf[2] == ‘T‘ && TcpRecvBuf[3] == ‘ ‘ && 27 TcpRecvBuf[4] == ‘/‘) { 28 /** 29 * 下面为GET请求返回的数据,用户可以自己定义 30 */ 31 //write(client_socket, http_html_hdr,sizeof(http_html_hdr)); 32 //write(client_socket, indexdata,sizeof(indexdata)); 33 } 34 } 35 close( client_socket ); /* 关闭此连接 */ 36 } 37 /** 这里可以延时一定时间 */ 38 } 39 }