分布式数据库中间件–(3) Cobar对简单select命令的处理过程

在上一篇中介绍了Cobar和client初次建立连接的过程，Cobar监听端口，client发起连接请求，Cobar发送握手数据包，client发送认证数据包最后依据认证的结果Cobar向client发送认证结果。

在认证成功后Cobar会将该连接的回调处理函数由FrontendAuthenticator（前端认证处理器）设置成FrontendCommandHanler（前端命令处理器）。

所以在client再次向Cobar发送请求报文的时候，前端命令处理器会处理该连接。以下详细分析一下简单select语句的运行过程。

1、事件的产生

NIOReactor的R线程一直在监听selector上的每一个连接的感兴趣事件是否发生，当client发送了一条select * from tb1，select函数会返回，然后获取到该连接SelectionKey，而且该SelectKey的兴趣事件是OP_READ。此时会调用read(NIOConnection)函数。

 2、调用该连接的read函数进行处理

该函数在上一篇中提到过，该函数的实如今AbstractConnection中，实现从channel中读取数据到缓冲区，然后从缓冲区完整的取出整包数据交给FrontendConnection类的handle()函数处理。

该函数交给processor进行异步处理。从processor中的线程池获取一个线程来运行该任务。这里调用详细的handler来进行处理。

刚開始提到的，当认证成功后，Cobar将连接的回调处理函数设置为FrontendCommandHandler。所以这里会调用前端命令处理器的handler函数进行数据的处理。

在这里须要先了解MySQL数据包的格式：

MySQLclient命令请求报文

该处理函数例如以下：

由于每一个报文都有消息头，消息头固定的是4个字节，前3个字节是消息长度，后面的一个字节是报文序号，例如以下所看到的

所以data[4]是第五个字节。也就是消息体的第一个字节。client向Cobar端发送的是命令报文，第一个字节是详细的命令。

假设是select语句，那么data[4]就是COM_QUERY，然后会调用详细连接的query成员函数，其定义在FrontendConnection类中。

首先新建一个MySQLMessage对象，将数据包的索引位置定位到第6个字节位置处。然后将后面的全部的字节读取成指定编码格式的SQL语句，这里就形成了完整的SQL语句。

查询的时候Cobar控制台输出例如以下内容：

11:35:33,392 INFO data[4]:3
11:35:33,392 DEBUG 解析的SQL语句:select * from tb2

解析出SQL语句后交给queryHandler处理。该对象是在新建连接的时候设置的ServerQueryHandler类，事实上现的query函数例如以下：

首先对SQL语句进程解析，通过parse函数对语句解析后返回语句类型的编号。

假设语句没有语法错误，则直接交给SelectHandler进行处理。假设是一般的select语句，则直接调用ServerConnection的execute运行sql

c.execute(stmt, ServerParse.SELECT);

在ServerConnection中的execute函数中须要进行路由检查，由于select的数据不一定在一个数据库中，须要按拆分的规则进行路由的检查。

详细的路由算法也是比較复杂，以后会专门分析。

Cobar的DEBUG控制台输出路由的计算结果例如以下：

11:35:33,392 DEBUG 路由计算结果:select * from tb2, route={
1 -> dnTest2.default{select * from tb2}
2 -> dnTest3.default{select * from tb2}
}

该条SQL语句的select内容分布在dnTset2和dnTest3中，所以要分别向这两个数据库进行查询。

经过比較复杂的资源处理最后在每一个后端数据库上运行函数execute0。

这里真正的运行SQL语句，然后等待后端运行语句的返回数据，在成功获取后端Mysql返回的结果后，该函数返回的数据包是结果集数据包。

当client发起认证请求或命令请求后，server会返回对应的运行结果给client。client在收到响应报文后，须要首先检查第1个字节的值，来区分响应报文的类型。

注：响应报文的第1个字节在不同类型中含义不同，比方在OK报文中，该字节并没有实际意义，值恒为0×00；而在Result Set报文中，该字节又是长度编码的二进制数据结构（Length Coded Binary）中的第1字节。

Result Set 消息分为五部分，结构例如以下：

函数运行完毕后，返回的结果都放入LinkedList中，当读取结果完毕后放入多节点运行器的缓冲区。假设buffer满了，就通过前端连接写出给client。