如何在reactor的基础上实现业务?就是怎么利用reactor做服务器,并实现服务器的业务。
本文基于reactor,实现简单的http协议封装。只是为了说明reactor如何做业务,真正的http服务器业务逻辑是很复杂的。
服务器网络这一层,如nginx、redis,核心是epoll,实现使用的是reactor。
http协议封装与reactor的关系
reactor包含内容
-
reactor_run,event loop,通过epoll进行io检测;
-
accept_cb,处理网络连接;
-
recv_cb 接收客户端http请求
-
send_cb 发送http响应
应用层什么场景使用accept_cb?
-
对特定ip的访问进行限制;
-
负载均衡的功能,就是将请求转发到哪台服务器进行处理。
如果http服务器没有特殊的需求,是不需要修改reactor中的accept_cb的。如何在reactor基础上实现http
http使用的是reqeust-reply的模型进行通讯,客户端发送http请求,服务器处理请求并返回应答。http的传输层是基于TCP的。
http的tcp链接的生命周期:
-
accept_cb
-
recv_cb
-
send_cb
对于服务器,首先需要使用recv_cb接收http数据,通过拆包粘包得到一帧完整的http数据;之后对http数据进行解析处理;最后通过send_cb向客户端发送response。
实现简单的response
先实现一个最简单的response,对于所有http请求,直接回复一个response,内容是一段html。返回给客户端后,浏览器可以直接显示。只在send_cb中调用发送数据就可以了。
int http_response(struct ntyevent *ev) {
if (ev == NULL) return -1;
memset(ev->buffer, 0, BUFFER_LENGTH);
const char *html = "<html><head><title>hello http</title></head><body><H1>Cong</H1></body></html>\r\n\r\n";
ev->length = sprintf(ev->buffer,
"HTTP/1.1 200 OK\r\n\
Date: Sun, 30 Jan 2022 05:55:32 GMT\r\n\
Content-Type: text/html;charset=UTF-8\r\n\
Content-Length: 81\r\n\r\n%s",
html);
return ev->length;
}
int send_cb(int fd, int events, void *arg) {
struct ntyreactor *reactor = (struct ntyreactor*)arg;
struct ntyevent *ev = ntyreactor_idx(reactor, fd);
http_response(ev);
//
int len = send(fd, ev->buffer, ev->length, 0);
if (len > 0) {
printf("send[fd=%d], [%d]%s\n", fd, len, ev->buffer);
nty_event_del(reactor->epfd, ev);
nty_event_set(ev, fd, recv_cb, reactor);
nty_event_add(reactor->epfd, EPOLLIN, ev);
} else {
close(ev->fd);
nty_event_del(reactor->epfd, ev);
printf("send[fd=%d] error %s\n", fd, strerror(errno));
}
return len;
}
HTTP响应由四个部分组成,分别是:状态行、消息报头、空行和响应正文。
http get请求实现
实现http get请求获取静态资源。
客户端发送一个HTTP 请求到服务器的请求消息包括以下格式:请求行( request line )、请求头部( header )、空行和请求数据四个部分组成,下图给出了请求报文的一般格式。
读请求行
需要对http请求进行解析,判断请求类型(GET、POST等),获取资源(uri)
int http_request(struct ntyevent *ev) {
// GET, POST
char linebuf[1024] = {0};
int idx = readline(ev->buffer, 0, linebuf);
if (strstr(linebuf, "GET")) {
ev->method = HTTP_METHOD_GET;
//uri
int i = 0;
while (linebuf[sizeof("GET ") + i] != ' ') i++;
linebuf[sizeof("GET ")+i] = '\0';
sprintf(ev->resource, "./%s/%s", HTTP_WEBSERVER_HTML_ROOT, linebuf+sizeof("GET "));
} else if (strstr(linebuf, "POST")) {
}
}
在读取http请求头的时候,需要注意,http是以\r\n对每一行进行分隔的,第一行就是请求行,里面有请求类型(GET、POST)、uri、协议版本等。
自定义协议,如何界定包的完整性:
-
使用分隔符,比如http使用\r\n;
- <