http服务器,就是一个运行在主机上的程序。程序启动了之后,会一直等待其他所有用户端的请求,接收到请求之后,处理请求,然后发送响应给客户端。客户端和服务器之间使用http协议进行通信,所有遵循http协议的程序都可以作为客户端。
socket套接字:
int socket(int family,int type,int protocol);
- family:协议族。AF_INET:IPV4协议;AF_INET6:IPv6协议;AF_LOCAL:Unix域协议;AF_ROUTE:路由套接字;AF_KEY:密钥套接字
- type:套接字类型。SOCK_STREAM : 字节流套接字;SOCK_DGRAM:数据包套接字;SOCK_SEGPACKET:有序分组套接字;SOCK_RAW:原始套接字
- protocol:某个协议类型常量。TCP:0,UDP :1, SCTP :2
套接字地址结构:
在socket编程中,大部分函数都用到一个指向套接字地质结构的指针作为参数,针对不同的协议类型,会有不同的结构体定义格式,对于iPv4结构如下:
struct sockaddr_in { uint8_t sin_len; /* 结构体的长度 */ sa_family_t sin_family; /* IP协议族,IPV4是AF_INET */ in_port_t sin_port; /* 一个16比特的TCP/UDP端口地址 */ struct in_addr sin_addr; /* 32比特的IPV4地址,网络字节序 */ char sin_zero[8]; /* 未使用字段 */ }; 注:sockaddr_in是**Internet socket address structure**的缩写。
ip地址结构:
struct in_addr{ in_addr_t s_addr; }
套接字的地址结构作用是为了将ip地址和端口号传递到socket函数,写成结构体的方式是为了抽象。党作为一个参数传递进任何套接字函数时,套接字地址结构总是以引用方式传递。然而,协议族有很多,因此这样的指针作为参数之一的任何套接字函数必须处理来自所有支持的任何协议族的套接字地址结构。使用void*作为通用的指针类型,因此套接字函数被定义为以指向某个通用套接字结构的一个指针作为其参数之一
int bind(int ,struct sockaddr* ,socklen_t)
这样就要求,对这些函数的任何调用都必须将指向特定于协议的套接字的地址结构的指针进行强制类型转换,变成某个通用套接字的结构的指针。
struct sockaddr_in addr;
bind(sockfd,(struct sockaddr*)&addr,sizeof(addr));
对于所有的socket函数而言,sockaddr的唯一用途就是对指向特定协议的套接字结构的指针执行强制类型转换,只想要绑定的socket的协议地址。
bind函数:将套接字地址结构绑定到套接字。
int bind(sockfd,(struct sockaddr*)&addr,sizeof(addr));
绑定了socket之后 ,就可以使用该socket开始监听请求了。
listen函数:
将sockfd未连接的套接字转换成一个被动套接字,指示内核应该接受指向该套接字的连接请求。
int listen(int sockfd,int backlog);
关于backlog参数,内核为任何一个给定的监听套接字维护俩个队列:1、没有完成的队列,2、已经完成的队列
2个队列的和不超过backlog的大小。
listen完成之后,socket就处于llisten状态,此时的socket调用accept函数就可以接收来自客户端的请求了。
accept函数
int accept(int sockfd,struct sockaddr*clientaddr,socklen_t *addrlen);
第一个参数sockfd是客户端的套接字描述,第二个是客户端的套接字地址,第三个是套接字地址结构的长度。
如果accept成功,那么返回值是由内核生成的全新描述符,代表所返回的TCP连接。
accept函数后,一个TCP连接就简历起来了,接着服务器就接受客户端的请求信息,然后做出响应。
recv和send函数:
ssize_t recv(int sockfd,void* buff,size_t nbytes,int flags);
ssize_t send(int sockfd,const void* buff,size_t nbytes,int flags);
分别从用于客户端读取信息和发送信息到客户端。
HTTP响应报文:发送响应客户端时候,发送的报文要遵循HTTP协议,HTTP的响应报文格式如下:
<status-line>
<headers>
<blank line>
[<response-body>]
第一行status-line,状态栏,格式:http版本,状态码,状态码代表文字
headers是返回报文的类型,长度等类型,接着是一个空白,然后是响应报文的实体
#include <stdio.h> #include <ctype.h> #include <sys/types.h> #include <netinet/in.h> #include <unistd.h> #include <stdlib.h> #include <string.h> #include <sys/socket.h> #include <sys/stat.h> #define PORT 9001 #define QUEUE_MAX_COUNT 5 #define BUFF_SIZE 1024 #define SERVER_STRING "Server : hoohackhttp/0.1.0 " int main(){ int server_fd = -1; int client_fd = -1; u_short port = PORT; struct sockaddr_in client_addr; struct sockaddr_in server_addr; socklen_t client_addr_len = sizeof(client_addr); char buf[BUFF_SIZE]; char recv_buf[BUFF_SIZE]; char hello_str[] = "hello world!"; int hello_len = 0; //创建一个socket server_fd = socket(AF_IINET,SOCK_STREAM,0); if(server_fd == -1){ perror("socket"); exit(-1); } memset(&server_addr,0,sizeof(server_addr)); //设置端口,ip和tcpip协议族 server_addr.sin_family = AF_INET; server_addr.sin_port = htons(PORT); server_addr.sin_addr.s_addr = htonl(INADDR_ANY); //绑定套接字到端口 if(bind(server_fd,(struct sockaddr*)&server_addr),sizeof(server_addr)<0){ perror("bind"); exit(-1); } //启动socket监听请求,开始等待客户请求 if(listen(server_fd,QUEUE_MAX_COUNT)<0){ perror("listen"); exit(-1); } printf("http server running on port %d",port); while(1){ //调用accept函数,阻塞了程序,直到接收到客户端的请求 client_fd = accept(server_fd,(struct sockaddr*)&client_addr,&client_addr_len); if(client_fd <0){ perror("accept"); exit(-1); } printf("accept a client "); printf("client socket fd :%d ",client_fd); hello_len = recv(client_fd,recv_buf,BUFF_SIZE,0) printf("receive %d ",hello_len); //发送响应给客户端 sprintf(buf,"http/1.0 200 ok "); send(client_fd,buf,strlen(buf),0); strcpy(buf,SERVER_STRING); send(client_fd,buf,strlen(buf),0); sprintf(buf,"content-type:text/html "); send(client_fd,buf,strlen(buf),0); strcpy(buf," "); send(client_fd,buf,strlen(buf),0); sprintf(buf,"hello world "); send(client_fd,buf,strlen(buf),0); //关闭客户端套接字 close(server_fd); return 0; } }