王健伟老师_Linux C++网络编程_工程思维导图.pdf

激发线程来处理

Nginx（仿）

main排布

(0)先初始化的变量

(1)无伤大雅也不需要释放的放最上边

(2)单例类初始化

配置文件单例类

内存单例类

crc32 校验算法单例类

ngx_master_pr ocess_cycle()

ngx_worker_ process_cycle()子进程功能函数

创建epoll 对象，ep oll_create()

创建连 接池，initconnection();

分配内存 (lpn gx_c onne ction_t)p_memory->AllocMemory(ilenconnpool,true);

所有链 接【不 管是否空 闲】都放在这个 list ，m_connectionList.push_back(p_Conn);

空闲连 接会放 在这个lis t，m_freeconnectionList.push_back(p_Conn);

遍历所 有监听sock et【监听端口】

从连接 池中获 取一个空 闲连接 对象（监 听套接字连接）ngx_get_connection()

增加监 听事件CSocekt::ngx_epo ll_oper_event(）

系统函 数epoll_ctl()

newc->rhandler = &CSocekt::ngx_read_re quest_handler; 设置数 据来时 的读处理函数 ngx_read_request_handler()

newc->whandler = &CSocekt::ngx_write_request_handler ; 设 置数据来 时的写 处理函数ngx_write_request_handler()

设置标 题作用 ：在查看系统进程是可以看到独有的进程名，好区分

(this->* (p_Conn->rhandler) )(p_Conn);

在fork 之后子进 程中返回 的是0 ，并执行ngx_worker_process_cycle();

CThreadPool:: ThreadFunc()线程入口函数

线程入口参数的理解

线程进入死循环

没有拿到消息队列中的数据 或者 m_shutdown == false ，在下面的地方等待

保证每 个线程 都启动并运行到 pt hrea d_cond_wait()，OK 是，主线程返回

后续逻辑再说

接收数 据专用函数 recvproc(）

系统调 用函数recv(）

包头收 完整后 的处理ngx_wait_request_handler_proc_p1(）

包体接 收处理函数 ngx_wait_request_handler_proc_plast()

没有全 部发送 完毕(EAG AIN)，数据只发出去了一部分，但肯定是因为 发送缓冲区满了

将依靠ep oll驱动 调用ng x_wr ite_re quest_handler()函数发送数据

CSocekt::ngx_epoll_oper_event()

发送缓冲区已经满了【一个字节都没发出去】

也是把 发送的 消息放在epoll 中

要发送 的东西 也要从发 送队列里干掉 pSocketObj->m_MsgSendQueue.erase (pos2);

Se rver Re cyConnectionThread()处理连接回收的线程

主动关闭一个连接时的要做些善后的处理函数 ，CSocekt::zdCloses ocketProc()

什么时候去调用这个函数

心跳包 检测时 间到了CLog icSocket::procPingTimeOutChecking()

检测到 Flood攻击 ，ngx_read_request_handler()

当有需 要释放的连接时，就不停的一个一个的释放掉

释放流程，及重要步骤

要退出整个程序时

CLogicSo cket::threadRecv ProcFunc()处理收到的数据包

对于数 据包的 处理都要crc32 校验OK

没有包体，只有包头的数据包处理

含包体数据包处理，要做一些判断

客户端是否断线

消息码是否正确

是否有对应的消息处理函数

放心大胆的处理(真正的处理数据包)

调用消息码对应的成员函数来处理

(this->*statusHandler[])();

（技术）用来保存 成员函数指针 的数组

将一个待发送消息入到发消息队列

数据包 推进发 送队列中m_MsgSendQueue.push_back(p sendbuf);

将信号 量的值 +1,这 样其他卡在se m_wait的就可以走下去

msgSend(p_sendbuf);

&CL ogi cSo cke t::_HandleLogIn,//【6】：实现具体的登录功能

CLogicSocket::_HandleLogIn (）

ngx _wri te_reques t_handler()设置数据来时的写处理函数

发送数 据专用函数 sendproc()

系统调 用函数send()

对于上 面这函数，成功发送了数据，则需要调用

ngx _ep oll_oper_event在ep oll清除该事件