487-手写C++muduo库的梳理总结

本是古典何须时尚 2022-09-09 00:23 162阅读 0赞

## 手写C++muduo库的梳理总结 ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]  
mainReactor就是我们代码中的mainloop（baseloop），subReactor是我们代码中的工作线程进行读写事件的处理，read是底层做的，decode是我们自己做的。compute和encode也是我们自己做的。从网络上read数据，然后从网络上send数据，这些是由muduo库帮我们做的。decode compute encode是我们用户在OnMessage处理的业务逻辑。每一个线程都是一个独立的Reactor

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
**我们来梳理一下**

## Channel ##

我们看看它的成员变量：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
**channel主要做的事情是：**  
封装了fd，events和revents，还有一组回调方法  
fd就是表示要往poller上注册的文件描述符  
events就是事先设置的fd所感兴趣的事件（读事件或者写事件）  
revents就是poller最终给我们channel通知的这个fd上发生的事件，channel根据相应的发生的事件来执行相应的回调。  
对于上层来说，如果有一个fd的话，它就会把fd打包成channel通道，然后下发到poller上。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 4]

**我们来看看poller的头文件：**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 5]  
poller有一个成员变量channels，是一个map表，键就是channel打包的sockfd，值就是包含fd对应的channel，也就是说如果poller检测到哪个fd有事件发生了，就可以通过发生事件的fd和这个map表，找到这个fd对应的channel，这个channel里面就记录着详细的对应事件的回调方法。  
![在这里插入图片描述][6e8782588d41488eb045c7814384ed68.png]  
但是channel和poller是独立的，它们是不能直接互相通信的，它们都是依赖eventloop来通信的。  
不管是channel还是poller，都有一个成员变量记录它所在的事件循环（loop成员变量）。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 6]  
muduo库不管监听的listenfd还是accept返回，客户端连接成功返回跟客户端专门通信的connectionfd，都会把这个fd打包成channel，给它写入fd感兴趣的事件（读或者写事件），然后注册到相应的loop的poller上去。  
poller，我们在项目中实现的主要就是epollpoller，底层就是epoll，意味着底层就是通过epoll\_ctrl把相应的channel里面包含的fd注册到epoll上，当epoll返回以后，因为poller上有map表channels，通过sockfd找到它所对应的channel来调用相应的回调。  
channelcallbacks回调是上层设置的。  
我们总共就有2种channel，因为就2种fd:listenfd（依赖于accptor）和已建立连接的客户端专门通信用的connectionfd，  
**如下图表示：**![在这里插入图片描述][7ad23209a67f45f0b969c441e0579a1d.png]channel在调用相应的回调，比如说是listenfd发生的事件，那么它所调用的回调函数就是acceptor塞给它的，如果是已建立连接的客户端专门通信用的connectionfd，肯定就是TCPconnection塞给它的。channel和poller之间不能互相访问。  
**它们2个都是依赖eventloop事件循环的**  
eventloop相当于是reactor  
![在这里插入图片描述][e32488425bbc4c4c8705f989601dcf68.png]  
poller和epollpoller相当于是多路事件分发器  
![在这里插入图片描述][cd8935ce6aa44ea38042ac8d15680343.png]

## EventLoop ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 7]  
我们看到，它有一个activeChannels\_，这是一个vector，包含了所有的channel，因为上层交给反应堆的不只是单纯的fd，因为反应堆获取fd，还要执行相应的回调，所以塞给反应堆的都是channel，我们不要忘记，它还有weakupfd!  
wakeupfd也是被封装成wakeupchannel\_，主要作用是一个wakeupfd，是隶属于一个loop，也就是说，每个loop都有一个wakeupfd，因为loop最后执行触发底层的事件分发器，是epoll\_wait，只要没有事件发生，相应的loop线程阻塞在epoll\_wait上，如果我们想唤醒loop所在线程的阻塞状态，我们直接通过loop对象获取其wakeupfd，直接在这个wakeupfd上写个东西，相应的loop就会被唤醒。因为每个loop的wakeupfd也被封装成一个channel，注册在自己loop底层的epoll事件分发器上。  
![在这里插入图片描述][c9a0ec13950a43ea80d55e96c0a70482.png]  
**从大体上看，eventloop管理的就是一堆channel和一个poller，和自己的wakeupfd**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 8]  
这样一来，channel想把自己注册到poller上，或者是在poller上修改自己感兴趣的事件，channel都是通过eventloop获取poller的对象，来向poller设置，同样的，如果poller监测到有socketfd有相应的事件发生，就通过eventloop调用channel相应的fd所发生事件的回调函数。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 9]  
**我们看到，eventloop上有一个vector（pendingFunctors），存了一堆的回调函数。**  
![在这里插入图片描述][99fed6976935494fa33ecd371ae1d6aa.png]  
因为这些回调，每一个回调在执行的时候都应该是在loop自己所在的线程执行，如果说当前线程调用了loop，让这个loop执行回调，在程序逻辑上会进行个判断，如果当前线程就是这个loop那么直接执行回调，否则的话，就把它存到pendingFunctors这个vector里面，然后唤醒相应的loop，然后在vector里拿相应的回调执行。

## EventThreadPool ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 10]

**Thread是底层的线程。  
EventloopThread是事件的线程  
EventloopThreadPool是事件循环线程池**  
EventloopThreadPool里面有一个方法：getNextloop方法，默认是通过轮询算法获取下一个subloop，如果客户没有提供setthreadnumber设置线程，那么就是没有创建subloop，getNextloop永远返回的是baseloop  
当我们通过setthreadnumber设置底层的线程数量，EventloopThreadPool就会驱动底层开始创建线程，一个线程一个loop，就是**one loop per thread**

**EventloopThreadPool的内容如下**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 11]  
**EventloopThread的内容如下**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 12]  
包含了底层的线程模型thread  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 13]  
下面这个方法是启动新线程，新线程的执行函数：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 14]  
初始化好之后，开始epoll\_wait（loop.loop)

## Acceptor ##

Acceptor封装了listenfd相关的操作，比如说：创建listenfd，绑定bind，listen，listen成功后，把listenfd打包成acceptorchannel扔给baseloop来监听它的事件。  
**Buffer**是缓冲区，对于nonblocking（非阻塞）的I/O，我们都需要设置缓冲区，涉及到应用写数据写到缓冲区，再写到TCP的发送缓冲区，然后send数据  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_19_color_FFFFFF_t_70_g_se_x_16]  
因为TCP的发送缓冲区，写满了就要发送，这是同步的过程，效率比较慢。  
如果有缓冲区的话，我们用户写数据，直接向缓冲区进行写就可以了。  
**缓冲区里有prependable，readeridx，writeridx，这3个下标**  
prependable有8个字节，是头部信息，刚开始readeridx和writeridx都在这8个字节处的位置，然后我们写数据进去，写好的东西就可以是待发送的东西，由Buffer专门进行在缓冲区读取数据进行发送，我们从缓冲区可以进行send发送，用户也可以不断从缓冲区写数据，通过readeridx和writeridx处理  
模仿了Java的neti网络库channelbuffer  
**应用产生数据快，tcp发送的慢，难道每一次发送数据都要等tcp发送完上一次的数据再发送当前数据？写数据到buffer，然后让系统去调用write，或者系统调用read，把数据读到buffer上。相当于应用发送或者接收数据和tcp真实发送或者接收数据就成异步的了，这就非常高效了！！！**

## TcpConnection ##

**一个连接成功的客户端对应一个TcpConnection，**  
这个TcpConnection包含的东西有哪些？  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 15]  
**封装了socket，channel，和各种回调，高水位线的控制（不要发送过快），发送和接收缓冲区。**  
对于connectionfd在channel上执行的回调，都是由TcpConnection来设置的  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 16]

## TcpServer就是总领所有 ##

**TcpServer的成员：**  
Acceptor（得到新用户，才能通过EventLoopThreadpool的getnextloop，把新用户封装tcpconnection设置各种各样的回调以后，才能选择一个subloop，把新的connection扔给相应的loop）,EventLoopThreadpool，一堆callback，connectionmap![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 17]

## 流程叙述 ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 18]  
**首先，我们是怎么使用的？**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 19]  
1.定义一个loop，就是baseloop  
2.InetAddress打包了IP地址和端口号  
3.创建server对象，给到EchoServer的构造函数，通过其参数进行初始化底层的TCPserver对象，保留了loop  
4.设置了2个回调  
5.设置了底层的loop线程的数量（这个数量不包括baseloop）

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 20]  
很好的把网络代码和业务代码分离了，我们只需要做开发者需要关注的：  
**6.我们用户作为开发者只需要关注下面的2个方法：**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 21]  
响应连接的建立和断开

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 22]  
响应读写事件  
设置完之后  
7.server.start();启动loop  
loop.loop()

**总结而来就是：首先构建tcpserver对象，设置回调方法，然后设置底层的loop线程的数量，然后调用start方法，最后开启主线程的loop**

## 我们看看TcpServer的构造都做了什么？ ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 23]  
**创建了Acceptor，EventLoopThreadPool（还没有开启loop线程）**  
![在这里插入图片描述][1819c1fe1089468eb2094524caa9fd1c.png]  
![在这里插入图片描述][d4f6cc2ecbfd45d4abdef09307866a3b.png]  
首先Acceptor创建了一个非阻塞的listenfd，然后把它打包成1个channel，准备往mainloop的poller上扔。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 24]  
**然后设置了一些tcp选项，创建socket，绑定bind，给channel设置回调，就是readcallback**

**也就是说：Acceptchannel只关心读事件。**  
只关心acceptchannel有新用户的连接的事件，底层的channel会去执行readcallback，对于Acceptor的readcallback执行的是handleRead  
![在这里插入图片描述][6f6680ebf7e34539a9e1664e7e3de21e.png]  
**我们回过来继续看tcpserver的构造函数，接下来创建了EventLoopThreadPool（还没有开启loop线程），**  
然后执行了setNewConnectionCallback  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 25]

**我们刚才看到acceptor的构造函数，**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 26]

绑定了一个setReadCallback，也就是说，有新用户的连接，底层的channel回去执行readcallback，因为有新用户的连接，响应了epollin事件，然后就执行readcallback  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 27]  
而对应accptor执行的setreadcallback，执行的是handleread  
![在这里插入图片描述][895088af780a42dba2c719035f677991.png]  
我们进去看看handleread

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 28]  
这个里面的回调newConnectionCallback是谁设置的？  
这个setNewconnectionCallback是谁设置的？  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 29]

**是最上层TcpServer设置的！**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 30]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 31]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 32]  
注册在mainloop上的acceptor，当有新用户连接，成功以后，经过上面一串，最终执行的是TcpServer的newConnection方法。

**我们继续看TcpServer**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 33]

## 我们看看start方法 ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 34]**通过atomic变量started控制一下**  
我们最开始初始化为0，只能取启动1次，我们看第一句代码，threadpool启动底层线程池，创建loop子线程，并且开启loop的loop（）  
**子线程创建执行的就是**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 35]  
我们设置的线程的回调方法就是  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 36]  
59行马上就启动loop（）了  
启动的时候，为了能把处于睡眠中的subloop唤醒，每个loop都有一个wakeupfd注册在相应loop的子线程的poller上。

**接着我们看start的第二句**  
![在这里插入图片描述][3c9dd9d2e836432db18d5c66a4648dc9.png]  
执行acceptor的listen方法，把acceptorchannel注册在baseloop上的poller上。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 37]  
**这一切就都准备好了**  
main函数最后一句开启baseloop的loop  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 38]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 39]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 40]  
**我们在调用的三步骤：**  
1、构建TcpServer对象，同时包含了注册回调，设置底层线程的个数，和扩展。  
2、start开启loop子线程，注册wakeupfd，能够让主线程mainloop来唤醒子线程loop。然后acceptor listen，把listenfd打包成一个acceptorchannel注册到baseloop上。  
3、最后启动loop（）；

**我们看看acceptor的listen**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 41]  
**muduo库：mainloop和subloop之间并没有同步队列，并没有生产者消费者模型，mainloop生成连接，放到同步队列里面，subloop从同步队列去自己取连接，做成异步的生成连接和消费连接，并没有。  
而是用系统调用eventfd，创建wakeupfd，可以用它直接做线程间的notify，就是通知，唤醒，效率是非常非常高的。**  
**在libevent上用的是sockpair这个系统调用，创建的是基于Unix本地通信的双向通信的套接字。**

我们继续看，现在有一个新的连接了，mainloop就要返回了，执行acceptorchannel的readcallback，**最终调用的是TCPserver的newconnection**  
然后通过轮询算法选择一个subloop，让这个ioloop指针指向，  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 42]  
接着创建1个tcpconnection对象  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 43]  
然后设置了一些回调，这些回调将来由TcpConnection设置到底层的channel里面。  
**主要的是设置了**  
![在这里插入图片描述][8a99deaf0464421b880a98db7ae8412a.png]  
当fd被关闭的时候，最终回调到TcpServer 的removeconnection，最终执行下面这个方法  
![在这里插入图片描述][1dc1089bd5ec49aeaae09f9410232c2f.png]  
这个ioLoop是肯定是在当前的主线程里去执行的，但是主线程访问ioLoop访问的肯定是一个子线程对应的loop，所以这里的ioLoop->runInLoop肯定不是在主线程里面执行的，**除非是没有设置子线程**。  
**我们看看runInLoop函数**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 44]  
**queueInloop就是：每一个eventloop都有一个成员变量：wakeupfd，现在要在一个subloop里面执行下面这个方法：**![在这里插入图片描述][1dc1089bd5ec49aeaae09f9410232c2f.png]  
**通过这个指针找到subloop的wakeupfd，往wakeupfd上写数据，把相应的subloop唤醒，唤醒以后就去执行这个connectionEstablished，**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 45]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_17_color_FFFFFF_t_70_g_se_x_16]

**我们进入connectEstablished**

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 46]  
**设置了状态**，一个connection肯定是包含有一个channel，因为一个connection表示一个connectfd，就会打包成1个channel。  
用channel绑定了当前 的TcpConnection  
因为只有channel才能收到poller给它通知的事件回调，它执行的事件回调都是TcpConnection设置给它的，如果TcpConnection由于一些原因这个对象TcpConnection没有了，那channel到时候还执行不执行回调？  
所以，channel在这里使用了 weakptr弱智能指针来记录了这个TcpConnection对象，到时候通过弱智能指针的提升来监测TcpConnection是否存活，存在就执行相应的回调，不存在就不执行了。  
然后channel调用enableReading函数，向相应的poller注册channel，唤醒后把当前TcpConnectionchannel注册在它选择的某个subloop上了，

**在主函数调用中，新连接来了，就是**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 47]  
**连接成功，有数据通信怎么办？**  
对于新连接来说，都是注册了socketfd的epollIn事件，如果有相应的可读事件到来，那么相应的loop线程的poller就会返回，返回以后就执行相应的channel的readcallback事件，![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 48]  
通过的是  
![在这里插入图片描述][b5ec5f7cbce34f159058b897574049d1.png]  
**执行的就是Tcpconnection的handleread**  
![在这里插入图片描述][5557d62510f145df829cb859a1fdb948.png]  
**handleread开始读数据，数据读上来**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 49]  
**调用messagecallback  
相应的响应就是给上层应用报上来，回调给用户。**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 50]  
通过buf->retrieveALLAsString拿到原始字符串，反序列化得到json或者pbbuff，然后业务处理，然后响应send。  
所以说，相应的channel有可读事件发生，subloop就会回调channel的readcallback，tcpconnection给相应的channel的readcallback绑定的就是tcpconnection的handleread，handleread通过inputbuffer读取相应的socketfd上的数据，读取完，回调用户设置的messagecallback  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 51]  
然后用户这里就响应了  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 50]

## 接着我们来看连接的关闭 ##

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 52]  
**如果有异常，对端关闭了或者是当前服务端在这里主动调用shutdown，底层的channel都会响应closecallback**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 53]  
这个closecallback，TCPconnection设置的是哪个回调？  
![在这里插入图片描述][4a5c0abda6a642928d5ef26ce240873b.png]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 54]  
handleclose把对应的channel和感兴趣的事件从poller上删除。然后执行用户的回调。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 55]

**对于使用者来说，onconnection又发生了回调，**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 56]  
执行tcpconnection的  
![在这里插入图片描述][cc72328828504f078e0e7836f31c3c32.png]  
这次是断开连接的回调  
**执行TCPserver的**

![在这里插入图片描述][50e2e71f725b4fa9b9113ab7a5dca932.png]  
就调用到  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 57]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 58]  
在TCPserver里，把这个connection从connectionsmap删除掉，然后getloop，获取这条连接所在的子loop，执行connectDestroyed，  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 59]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 60]  
已经设置成kDisconnected了

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/719142a7e06f433d8ee2250ff1694348.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/460af523c4014ea181b8c93f89e9d738.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220829/1b991e8ca55c43ed9eb543ca62f466ea.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220829/1acd2d705b1a4789a2ba672a2a5e3ebc.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220829/56e4c34107a0492ea9431b64446255dd.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220829/74c635cfa69b439ebcd6d8a5d4aa793d.png
[6e8782588d41488eb045c7814384ed68.png]: /images/20220829/a296c685d391490b97cae628d573b110.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220829/5590c342a08b458b8d8f4f5394bf5511.png
[7ad23209a67f45f0b969c441e0579a1d.png]: /images/20220829/7cdab7e4be424e16965ee145f8d43486.png
[e32488425bbc4c4c8705f989601dcf68.png]: /images/20220829/f4e33c5a31ef4da5a47e829ad7bb30d8.png
[cd8935ce6aa44ea38042ac8d15680343.png]: /images/20220829/1c7f68bc9401427aab34d86211d28bb0.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220829/549d6ebaed0b4918945dda31c51edcd0.png
[c9a0ec13950a43ea80d55e96c0a70482.png]: /images/20220829/e4fdd05bc4c344ae9721ae6aa18e7674.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 8]: /images/20220829/2947c16715184a24a66ae1716ef5552d.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 9]: /images/20220829/66c9588934164ae38d47b336804e057c.png
[99fed6976935494fa33ecd371ae1d6aa.png]: /images/20220829/44ede6f59384495eade16b31ffc9df07.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 10]: /images/20220829/56c7e7f1a0b245c6979865fee3c0682a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 11]: /images/20220829/9d0acd05e59a4079ba4b91a50723b69a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 12]: /images/20220829/7a9f24fd7c904381825acbf4cd0e6224.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 13]: /images/20220829/072d2101652649df810511377bde09fa.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 14]: /images/20220829/8204b1ed87e04efcbd0a1b386f6ed478.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_19_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/f63e176901154040987c0b0ffddf8f4c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 15]: /images/20220829/29cf1ae0b82144e3a8ad7706757e6208.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 16]: /images/20220829/dcf72895bfb541ebaeb4b9ef86e7ae7f.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 17]: /images/20220829/0b0d4d4bdb5a4ffba4a647ebbe5cebfc.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 18]: /images/20220829/54fbaf446a9c43bf8bb64225f7c8a426.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 19]: /images/20220829/f210012f9bf448dfbec10c39648b4b8b.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 20]: /images/20220829/04088caf88da498f8f6ce857d11e1403.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 21]: /images/20220829/54b4cd72ba7d49d88051cb4d245d2b2c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 22]: /images/20220829/84d8c04703144cb5ae00ac4e4b199baa.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 23]: /images/20220829/ef2b7684f3544bceb4035d3048d1972a.png
[1819c1fe1089468eb2094524caa9fd1c.png]: /images/20220829/8da87853183d4cbfad51d80c2a1af0bc.png
[d4f6cc2ecbfd45d4abdef09307866a3b.png]: /images/20220829/0871db8a67fa4472a0e60bcfeeb5a201.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 24]: /images/20220829/2a8c577f455f4e60b75ff59466be849d.png
[6f6680ebf7e34539a9e1664e7e3de21e.png]: /images/20220829/5cf4269080bd4cd1a4d24840837d0eba.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 25]: /images/20220829/b38cb25859424743ad5de0d2b0d4613c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 26]: /images/20220829/6601127220cb419593b1f56efac2dd61.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 27]: /images/20220829/600cf85b152b46f88f1b4831ae1f4cfd.png
[895088af780a42dba2c719035f677991.png]: /images/20220829/5d0a5ccbccfb43adb64e8fc9338b33f1.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 28]: /images/20220829/3ab06c38ff464fedae0b383c3908db0a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 29]: /images/20220829/a022e72564184281bccf411b5f7517da.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 30]: /images/20220829/431f7a643f084b45931520355c54d127.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 31]: /images/20220829/a185f61161744ec69692c7b6602a02e9.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 32]: /images/20220829/019841c827d74ca4b011c593f9f80165.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 33]: /images/20220829/c4d338858df6464989439e326eca539a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 34]: /images/20220829/22ff3a024d2a43ac8a13034657802820.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 35]: /images/20220829/cf4c29614cca42eba81610c1e2003ceb.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 36]: /images/20220829/e416f4995e8149829dbd7b138236627b.png
[3c9dd9d2e836432db18d5c66a4648dc9.png]: /images/20220829/c7518dfcbd954ed49ee546b6a174c037.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 37]: /images/20220829/98b6ee83bfcf4da89b8ff3fc6d507ac8.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 38]: /images/20220829/e5010eddd0ec49768291a1996ac2de14.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 39]: /images/20220829/3b0e6c8ccdff4425ae6b95031ffe76af.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 40]: /images/20220829/1cf48ec8222f4f8c954d2e3b2d62f7e5.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 41]: /images/20220829/594fc2a4a36a40b0b0d90ba6821f6a05.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 42]: /images/20220829/692c31830de144ff924af919347f577c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 43]: /images/20220829/2007b442b0de4ecb9cd29ced09ad31f0.png
[8a99deaf0464421b880a98db7ae8412a.png]: /images/20220829/014099d3b62a45e484d37e76130f1eeb.png
[1dc1089bd5ec49aeaae09f9410232c2f.png]: /images/20220829/ddac1f7d4cca48ff9c73078d1ec13041.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 44]: /images/20220829/293d8285120343f5a2fd0c96eb9328d8.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 45]: /images/20220829/cee77cb53ab34aff9b0e0f2b08caa908.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_17_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/3f00cc7f71bc4353a25505071b8c7196.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 46]: /images/20220829/c7f1fcc2d78b4c038912a17c4db85d22.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 47]: /images/20220829/e1dee0c2bc864a96a3f6582ffc702d86.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 48]: /images/20220829/8b8106e1fb7345569a5b0825ec46acdf.png
[b5ec5f7cbce34f159058b897574049d1.png]: /images/20220829/e60e409f04184f2c8fe28608d0b20aa8.png
[5557d62510f145df829cb859a1fdb948.png]: /images/20220829/04c7fb7e27144e2191c2fb050170f31e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 49]: /images/20220829/6e1ed4b0a4a743a58123bf29a4cb24b9.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 50]: /images/20220829/b8e534568b1843ebac7346faef1070f1.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 51]: /images/20220829/ba1c079cab4248e8a59382ac1e57043e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 52]: /images/20220829/3e6540888e4c4810887be84d34d24b28.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 53]: /images/20220829/d84d59caa1f943c092f9a83882c7b9f5.png
[4a5c0abda6a642928d5ef26ce240873b.png]: /images/20220829/2e10f00d196c47e4b97b087300f179ee.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 54]: /images/20220829/831fc51b50f94702b6d6dce0fa34880b.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 55]: /images/20220829/72ef835448bc4d77943cdbca682c874a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 56]: /images/20220829/e3846c7270a4450d8a703f51621bdb56.png
[cc72328828504f078e0e7836f31c3c32.png]: /images/20220829/a2506e612e0b4a17911848a492851282.png
[50e2e71f725b4fa9b9113ab7a5dca932.png]: /images/20220829/e520c2fb836640e9b8534b5d21c7a437.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 57]: /images/20220829/85a10f1c910a4edea6906dfb241807dd.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 58]: /images/20220829/980822ee26d244e4a5855e77315f12b7.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 59]: /images/20220829/bfba524087e145e0ba4a6345c16f22e3.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 60]: /images/20220829/5cd2191466ce4980bb6ec0f150d3ac8e.png