mysql 源码学习笔记：客户端连接处理流程

谁践踏了优雅 2022-09-29 05:29 161阅读 0赞

**版本**

CentOS release 6.7环境下mysql-5.7.16 社区版

**概述**

mysql通过监听本地unix sock和tcp连接的端口，分别处理本机和远程客户端的连接，以每个客户端连接对应一个线程的（默认）方式，处理客户端发送的命令。

这里对服务器端的源码做分析，不对客户端的源码作分析。

**源码分析**

**服务器端监听**

**基础类**

mysql通过两个类来实现mysql的监听机制

class Mysqld\_socket\_listener /\*记录服务器监听的基本信息\*/

/\*tcp 连接的监听地址和端口、unix socket路径名等信息\*/

std::string m\_bind\_addr\_str

......

/\*错误等统计信息\*/

static ulong connection\_errors\_select;

......

template <typename Listener> class Connection\_acceptor /\*封装了一些socket相关函数\*/

Listener \*m\_listener; 与类Mysqld\_socket\_listener结合使用，指向该类的对象

/\*封装了socket操作一些方法\*/

bool init\_connection\_acceptor()

....

**初始化**

通过系统变量bind\_addr\_str、mysqld\_port、unix\_sock\_name等创建类mysqld\_socket\_listener的对象，并为全局的类对象mysqld\_socket\_acceptor的对象初始化。

创建TCP、unix socket的SOCKET文件描述符，加入到poll的监控队列中，等待客户端连接。

Connection\_acceptor<Mysqld\_socket\_listener> \*mysqld\_socket\_acceptor= NULL;

mysqld\_main

| network\_init

| set\_ports

| 如果端口未设置 mysqld\_port = 3306

| 如果sock文件未设置 mysqld\_unix\_port = /tmp/mysql.sock

/\*定义类对象\*/

| Mysqld\_socket\_listener \*mysqld\_socket\_listener...

| mysqld\_socket\_acceptor = new (std::nothrow) Connection\_acceptor<Mysqld\_socket\_listener>(mysqld\_socket\_listene）

/\*创建socket，加入poll中\*/

| mysqld\_socket\_acceptor->init\_connection\_acceptor()

| m\_listener->setup\_listener();

|  TCP\_socket tcp\_socket(m\_bind\_addr\_str, m\_tcp\_port,  m\_backlog, m\_port\_timeout);

MYSQL\_SOCKET mysql\_socket= tcp\_socket.get\_listener\_socket();             创建TCP连接的socket

|  Unix\_socket unix\_socket(&m\_unix\_sockname, m\_backlog);

MYSQL\_SOCKET mysql\_socket= unix\_socket.get\_listener\_socket();            创建unix sock连接的socket

|   for (socket\_map\_iterator\_t sock\_map\_iter=  m\_socket\_map.begin();  ...        将socket作为设备句柄

|  m\_poll\_info.m\_fds\[count\].fd= mysql\_socket\_getfd(listen\_socket);               使用poll 分别监听 两个socket

|  m\_poll\_info.m\_fds\[count\].events= POLLIN;

| m\_poll\_info.m\_pfs\_fds\[count\]= listen\_socket;

**监听并接收socket连接**

通过poll来监听加入poll监控队列的文件描述符（tcp socket和本地unix socket），如果客户端发送连接请求，则通过accept函数与客户端建立连接

mysqld\_main

| mysqld\_socket\_acceptor->connection\_event\_loop();

**   |  m\_listener->listen\_for\_connection\_event();**

**   **         |  poll(&m\_poll\_info.m\_fds\[0\], m\_socket\_map.size(), -1);                            开始使用poll 监听客户端连接

|    for (socket\_map\_iterator\_t sock\_map\_iter=  m\_socket\_map.begin();     当有客户端连接请求时，遍历所有的socket

sock\_map\_iter != m\_socket\_map.end(); ++sock\_map\_iter)

|   connect\_sock= mysql\_socket\_accept(key\_socket\_client\_connection, listen\_sock,      通过accept创建新的socket

(struct sockaddr \*)(&cAddr), &length);

|  **mgr->process\_new\_connection(channel\_info);**

|  **Per\_thread\_connection\_handler::add\_connection**

|  error= mysql\_thread\_create(key\_thread\_one\_connection, &id,  &connection\_attrib,

**handle\_connection**,  (void\*) channel\_info);              创建新线程处理客户端连接，线程处理函数为 handle\_connection

**客户端连接**

当客户端连接到服务器端，服务器端创建了socket与客户端连接后，服务器端会创建一个单独的线程对这个客户端做处理，包括身份验证、接收命令、处理命令、发送应答等。

**基础类**

class Connection\_handler\_manager 封装了客户端连接管理函数

/\*连接处理函数，默认指向Per\_thread\_connection\_handler\*/

Connection\_handler\* m\_connection\_handler;

......

/\*校验连接数，为客户端创建新的线程等操作\*/

bool check\_and\_incr\_conn\_count();

void process\_new\_connection(Channel\_info\* channel\_info);

....

**创建线程**

mysqld\_main

| mysqld\_socket\_acceptor->connection\_event\_loop();

| m\_listener->listen\_for\_connection\_event()

/\*生成新的sokcet 与客户端建立连接后\*/

| mgr(Connection\_handler\_manager)->process\_new\_connection()

/\*校验连接数， 这里校验的是最大连接数 + 1，为root预留一个连接数 \*/

| check\_and\_incr\_conn\_count

/\*默认m\_connection\_handler 指向 Per\_thread\_connection\_handler\*/

| m\_connection\_handler->add\_connection(Per\_thread\_connection\_handler::add\_connection)

/\*为客户端创建新的线程，线程执行函数为handle\_connection\*/

| error= mysql\_thread\_create(...,handle\_connection...

**客户端线程处理函数**

包括客户端的身份校验、命令接收、命令执行等。

handle\_connection

| thd\_prepare\_connection(thd)

| login\_connection /\*客户端身份校验，host、user、passwd等的校验\*/

|    for (;;)

|  THD \*thd= init\_new\_thd(channel\_info);

|   thd\_manager->add\_thd(thd);                                                       将新增线程加入线程管理模块

|   while (thd\_connection\_alive(thd))

**                | if (do\_command(thd))                                                                等待客户端发送命令， 循环处理**

break;

|   end\_connection(thd);

mysql 源码学习笔记：客户端连接处理流程

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 grpc 客户端连接请求源码

相关 Thrfit 客户端请求处理流程

相关 mysql 源码学习笔记：客户端连接处理流程

相关 Redis如何处理客户端连接

相关 Redis如何处理客户端连接

相关 mysql 源码学习笔记：mysqld启动流程

相关 netty5笔记-总体流程分析5-客户端连接过程

相关 netty源码阅读之客户端新连接

相关 Elasticsearch笔记（八）：客户端连接

相关 Redis学习笔记 - 客户端