Cocos2dx的http请求流程，lua版

Posted 2023-04-19

参考技术A 1.因为http连接是短链接，所以每次访问都会进行一次连接。http调用流程：

lua封装的Http类在Http:request(）方法中：

Ⅰ、调用c++类类XMLHttpRequest request=cc.XMLHttpRequest:new（）创建一个XMLHttpRequest对象，该对象调用类request:open（httpType,Url）方法设置访问类型和全局定位符；

Ⅱ、调用c++类XMLHttpRequest注册的lua变量timeout【tolua_variable(L, "timeout", lua_get_XMLHttpRequest_timeout,lua_set_XMLHttpRequest_timeout);】，request.timeout=X 设置连接超时时间X；

Ⅲ、调用c++类XMLHttpRequest request:registerScriptHandler(handler(request,self.onRequestFinished)） 设置接受消息后的回调函数，在onRequestFinished在lua中使用request.response获取c++得到的response数据，【因为c++注册了该lua变量 tolua_variable(L, "response", lua_get_XMLHttpRequest_response, nullptr)，所以可以直接使用】；

Ⅳ、调用request:send(rDataStr)方法进行访问，对应c++方法【tolua_function(L, "send", lua_cocos2dx_XMLHttpRequest_send);】；

2.在lua_cocos2dx_XMLHttpRequest_send（）方法中 对XMLHttpRequest对象的RequestData进行了设置，同时调用了XMLHttpRequest::_sendRequest()函数。

3.XMLHttpRequest::_sendRequest()函数中设置了HttpRequest对象的接受数据后的回调函数，该回调函数设置了responseData【responseData可在lua回调函数中直接获得，因为c++注册了tolua_variable(L, "response", lua_get_XMLHttpRequest_response, nullptr);】,然后调用lua注册在c++中的lua函数request:registerScriptHandler(handler(request,self.onRequestFinished)）。然后执行了network::HttpClient::getInstance()->setTimeoutForConnect(_timeout);network::HttpClient::getInstance()->setTimeoutForRead(_timeout);最后执行network::HttpClient::getInstance()->send(_httpRequest);

4.在HttpClient::send(HttpRequest* request）函数中会执行两个重要操作。一.在HttpClient::lazyInitThreadSemphore()中创建请求对象列表和相应对象列表，并且开启一个新线程执行HttpClient::networkThread（）函数。二是将参数request对象加入到s_requestQueue请求列表中，同时唤醒networkThread（）所在线程，执行networkThread()函数。

5.networkThread()函数承担了socket请求的主要工作：一.执行一个while循环【若s_requestQueue请求列表为空则阻塞线程进入等待状态，等待被唤醒。若不为空则取出请求队列中的第一个请求，并且创建一个响应对象HttpResponse并且加入到响应队列中。然后执行processResponse（）函数，processResponse函数执行完后相应的HttpResponse对象中的ResponseData等数据会被设置，然后在cocos线程中执行HttpClient::dispatchResponseCallbacks（）函数，HttpClient::dispatchResponseCallbacks（）函数中会从响应队列中获取第一个响应对象，然后获取响应对象对应的请求对象，执行请求对象HttpRequest对应的回调函数，该函数在_sendRequest()中设置。然后继续执行下一个循环，直到HttpClient对象被销毁则跳出循环。跳出循环后移除请求队列中的元素，清空请求队列内存】。整个大致的请求流程完毕。

6.重点剖析一下processResponse（）函数中的processTask()函数：在该函数中首先获取请求类型（get,put,post,delete）,然后执行processTask()函数。执行完processTask()函数后，会设置该请求的响应数据和响应code，同时设置response是否成功。processTask(requestType, &getResponseData,&responseCode,&ResponseHeader,errorBuffer)执行了主要的请求工作：在xoce工程中该函数中用到了OC的Foundation框架下http请求相关的接口。NSURLConnection类用于连接服务器执行scheduleInRunLoop：forMode：函数和start函数，NSMutableURLRequest对象用于保存URL、请求数据、连接超时时间等参数。在请求成功时循环执行[[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];直到请求成功后，从HttpAsynConnection对象的responseData成员对象中获取数据并写入到&getResponseData中，从而获取响应数据到&getResponseData引用中。【HttpAsynConnection类定义：@interface HttpAsynConnection : NSObject <NSURLConnectionDelegate, NSURLConnectionDataDelegate> 。HttpAsynConnection继承了<NSURLConnectionDelegate, NSURLConnectionDataDelegate>这两个接口，然后重写这些接口中的获取数据，连接成功的等回调函数】。

nginx 11个处理阶段 && nginx lua 8个处理阶段

1. nginx 11 个处理阶段

nginx实际把请求处理流程划分为了11个阶段，这样划分的原因是将请求的执行逻辑细分，各阶段按照处理时机定义了清晰的执行语义，开发者可以很容易分辨自己需要开发的模块应该定义在什么阶段，其定义在http/ngx_http_core_module.h中有定义：

NGX_HTTP_POST_READ_PHASE:
接收完请求头之后的第一个阶段，它位于uri重写之前，实际上很少有模块会注册在该阶段，默认的情况下，该阶段被跳过

NGX_HTTP_SERVER_REWRITE_PHASE:
server级别的uri重写阶段，也就是该阶段执行处于server块内，location块外的重写指令，在读取请求头的过程中nginx会根据host及端口找到对应的虚拟主机配置

NGX_HTTP_FIND_CONFIG_PHASE:
寻找location配置阶段，该阶段使用重写之后的uri来查找对应的location，值得注意的是该阶段可能会被执行多次，因为也可能有location级别的重写指令

NGX_HTTP_REWRITE_PHASE:
location级别的uri重写阶段，该阶段执行location基本的重写指令，也可能会被执行多次

NGX_HTTP_POST_REWRITE_PHASE:
location级别重写的后一阶段，用来检查上阶段是否有uri重写，并根据结果跳转到合适的阶段

NGX_HTTP_PREACCESS_PHASE:
访问权限控制的前一阶段，该阶段在权限控制阶段之前，一般也用于访问控制，比如限制访问频率，链接数等

NGX_HTTP_ACCESS_PHASE:
访问权限控制阶段，比如基于ip黑白名单的权限控制，基于用户名密码的权限控制等

NGX_HTTP_POST_ACCESS_PHASE:
问权限控制的后一阶段，该阶段根据权限控制阶段的执行结果进行相应处理

NGX_HTTP_TRY_FILES_PHASE:
try_files指令的处理阶段，如果没有配置try_files指令，则该阶段被跳过

NGX_HTTP_CONTENT_PHASE:
内容生成阶段，该阶段产生响应，并发送到客户端

NGX_HTTP_LOG_PHASE:
日志记录阶段，该阶段记录访问日志

2. nginx lua 8个处理阶段

init_by_lua http
set_by_lua server, server if, location, location if
rewrite_by_lua http, server, location, location if
access_by_lua http, server, location, location if
content_by_lua location, location if
header_filter_by_lua http, server, location, location if
body_filter_by_lua http, server, location, location if
log_by_lua http, server, location, location if
{
set_by_lua: 流程分支处理判断变量初始化
rewrite_by_lua: 转发、重定向、缓存等功能(例如特定请求代理到外网)
access_by_lua: IP准入、接口权限等情况集中处理(例如配合iptable完成简单防火墙)
content_by_lua: 内容生成
header_filter_by_lua: 应答HTTP过滤处理(例如添加头部信息)
body_filter_by_lua: 应答BODY过滤处理(例如完成应答内容统一成大写)
log_by_lua: 会话完成后本地异步完成日志记录(日志可以记录在本地，还可以同步到其他机器)
}