分布式數(shù)據(jù)庫(kù)中間件–(2)Cobar與客戶端的握手認(rèn)證

 private void read(NIOConnection c) {
 try {
 c.read();
 } catch (Throwable e) {
 c.error(ErrorCode.ERR_READ, e);
 }
 }

 public void handle(final byte[] data) {
 // 從線程池獲取一個(gè)線程,異步處理前端數(shù)據(jù)
 	// 從processor中的線程池中獲取一個(gè)可以執(zhí)行的線程,執(zhí)行Runnable任務(wù)
 processor.getHandler().execute(new Runnable() {
 @Override
 public void run() {
 try {
 //調(diào)用具體NIOHandler子類的handle函數(shù)
 handler.handle(data);
 } catch (Throwable t) {
 error(ErrorCode.ERR_HANDLE_DATA, t);
 }
 }
 });
 }

 public FrontendConnection(SocketChannel channel) {
 super(channel);
 .....................
 //前端認(rèn)證處理器
 this.handler = new FrontendAuthenticator(this);
 }

 public void handle(byte[] data) {
 // check quit packet
 if (data.length == QuitPacket.QUIT.length && data[4] == MySQLPacket.COM_QUIT) {
 source.close();
 return;
 }
 //新建認(rèn)證包對(duì)象
 AuthPacket auth = new AuthPacket();
 //讀取認(rèn)證包到對(duì)象
 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:
 //認(rèn)證成功,向客戶端發(fā)送認(rèn)證結(jié)果消息
 success(auth);
 }
 }

 protected void success(AuthPacket auth) {
 	//認(rèn)證通過(guò),設(shè)置連接屬性:已認(rèn)證\用戶\數(shù)據(jù)庫(kù)\處理器
 source.setAuthenticated(true);
 source.setUser(auth.user);
 source.setSchema(auth.database);
 source.setCharsetIndex(auth.charsetIndex);
 //設(shè)置該連接的連接處理器為前端命令處理器
 source.setHandler(new FrontendCommandHandler(source));
 .......
 ByteBuffer buffer = source.allocate();
 source.write(source.writeToBuffer(AUTH_OK, buffer));
 }

16:59:19,388 INFO ===============================================
16:59:19,389 INFO Cobar is ready to startup ...
16:59:19,389 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接受連接數(shù):0
16:59:23,464 DEBUG 2>>NIOReactor接受連接數(shù):1
16:59:23,465 DEBUG select讀事件
16:59:23,465 INFO com.alibaba.cobar.net.handler.FrontendAuthenticator接收的請(qǐng)求長(zhǎng)度: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>