对于HTTP的简单理解

http服务器简介

HTTP 协议是 Hyper Text Transfer Protocol（超文本传输协议）的缩写,是用于从万维网(WWW:World Wide Web)服务器传输超文本到本地浏览器的传送协议。HTTP 是一个基于TCP/IP 通信协议来传递数据（HTML 文件, 图片文件, 查询结果等）

http工作原理

http协议工作于客户端-服务端架构上，浏览器作为http客户端通过URL向http服务器即web服务器发送所有请求，web服务器根据接收到的请求向客户端发送响应信息，http端口默认为80端口

注意事项

http是无连接的，就是一次只能处理一个请求处理完请求后给客户发送应答，断开连接
http是媒体独立的，客户端和服务端只知道如何处理数据内容，任何类型的数据都可以通过http发送，客户端和服务器指定使用合适的MIME-type内容类型
http是无状态的，对于事务处理没有记忆，缺少状态信息保存

http消息结构

HTTP 是基于客户端/服务端（C/S）的架构模型，通过一个可靠的链接来交换信息，是一个无

状态的请求/响应协议
一个 HTTP"客户端"是一个应用程序（Web 浏览器或其他任何客户端），通过连接到服务器达

到向服务器发送一个或多个 HTTP 的请求的目的
一个 HTTP"服务器"同样也是一个应用程序（通常是一个 Web 服务，如 Apache Web 服务器

或 IIS 服务器等），通过接收客户端的请求并向客户端发送 HTTP 响应数据
HTTP 使用统一资源标识符（Uniform Resource Identifiers, URI）来传输数据和建立连接

客户端请求消息

客户端发送一个http请求到服务器的请求消息包括以下格式：请求行、请求头部、空行和请求数据四个部分

客户端请求示例

GET /hello.txt HTTP/1.1
User-Agent: curl/7.16.3 libcurl/7.16.3 OpenSSL/0.9.7l zlib/1.2.3
Host: www.example.com
Accept-Language: en, mi

服务器响应信息

http响应也由四个部分组成，分别是：状态行、消息报头、空行和响应正文

GET请求服务端响应示例：

HTTP/1.1 200 OK
Date: Mon, 27 Jul 2009 12:28:53 GMT
Server: Apache
Last-Modified: Wed, 22 Jul 2009 19:15:56 GMT
ETag: "34aa387-d-1568eb00"
Accept-Ranges: bytes
Content-Length: 51
Vary: Accept-Encoding
Content-Type: text/plain

输出结果：

Hello World! My payload includes a trailing CRLF.

HTTP的请求方法

根据HTTP标准，http可以有多种请求方法

HTTP1.0 定义了三种请求方法： GET, POST 和 HEAD 方法

HTTP1.1 新增了六种请求方法：OPTIONS、PUT、PATCH、DELETE、TRACE 和 CONNECT 方法

序号	方法	描述
1	GET	请求指定的页面信息，并返回实体主体
2	HEAD	类似于 GET 请求，只不过返回的响应中没有具体的内容，用于获取报头
3	POST	向指定资源提交数据进行处理请求（例如提交表单或者上传文件）。数据被包含在请求体中。POST 请求可能会导致新的资源的建立和/或已有资源的修改
4	PUT	从客户端向服务器传送的数据取代指定的文档的内容
5	DELETE	请求服务器删除指定的页面
6	CONNECT	HTTP/1.1 协议中预留给能够将连接改为管道方式的代理服务器
7	OPTIONS	允许客户端查看服务器的性能
8	TRACK	回显服务器收到的请求，主要用于测试或诊断
9	PATCH	是对 PUT 方法的补充，用来对已知资源进行局部更新

HTTP响应头信息

HTTP 请求头提供了关于请求，响应或者其他的发送实体的信息

应答头	说明
Allow	服务器支持哪些请求方法（如 GET、POST 等）
Content-Encoding	文档的编码（Encode）方法。只有在解码之后才可以得到 Content-Type 头指定的内容类型。利用 gzip 压缩文档能够显著地减少 HTML 文档的下载时间。Java 的 GZIPOutputStream 可以很方便地进行 gzip 压缩，但只有 Unix 上的 Netscape 和 Windows 上的 IE 4、IE 5 才支持它。因此，Servlet 应该通过查看Accept-Encoding 头（即 request.getHeader(“Accept-Encoding”)）检查浏览器是否支持 gzip，为支持 gzip 的浏览器返回经 gzip 压缩的 HTML 页面，为其他浏览器返回普通页面。
Content-Length	表示内容长度。只有当浏览器使用持久 HTTP 连接时才需要这个数据。如果你想要利用持久连接的优势，可以把输出文档写入 ByteArrayOutputStream，完成后查看其大小，然后把该值放入 Content-Length 头，最后通过 byteArrayStream.writeTo(response.getOutputStream()发送内容。
Content-Type	表示后面的文档属于什么 MIME 类型。Servlet 默认为 text/plain，但通常需要显式地指定为 text/html。由于经常要设置 Content-Type，因此 HttpServletResponse 提供了一个专用的方法 setContentType。
Date	当前的 GMT 时间。你可以用 setDateHeader 来设置这个头以避免转换时间格式的麻烦
Expires	应该在什么时候认为文档已经过期，从而不再缓存它？
Last-Modified	文档的最后改动时间。客户可以通过 If-Modified-Since 请求头提供一个日期，该请求将被视为一个条件 GET，只有改动时间迟于指定时间的文档才会返回，否则返回一个 304（Not Modified）状态。Last-Modified 也可用 setDateHeader 方法来设置

HTTP状态码

当浏览者访问一个网页时，浏览者的浏览器会向网页所在服务器发出请求。当浏览器接收并显示网页前，此网页所在的服务器会返回一个包含 HTTP 状态码的信息头（server header）用以响应浏览器的请求。HTTP 状态码的英文为 HTTP Status Code

五种类型状态码

分类	分类描述
1**	新消息，服务器收到请求，需要请求者继续执行操作
2**	成功，操作被成功接收并处理
3**	重定向，需要进一步的操作以完成请求
4**	客户端错误，请求包含语法错误或无法完成请求
5**	服务器错误，服务器在执行请求过程中发生错误

状态码列表

状态码	状态码英文名称	中文描述
100	Continue	继续，客户端应继续其请求
101	Switching Protocols	切换协议，服务器根据客户端的请求切换协议，只能切换到更高级的协议，例如切换到http的新版本协议
200	OK	请求成功，一般用于GET与POST请求
201	Created	已创建，成功请求并创建了新的资源
202	Accepted	已接受请求，但未处理
203	Non-Authoritative Information	非授权信息，请求成功，但返回的meta信息不是在原始的服务器而是一个副本
204	No Content	无内容，服务器处理成功，但没有返回内容，在未更新网页的情况下，可以确浏览器继续浏览当前文档
205	Reset Content	重置内容，服务器处理成功，客户端要重置文档视图
206	Partial Content	部分内容，服务器处理了部分GET请求
300	Multiple Choices	多种选择，请求的资源可以包括多个位置，相应可返回一个资源特征与地址的列表用于用户终端选择
301	Moved Permanently	永久移动。请求的资源已被永久的移动到新 URI，返回信息会包括新的 URI，浏览器会自动定向到新 URI。今后任何新的请求都应使用新的 URI 代替
302	Found	临时移动。与 301 类似。但资源只是临时被移动。客户端应继续使用原有 URI
303	See Other	查看其它地址。与 301 类似。使用 GET 和 POST 请求查看
304	Not Modified	未修改。所请求的资源未修改，服务器返回此状态码时，不会返回任何资源。客户端通常会缓存访问过的资源，通过提供一个头信息指出客户端希望只返回在指定日期之后修改的资源
305	Use Proxy	使用代理。所请求的资源必须通过代理访问
400	Bad Request	客户端请求的语法错误，服务器无法理解
401	未经授权	请求要求用户的身份认证
402	Payment Required	保留，将来使用
403	Forbidden	禁止访问
404	Not Found	请求内容不存在
500	Internal Server Error	服务器内部错误，无法完成请求
501	Not Implemented	服务器不支持请求的功能，无法完成请求
502	Bad Gateway	作为网关或者代理工作的服务器尝试执行请求时，从远程服务器接收到了一个无效的响应
503	Service Unavailable	由于超载或系统维护，服务器暂时的无法处理客户端的请求。延时的长度可包含在服务器的 Retry-After 头信息中
504	Gateway Time-out	充当网关或代理的服务器，未及时从远端服务器获取请求
505	HTTP Version not supported	服务器不支持请求的 HTTP 协议的版本，无法完成处理

HTTP的实现

本设计使用Reactor模型实现一个http服务器，Reactor模型不再过多赘述，可以看我另外一篇专门讲Reactor的博客，本文主要讲建立TCP连接，接受客户端请求和发送HTTP响应，这也是一个http连接的生命周期

建立TCP连接

这一步的应用场景一般是对连接进行检验，比如

ip限制检查
负载均衡

int accept_cb(int fd, int events, void *arg) {struct ntyreactor *reactor = (struct ntyreactor*)arg;if (reactor == NULL) return -1;struct sockaddr_in client_addr;socklen_t len = sizeof(client_addr);int clientfd;if ((clientfd = accept(fd, (struct sockaddr*)&client_addr, &len)) == -1) {if (errno != EAGAIN && errno != EINTR) {}printf("accept: %s\n", strerror(errno));return -1;}int flag = 0;if ((flag = fcntl(clientfd, F_SETFL, O_NONBLOCK)) < 0) {printf("%s: fcntl nonblocking failed, %d\n", __func__, MAX_EPOLL_EVENTS);return -1;}struct ntyevent *event = ntyreactor_idx(reactor, clientfd);nty_event_set(event, clientfd, recv_cb, reactor);nty_event_add(reactor->epfd, EPOLLIN, event);printf("new connect [%s:%d], pos[%d]\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), clientfd);return 0;}

接受http请求

int recv_cb(int fd, int events, void *arg) {struct ntyreactor *reactor = (struct ntyreactor*)arg;struct ntyevent *ev = ntyreactor_idx(reactor, fd);int len = recv(fd, ev->buffer, BUFFER_LENGTH , 0); //接受一个http请求nty_event_del(reactor->epfd, ev);if (len > 0) {ev->length = len;ev->buffer[len] = '\0';printf("C[%d]:%s\n", fd, ev->buffer);nty_event_set(ev, fd, send_cb, reactor);nty_event_add(reactor->epfd, EPOLLOUT, ev);} else if (len == 0) {close(ev->fd);//printf("[fd=%d] pos[%ld], closed\n", fd, ev-reactor->events);} else {close(ev->fd);printf("recv[fd=%d] error[%d]:%s\n", fd, errno, strerror(errno));}return len;
}

http协议解析

处理客户端发来的请求报文前要先弄清楚是什么请求报文，下面以GET和POST请求为例

int http_request(struct ntyevent *ev) {// GET, POSTchar linebuf[1024] = {0};int idx = readline(ev->buffer, 0, linebuf);if (strstr(linebuf, "GET")) {ev->method = HTTP_METHOD_GET;//uriint 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是一个超文本传输协议，这个函数是对文本进行处理

int http_response(struct ntyevent *ev) {if (ev == NULL) return -1;memset(ev->buffer, 0, BUFFER_LENGTH);
#if 0const char *html = "<html><head><title>hello http</title></head><body><H1>King</H1></body></html>\r\n\r\n";                        ev->length = sprintf(ev->buffer, "HTTP/1.1 200 OK\r\n\Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n\Content-Type: text/html;charset=ISO-8859-1\r\n\Content-Length: 83\r\n\r\n%s", html);#elseprintf("resource: %s\n", ev->resource);int filefd = open(ev->resource, O_RDONLY);if (filefd == -1) { // return 404ev->ret_code = 404;ev->length = sprintf(ev->buffer, "HTTP/1.1 404 Not Found\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: 85\r\n\r\n""<html><head><title>404 Not Found</title></head><body><H1>404</H1></body></html>\r\n\r\n" );} else {struct stat stat_buf;fstat(filefd, &stat_buf);close(filefd);if (S_ISDIR(stat_buf.st_mode)) {        ev->ret_code = 404;ev->length = sprintf(ev->buffer, "HTTP/1.1 404 Not Found\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: 85\r\n\r\n""<html><head><title>404 Not Found</title></head><body><H1>404</H1></body></html>\r\n\r\n" );} else if (S_ISREG(stat_buf.st_mode)) {ev->ret_code = 200;ev->length = sprintf(ev->buffer, "HTTP/1.1 200 OK\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: %ld\r\n\r\n", stat_buf.st_size );}}
#endifreturn ev->length;
}

发送HTTP响应

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);if (ev->ret_code == 200) {int filefd = open(ev->resource, O_RDONLY);struct stat stat_buf;fstat(filefd, &stat_buf);sendfile(fd, filefd, NULL, stat_buf.st_size);close(filefd);}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;
}

全部代码附录

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/epoll.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <time.h>
#include <sys/stat.h>
#include <sys/sendfile.h>#define BUFFER_LENGTH        4096
#define MAX_EPOLL_EVENTS    1024
#define SERVER_PORT         8888
#define PORT_COUNT          1#define HTTP_WEBSERVER_HTML_ROOT   "html"#define HTTP_METHOD_GET     0
#define HTTP_METHOD_POST    1typedef int NCALLBACK(int ,int, void*);struct ntyevent {int fd;int events;void *arg;int (*callback)(int fd, int events, void *arg);int status;char buffer[BUFFER_LENGTH];int length;long last_active;// http paramint method; //char resource[BUFFER_LENGTH];int ret_code;};struct eventblock {struct eventblock *next;struct ntyevent *events;};struct ntyreactor {int epfd;int blkcnt;struct eventblock *evblk; //fd --> 100w
};int recv_cb(int fd, int events, void *arg);
int send_cb(int fd, int events, void *arg);
struct ntyevent *ntyreactor_idx(struct ntyreactor *reactor, int sockfd);void nty_event_set(struct ntyevent *ev, int fd, NCALLBACK callback, void *arg) {ev->fd = fd;ev->callback = callback;ev->events = 0;ev->arg = arg;ev->last_active = time(NULL);return ;}int nty_event_add(int epfd, int events, struct ntyevent *ev) {struct epoll_event ep_ev = {0, {0}};ep_ev.data.ptr = ev;ep_ev.events = ev->events = events;int op;if (ev->status == 1) {op = EPOLL_CTL_MOD;} else {op = EPOLL_CTL_ADD;ev->status = 1;}if (epoll_ctl(epfd, op, ev->fd, &ep_ev) < 0) {printf("event add failed [fd=%d], events[%d]\n", ev->fd, events);return -1;}return 0;
}int nty_event_del(int epfd, struct ntyevent *ev) {struct epoll_event ep_ev = {0, {0}};if (ev->status != 1) {return -1;}ep_ev.data.ptr = ev;ev->status = 0;epoll_ctl(epfd, EPOLL_CTL_DEL, ev->fd, &ep_ev);return 0;
}int readline(char *allbuf, int idx, char *linebuf) {int len = strlen(allbuf);for(;idx < len;idx ++) {if (allbuf[idx] == '\r' && allbuf[idx+1] == '\n') {return idx+2;} else {*(linebuf++) = allbuf[idx];}}return -1;
}int http_request(struct ntyevent *ev) {// GET, POSTchar linebuf[1024] = {0};int idx = readline(ev->buffer, 0, linebuf);if (strstr(linebuf, "GET")) {ev->method = HTTP_METHOD_GET;//uriint 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")) {}}int recv_cb(int fd, int events, void *arg) {struct ntyreactor *reactor = (struct ntyreactor*)arg;struct ntyevent *ev = ntyreactor_idx(reactor, fd);int len = recv(fd, ev->buffer, BUFFER_LENGTH, 0); // if (len > 0) {ev->length = len;ev->buffer[len] = '\0';printf("C[%d]:%s\n", fd, ev->buffer); //httphttp_request(ev);//send();nty_event_del(reactor->epfd, ev);nty_event_set(ev, fd, send_cb, reactor);nty_event_add(reactor->epfd, EPOLLOUT, ev);} else if (len == 0) {nty_event_del(reactor->epfd, ev);close(ev->fd);//printf("[fd=%d] pos[%ld], closed\n", fd, ev-reactor->events);} else {nty_event_del(reactor->epfd, ev);close(ev->fd);printf("recv[fd=%d] error[%d]:%s\n", fd, errno, strerror(errno));}return len;
}int http_response(struct ntyevent *ev) {if (ev == NULL) return -1;memset(ev->buffer, 0, BUFFER_LENGTH);
#if 0const char *html = "<html><head><title>hello http</title></head><body><H1>King</H1></body></html>\r\n\r\n";ev->length = sprintf(ev->buffer, "HTTP/1.1 200 OK\r\n\Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n\Content-Type: text/html;charset=ISO-8859-1\r\n\Content-Length: 83\r\n\r\n%s", html);#elseprintf("resource: %s\n", ev->resource);int filefd = open(ev->resource, O_RDONLY);if (filefd == -1) { // return 404ev->ret_code = 404;ev->length = sprintf(ev->buffer, "HTTP/1.1 404 Not Found\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: 85\r\n\r\n""<html><head><title>404 Not Found</title></head><body><H1>404</H1></body></html>\r\n\r\n" );} else {struct stat stat_buf;fstat(filefd, &stat_buf);close(filefd);if (S_ISDIR(stat_buf.st_mode)) {ev->ret_code = 404;ev->length = sprintf(ev->buffer, "HTTP/1.1 404 Not Found\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: 85\r\n\r\n""<html><head><title>404 Not Found</title></head><body><H1>404</H1></body></html>\r\n\r\n" );} else if (S_ISREG(stat_buf.st_mode)) {ev->ret_code = 200;ev->length = sprintf(ev->buffer, "HTTP/1.1 200 OK\r\n""Date: Thu, 11 Nov 2021 12:28:52 GMT\r\n""Content-Type: text/html;charset=ISO-8859-1\r\n""Content-Length: %ld\r\n\r\n", stat_buf.st_size );}}#endifreturn 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);if (ev->ret_code == 200) {int filefd = open(ev->resource, O_RDONLY);struct stat stat_buf;fstat(filefd, &stat_buf);sendfile(fd, filefd, NULL, stat_buf.st_size);close(filefd);}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;
}int accept_cb(int fd, int events, void *arg) {struct ntyreactor *reactor = (struct ntyreactor*)arg;if (reactor == NULL) return -1;struct sockaddr_in client_addr;socklen_t len = sizeof(client_addr);int clientfd;if ((clientfd = accept(fd, (struct sockaddr*)&client_addr, &len)) == -1) {if (errno != EAGAIN && errno != EINTR) {}printf("accept: %s\n", strerror(errno));return -1;}int flag = 0;if ((flag = fcntl(clientfd, F_SETFL, O_NONBLOCK)) < 0) {printf("%s: fcntl nonblocking failed, %d\n", __func__, MAX_EPOLL_EVENTS);return -1;}struct ntyevent *event = ntyreactor_idx(reactor, clientfd);nty_event_set(event, clientfd, recv_cb, reactor);nty_event_add(reactor->epfd, EPOLLIN, event);printf("new connect [%s:%d], pos[%d]\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), clientfd);return 0;}int init_sock(short port) {int fd = socket(AF_INET, SOCK_STREAM, 0);fcntl(fd, F_SETFL, O_NONBLOCK);struct sockaddr_in server_addr;memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htonl(INADDR_ANY);server_addr.sin_port = htons(port);bind(fd, (struct sockaddr*)&server_addr, sizeof(server_addr));if (listen(fd, 20) < 0) {printf("listen failed : %s\n", strerror(errno));}return fd;
}int ntyreactor_alloc(struct ntyreactor *reactor) {if (reactor == NULL) return -1;if (reactor->evblk == NULL) return -1;struct eventblock *blk = reactor->evblk;while (blk->next != NULL) {blk = blk->next;}struct ntyevent *evs = (struct ntyevent*)malloc((MAX_EPOLL_EVENTS) * sizeof(struct ntyevent));if (evs == NULL) {printf("ntyreactor_alloc ntyevents failed\n");return -2;}memset(evs, 0, (MAX_EPOLL_EVENTS) * sizeof(struct ntyevent));struct eventblock *block = (struct eventblock *)malloc(sizeof(struct eventblock));if (block == NULL) {printf("ntyreactor_alloc eventblock failed\n");return -2;}memset(block, 0, sizeof(struct eventblock));block->events = evs;block->next = NULL;blk->next = block;reactor->blkcnt ++; //return 0;
}struct ntyevent *ntyreactor_idx(struct ntyreactor *reactor, int sockfd) {int blkidx = sockfd / MAX_EPOLL_EVENTS;while (blkidx >= reactor->blkcnt) {ntyreactor_alloc(reactor);}int i = 0;struct eventblock *blk = reactor->evblk;while(i ++ < blkidx && blk != NULL) {blk = blk->next;}return &blk->events[sockfd % MAX_EPOLL_EVENTS];
}int ntyreactor_init(struct ntyreactor *reactor) {if (reactor == NULL) return -1;memset(reactor, 0, sizeof(struct ntyreactor));reactor->epfd = epoll_create(1);if (reactor->epfd <= 0) {printf("create epfd in %s err %s\n", __func__, strerror(errno));return -2;}struct ntyevent *evs = (struct ntyevent*)malloc((MAX_EPOLL_EVENTS) * sizeof(struct ntyevent));if (evs == NULL) {printf("ntyreactor_alloc ntyevents failed\n");return -2;}memset(evs, 0, (MAX_EPOLL_EVENTS) * sizeof(struct ntyevent));struct eventblock *block = (struct eventblock *)malloc(sizeof(struct eventblock));if (block == NULL) {printf("ntyreactor_alloc eventblock failed\n");return -2;}memset(block, 0, sizeof(struct eventblock));block->events = evs;block->next = NULL;reactor->evblk = block;reactor->blkcnt = 1;return 0;
}int ntyreactor_destory(struct ntyreactor *reactor) {close(reactor->epfd);//free(reactor->events);struct eventblock *blk = reactor->evblk;struct eventblock *blk_next = NULL;while (blk != NULL) {blk_next = blk->next;free(blk->events);free(blk);blk = blk_next;}return 0;
}int ntyreactor_addlistener(struct ntyreactor *reactor, int sockfd, NCALLBACK *acceptor) {if (reactor == NULL) return -1;if (reactor->evblk == NULL) return -1;//reactor->evblk->events[sockfd];struct ntyevent *event = ntyreactor_idx(reactor, sockfd);nty_event_set(event, sockfd, acceptor, reactor);nty_event_add(reactor->epfd, EPOLLIN, event);return 0;
}int ntyreactor_run(struct ntyreactor *reactor) {if (reactor == NULL) return -1;if (reactor->epfd < 0) return -1;if (reactor->evblk == NULL) return -1;struct epoll_event events[MAX_EPOLL_EVENTS+1];int checkpos = 0, i;while (1) {/*long now = time(NULL);for (i = 0;i < 100;i ++, checkpos ++) {if (checkpos == MAX_EPOLL_EVENTS) {checkpos = 0;}if (reactor->events[checkpos].status != 1) {continue;}long duration = now - reactor->events[checkpos].last_active;if (duration >= 60) {close(reactor->events[checkpos].fd);printf("[fd=%d] timeout\n", reactor->events[checkpos].fd);nty_event_del(reactor->epfd, &reactor->events[checkpos]);}}
*/int nready = epoll_wait(reactor->epfd, events, MAX_EPOLL_EVENTS, 1000);if (nready < 0) {printf("epoll_wait error, exit\n");continue;}for (i = 0;i < nready;i ++) {struct ntyevent *ev = (struct ntyevent*)events[i].data.ptr;if ((events[i].events & EPOLLIN) && (ev->events & EPOLLIN)) {ev->callback(ev->fd, events[i].events, ev->arg);}if ((events[i].events & EPOLLOUT) && (ev->events & EPOLLOUT)) {ev->callback(ev->fd, events[i].events, ev->arg);}       }}
}// 3, 6w, 1, 100 ==
// <remoteip, remoteport, localip, localport>
int main(int argc, char *argv[]) {unsigned short port = SERVER_PORT; // listen 8888if (argc == 2) {port = atoi(argv[1]);}struct ntyreactor *reactor = (struct ntyreactor*)malloc(sizeof(struct ntyreactor));ntyreactor_init(reactor);int i = 0;int sockfds[PORT_COUNT] = {0};for (i = 0;i < PORT_COUNT;i ++) {sockfds[i] = init_sock(port+i);ntyreactor_addlistener(reactor, sockfds[i], accept_cb);}//dup2(sockfd, STDIN);ntyreactor_run(reactor);ntyreactor_destory(reactor);for (i = 0;i < PORT_COUNT;i ++) {close(sockfds[i]);}free(reactor);return 0;
}

学习课程来源

http服务器的实现相关推荐

总结一下在使用某里云服务器的过程中出现过的一些问题
此文总结在使用阿里云的过程中出现过的问题想起来就记录一下本人为言行负责! 海内选择腾讯华为,共勉! k8s不同命名空间的配置文件串掉了 k8s集群服务器购买上后,无法使用外网.连续购买了4台然 ...
阿里云如何将服务器添加至跳板机，如何将服务器添加至jumpsever
如何将服务器添加至跳板机. 获取跳板机/root/.ssh/id_rsa.pub 中的内容登陆要添加到跳板机的目标机器 /root/.ssh/authorized_keys 将跳板机id_rsa.p ...
Alibaba Cloud Linux 2.1903 LTS 64位服务器yum源下载404,Alibaba Cloud Linux 2实例中使用docker-ce、epel等YUM源安装软件失败
[Alibaba Cloud Linux 2.1903 LTS 64位]服务器yum源下载404 failure: repodata/repomd.xml from docker-ce-stable: ...
将文件上传至ftp服务器，FTP文件上传工具类，将文件上传至服务器指定目录
将文件上传至ftp服务器,传入File对象,将文件上传至ftp服务器需要配置修改的点: 1. 服务器ip端口(服务器ip 端口22/21). 2. 服务器账号密码(服务器登录用户名密码). 3. 上 ...
jar包升级部署到服务器详细流程，将服务部署在linux中
假设你已经准备好以下东西,即可进行服务部署一台服务器(云服务器或虚拟机皆可) 已安装好的jdk 1.8 + 的环境(可自行百度) 打好的jar包(maven打jar包) 1. 在服务器中新建好你的项 ...
jar包部署shell脚本编写，在服务器上部署jar包，在Linux服务器上部署服务，设置编码格式，设置内存管理
准备步骤: 1.安装java环境,知道java安装目录 2.将jar包拖放或发送至服务器中(目录自定义) 一.编写shell脚本,将以下代码放在shell脚本中,将shell脚本放在jar包同级目录下 ...
linux/docker个人服务器项目中文变问号？？，时间差8小时问题解决方法，最新，最有效
前段时间在腾讯云上面买了一台个人服务器,在搭建好web项目的时候,在项目中录入中文,全部变成了问号,时间也错了,百思不得其解,后来我尝试着修改docker编码,修改系统语言,都无法改变.后来我把项目从 ...
设置腾讯云linux服务器中 MySQL 允许远程访问
申请了一台linux腾讯云服务器,想要把数据库搭建在上面,本地的Windows直接可以访问以下就是具体的操作流程,首先你需要安装好一个mysql,安装方法–>mysql安装(Linux) 接着 ...
使用Docker搭建svn服务器教程
使用Docker搭建svn服务器教程 svn简介 SVN是Subversion的简称,是一个开放源代码的版本控制系统,相较于RCS.CVS,它采用了分支管理系统,它的设计目标就是取代CVS.互联网上很 ...
Redis 笔记（16）— info 指令和命令行工具（查看内存、状态、客户端连接数、监控服务器、扫描大key、采样服务器、执行批量命令等）
Info 命令返回关于 Redis 服务器的各种信息和统计数值.通过给定可选的参数 section ,可以让命令只返回某一部分的信息. 1. 显示模块 server : 一般 Redis 服务器信息, ...

http服务器的实现