private void read(NIOConnection c) {
try {
c.read();
} catch (Throwable e) {
c.error(ErrorCode.ERR_READ, e);
}
}
6、 连接类中定义的read函数定义在AbstractConnection类中。在该read函数 public void handle(final byte[] data) {
// 从线程池获取一个线程,异步处理前端数据
// 从processor中的线程池中获取一个可以执行的线程,执行Runnable任务
processor.getHandler().execute(new Runnable() {
@Override
public void run() {
try {
//调用具体NIOHandler子类的handle函数
handler.handle(data);
} catch (Throwable t) {
error(ErrorCode.ERR_HANDLE_DATA, t);
}
}
});
}
8、 handler在构造函数中初始化成前端认证处理器，用于处理前端权限认证。
public FrontendConnection(SocketChannel channel) {
super(channel);
.....................
//前端认证处理器
this.handler = new FrontendAuthenticator(this);
}
9、 由于Cobar是基于MySQL协议的，所以需要分析一下MySQL协议的具体格式。下面就先分析一下MySQL认证数据包的格式：
每个报文都分为消息头和消息体两部分，其中消息头是固定的四个字节，报文结构如下：
public void handle(byte[] data) {
// check quit packet
if (data.length == QuitPacket.QUIT.length && data[4] == MySQLPacket.COM_QUIT) {
source.close();
return;
}
//新建认证包对象
AuthPacket auth = new AuthPacket();
//读取认证包到对象
auth.read(data);
// check user
if (!checkUser(auth.user, source.getHost())) {
failure(ErrorCode.ER_ACCESS_DENIED_ERROR, "Access denied for user '" + auth.user + "'");
return;
}
// check password
if (!checkPassword(auth.password, auth.user)) {
failure(ErrorCode.ER_ACCESS_DENIED_ERROR, "Access denied for user '" + auth.user + "'");
return;
}
// check schema
switch (checkSchema(auth.database, auth.user)) {
case ErrorCode.ER_BAD_DB_ERROR:
failure(ErrorCode.ER_BAD_DB_ERROR, "Unknown database '" + auth.database + "'");
break;
case ErrorCode.ER_DBACCESS_DENIED_ERROR:
String s = "Access denied for user '" + auth.user + "' to database '" + auth.database + "'";
failure(ErrorCode.ER_DBACCESS_DENIED_ERROR, s);
break;
default:
//认证成功,向客户端发送认证结果消息
success(auth);
}
}
在上面的auth.read函数中会按9中的协议格式进行读取数据到auth对象。认证成功后会执行：
protected void success(AuthPacket auth) {
//认证通过,设置连接属性:已认证\用户\数据库\处理器
source.setAuthenticated(true);
source.setUser(auth.user);
source.setSchema(auth.database);
source.setCharsetIndex(auth.charsetIndex);
//设置该连接的连接处理器为前端命令处理器
source.setHandler(new FrontendCommandHandler(source));
.......
ByteBuffer buffer = source.allocate();
source.write(source.writeToBuffer(AUTH_OK, buffer));
}
可以看到，在上面的函数中，设置连接对象source中的成员（是否认证、用户、数据库、编码、处理该连接后续数据包的处理器【handle方法】）
然后回复认证成功的消息。后面客户端再发送消息，会交给前端命令处理器进行处理。
客户端进行链接的时候Cobar服务器的输出：
16:59:19,388 INFO =============================================== 16:59:19,3 INFO Cobar is ready to startup ... 16:59:19,3 INFO Startup processors ... 16:59:19,455 INFO Startup connector ... 16:59:19,460 INFO Initialize dataNodes ... 16:59:19,506 INFO dnTest1:0 init success 16:59:19,514 INFO dnTest3:0 init success 16:59:19,517 INFO dnTest2:0 init success 16:59:19,527 INFO CobarServer is started and listening on 8066 16:59:19,527 INFO =============================================== 16:59:23,459 DEBUG 1>>NIOReactor接受连接数:0 16:59:23,4 DEBUG 2>>NIOReactor接受连接数:1 16:59:23,465 DEBUG select读事件 16:59:23,465 INFO com.alibaba.cobar.net.handler.FrontendAuthenticator接收的请求长度:62 58 0 0 1 5 166 15 0 0 0 0 1 33 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 114 111 111 116 0 20 169 171 247 102 133 96 158 224 121 22 226 229 88 244 119 238 185 61 124 219 16:59:23,468 INFO [thread=Processor1-H0,class=ServerConnection,host=192.168.137.8,port=46101,schema=null]'root' login success客户端得到的回复：
yan@yan-Z400:~$ mysql -uroot -p** -P8066 -h192.168.137.8 Welcome to the MySQL monitor. Commands end with ; or \g. Your MySQL connection id is 1 Server version: 5.1.48-cobar-1.2.7 Cobar Server (ALIBABA) Copyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved. Oracle is a registered trademark of Oracle Corporation and/or its affiliates. Other names may be trademarks of their respective owners. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. mysql>MySQL客户端的命令处理，具体后续会分析。
本文出自：http://blog.geekcome.com, 原文地址：http://blog.geekcome.com/%e5%88%86%e5%b8%83%e5%bc%8f%e6%95%b0%e6%8d%ae%e5%ba%93%e4%b8%ad%e9%97%b4%e4%bb%b6-2-cobar%e4%b8%8e%e5%ae%a2%e6%88%b7%e7%ab%af%e7%9a%84%e6%8f%a1%e6%%8b%e8%ae%a4%e8%af%81, 感谢原作者分享。
下载本文