数据库路由中间件MyCat - 源代码篇(7)
此文已由作者张镐薪授权网易云社区发布。
欢迎访问网易云社区,了解更多网易技术产品运营经验。
3. 连接模块
3.4 FrontendConnection前端连接
构造方法:
public FrontendConnection(NetworkChannel channel) throws IOException { super(channel);InetSocketAddress localAddr = (InetSocketAddress) channel.getLocalAddress();InetSocketAddress remoteAddr = null; if (channel instanceof SocketChannel) {remoteAddr = (InetSocketAddress) ((SocketChannel) channel).getRemoteAddress(); } else if (channel instanceof AsynchronousSocketChannel) {remoteAddr = (InetSocketAddress) ((AsynchronousSocketChannel) channel).getRemoteAddress();} this.host = remoteAddr.getHostString(); this.port = localAddr.getPort(); this.localPort = remoteAddr.getPort(); this.handler = new FrontendAuthenticator(this);}
FrontendConnection是对前端连接channel的封装,接受NetworkChannel作为参数构造。前端连接建立,需要先验证其权限,所以,handler首先设置为FrontendAuthenticator 等到验证成功,handler会被设置成FrontendCommandHandler。 下面来看和FrontendConnection相关的Handler: FrontendCommandHandler会先解析请求类型,之后调用不同的方法处理不同类型的请求。例如,FrontendQueryHandler会解析query类型的sql请求语句:
@Overridepublic void handle(byte[] data){ if(source.getLoadDataInfileHandler()!=null&&source.getLoadDataInfileHandler().isStartLoadData()){MySQLMessage mm = new MySQLMessage(data); int packetLength = mm.readUB3(); if(packetLength+4==data.length){source.loadDataInfileData(data);} return;} switch (data[4]){ case MySQLPacket.COM_INIT_DB:commands.doInitDB();source.initDB(data); break; case MySQLPacket.COM_QUERY:commands.doQuery();source.query(data); break; case MySQLPacket.COM_PING:commands.doPing();source.ping(); break; case MySQLPacket.COM_QUIT:commands.doQuit();source.close("quit cmd"); break; case MySQLPacket.COM_PROCESS_KILL:commands.doKill();source.kill(data); break; case MySQLPacket.COM_STMT_PREPARE:commands.doStmtPrepare();source.stmtPrepare(data); break; case MySQLPacket.COM_STMT_EXECUTE:commands.doStmtExecute();source.stmtExecute(data); break; case MySQLPacket.COM_STMT_CLOSE:commands.doStmtClose();source.stmtClose(data); break; case MySQLPacket.COM_HEARTBEAT:commands.doHeartbeat();source.heartbeat(data); break; default:commands.doOther();source.writeErrMessage(ErrorCode.ER_UNKNOWN_COM_ERROR, "Unknown command");}}
FrontendCommandHandler会调用FrontendConnection合适的方法解析处理不同的请求,例如它的initDB(byte[] data)方法:
public void initDB(byte[] data) {MySQLMessage mm = new MySQLMessage(data);mm.position(5);String db = mm.readString(); // 检查schema的有效性if (db == null || !privileges.schemaExists(db)) {writeErrMessage(ErrorCode.ER_BAD_DB_ERROR, "Unknown database '" + db + "'"); return;} if (!privileges.userExists(user, host)) {writeErrMessage(ErrorCode.ER_ACCESS_DENIED_ERROR, "Access denied for user '" + user + "'"); return;}Set<String> schemas = privileges.getUserSchemas(user); if (schemas == null || schemas.size() == 0 || schemas.contains(db)) { this.schema = db;write(writeToBuffer(OkPacket.OK, allocate()));} else {String s = "Access denied for user '" + user + "' to database '" + db + "'";writeErrMessage(ErrorCode.ER_DBACCESS_DENIED_ERROR, s);}}
方法调用: 通过查看可以发现,在command packet被解析出是initDB类型的请求时(其实就是用户发送的查询语句为“use XXX”),会调用此方法进行处理,同时,这些方法都是被RW线程执行的。 此方法从FrontedPrivilege中验证用户是否有权限访问这个逻辑库,如果有就把当前连接的逻辑库设为用户请求的逻辑库。 其他方法与handler也是相似的关系,可以看出,FrontendConnection组合了多种封装的handler来处理不同的请求的不同阶段。至于各种handler,会在之后sql解析,sql路由,协议实现等模块详细介绍。
3.4.1 ServerConnection服务端连接
前端连接包括ServerConnection(服务端连接)和ManagerConnection(管理端连接)。前端链接不会直接创建,而是通过工厂创建: 工厂方法:
@Overrideprotected FrontendConnection getConnection(NetworkChannel channel) throws IOException {SystemConfig sys = MycatServer.getInstance().getConfig().getSystem();ServerConnection c = new ServerConnection(channel);MycatServer.getInstance().getConfig().setSocketParams(c, true);c.setPrivileges(MycatPrivileges.instance());c.setQueryHandler(new ServerQueryHandler(c));c.setLoadDataInfileHandler(new ServerLoadDataInfileHandler(c)); // c.setPrepareHandler(new ServerPrepareHandler(c));c.setTxIsolation(sys.getTxIsolation());c.setSession2(new NonBlockingSession(c)); return c;}
可以看出,每个新的ServerConnection都会绑定一个新的ServerQueryHandler负责处理sql指令,一个ServerLoadDataInfileHandler负责处理文件载入命令,一个session负责处理事务 下面是相关的类图 这里的所有独立的handler里面都是static方法,可供其他类直接调用。每个ServerConnection都会有一个NonBlockingSession来处理。 这里说下连接、会话、逻辑库、MyCat实例的关系(与MySQL里面的连接、会话、数据库、MySQL实例的关系不太一样);首先每个MyCat实例都管理多个数据库。连接是针对MyCat实例建立的,并且,MyCat的连接(AbstractConnection)是不可复用的,在close方法会关闭连接并清理使用的资源。但是缓存资源(buffer)是可以复用的。比如,在一个前端连接长时间空闲时或者出现异常时,会被清理掉。每个连接会拥有一个session来处理事务,保存会话信息。 这里,每个连接拥有一个会话。每个连接中的方法,被RW线程执行,相当于与RW线程绑定。RW线程是可以复用的,这里相当于MySQL中的连接是可以复用的(连接池)。 Session.java:
public interface Session { /*** 取得源端连接*/FrontendConnection getSource(); /*** 取得当前目标端数量*/int getTargetCount(); /*** 开启一个会话执行*/void execute(RouteResultset rrs, int type); /*** 提交一个会话执行*/void commit(); /*** 回滚一个会话执行*/void rollback(); /*** 取消一个正在执行中的会话* * @param sponsor* 如果发起者为null,则表示由自己发起。*/void cancel(FrontendConnection sponsor); /*** 终止会话,必须在关闭源端连接后执行该方法。*/void terminate();}
下面我们着重研究它的实现类NonBlockingSession: 首先,取得源端连接方法FrontendConnection getSource();,其实就是NonBlockingSession在创建时就已绑定一个连接,谁会调用这个方法取得源端链接呢? 可以发现,主要有各种查询的handler还有SQLengine会去调用。因为处理无论返回什么结果,都需要返回给源端。 int getTargetCount();取得当前目标端数量。根据目标端的数量不同会用不同的handler处理转发SQL和合并结果。
@Overridepublic void execute(RouteResultset rrs, int type) { // 清理之前处理用的资源clearHandlesResources(); if (LOGGER.isDebugEnabled()) {StringBuilder s = new StringBuilder();LOGGER.debug(s.append(source).append(rrs).toString() + " rrs ");} // 检查路由结果是否为空RouteResultsetNode[] nodes = rrs.getNodes(); if (nodes == null || nodes.length == 0 || nodes[0].getName() == null|| nodes[0].getName().equals("")) { //如果为空,则表名有误,提示客户端source.writeErrMessage(ErrorCode.ER_NO_DB_ERROR, "No dataNode found ,please check tables defined in schema:"+ source.getSchema()); return;} //如果路由结果个数为1,则为单点查询或事务if (nodes.length == 1) { //使用SingleNodeHandler处理单点查询或事务singleNodeHandler = new SingleNodeHandler(rrs, this); try {singleNodeHandler.execute();} catch (Exception e) {LOGGER.warn(new StringBuilder().append(source).append(rrs), e);source.writeErrMessage(ErrorCode.ERR_HANDLE_DATA, e.toString());}} else { //如果路由结果>1,则为多点查询或事务boolean autocommit = source.isAutocommit();SystemConfig sysConfig = MycatServer.getInstance().getConfig().getSystem(); //mutiNodeLimitType没有用。。。int mutiNodeLimitType = sysConfig.getMutiNodeLimitType(); //使用multiNodeHandler处理多点查询或事务multiNodeHandler = new MultiNodeQueryHandler(type, rrs, autocommit, this); try {multiNodeHandler.execute();} catch (Exception e) {LOGGER.warn(new StringBuilder().append(source).append(rrs), e);source.writeErrMessage(ErrorCode.ERR_HANDLE_DATA, e.toString());}}}
每次一个Session执行SQL时,会先清理handler使用的资源。SingleNodeHandler与multiNodeHandler之后会讲。这里的handler我们之后会在每个模块去讲,Session之后也还会提到,敬请期待
免费体验云安全(易盾)内容安全、验证码等服务
更多网易技术、产品、运营经验分享请点击。
相关文章:
【推荐】 Android TV 开发(5)
【推荐】 分布式存储系统可靠性系列三:设计模式
转载于:https://www.cnblogs.com/zyfd/p/9894735.html
数据库路由中间件MyCat - 源代码篇(7)相关推荐
- 数据库路由中间件MyCat - 源代码篇(17)
此文已由作者张镐薪授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. 调用processInsert(sc,schema,sqlType,origSQL,tableName,pr ...
- 数据库路由中间件MyCat - 源代码篇(15)
此文已由作者张镐薪授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. public static void handle(String stmt, ServerConnectio ...
- 数据库路由中间件MyCat - 使用篇(1)
此文已由作者张镐薪授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. 基本概念 直接介绍概念太枯燥了,还是拿个和背景篇相似的例子介绍 业务场景:客户完成下单,快递员接受并更新运单 ...
- 数据库路由中间件MyCat - 使用篇(2)
此文已由作者张镐薪授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. 基本概念 3. 分片 3.1 分片节点(dataNode) 表被水平切分后,每个分片表所在的数据库就是一个分 ...
- 深入理解数据库分片中间件MyCat实现原理
作者:田超凡 原创博文,严禁复制转载,仿冒必究 1 海量数据的存储问题 如今随着互联网的发展,数据的量级也是撑指数的增长,从GB到TB到PB.对数据的各种操作也是愈加的困难,传统的关系性数据库已经无法 ...
- MyCat - 使用篇(1)
数据库路由中间件MyCat - 使用篇(1) 基本概念 直接介绍概念太枯燥了,还是拿个和背景篇相似的例子介绍 业务场景:客户完成下单,快递员接受并更新运单状态,客户可以随时查看运单状态的任务.一票快 ...
- 开源分布式数据库中间件MyCat架构简介(二)——基于MyCat的分库分表,读写分离,水平切分和垂直切分实现原理
目录 前言 基于MyCat的分库分表,读写分离,水平切分和垂直切分实现原理 一.关于Mycat 二.Mycat 实现原理 三.MyCat 应用场景 四.MyCat 未来展望 五.Mycat 中相关概念 ...
- 数据库中间件MyCat学习总结(1)——MyCat入门简介
为什么需要MyCat? 虽然云计算时代,传统数据库存在着先天性的弊端,但是NoSQL数据库又无法将其替代.如果传统数据易于扩展,可切分,就可以避免单机(单库)的性能缺陷. MyCat的目标就是:低成本 ...
- 分布式数据库中间件 MyCat 安装及使用
分布式数据库中间件 MyCat 安装及使用 关于 MyCat 的铺垫文章已经写了三篇了: MySQL 只能做小项目?松哥要说几句公道话! 北冥有 Data,其名为鲲,鲲之大,一个 MySQL 放不下! ...
最新文章
- 关于tinymce的一些记事
- F1~F12在Windows系统中的作用
- [云炬创业基础笔记]第七张创业团队测试3
- STL的deque容器
- 06_pandas入门教程,引包,使用DataFrame和Series做一些事情
- Centos 7 文件管理基础命令
- android textview 白色,android – AutoCompleteTextview默认情况下,颜色设置为白色
- 一部分 数据 迁移_从虚机到容器,知名架构师告诉你如何平滑进行业务迁移
- 篇章级关系抽取(Doc-RE)论文列表整理
- 使用OBS录屏神器,完美录制第二块屏幕。
- Oracle表空间查询
- 12月29日每日一题
- 有趣又实用的4款微信小程序,有了它们,APP都要靠边站!
- eSpeak TTS 中英文真人发音引擎
- 2022-2028年中国数位板行业发展现状调查及市场分析预测报告
- 《流畅的python》这本确实老辣
- 增量式PID控制算法及仿真
- 清华数据女神评选结果:第一竟然是叉院大神...?
- 使用TKMapper主键的坑
- 《黑头人》(暂定)开发日志
热门文章
- 你不知道的javascript事件
- NSIndexPath类
- [置顶]Java Web学习总结(25)——MyEclipse+Tomcat+MAVEN+SVN项目完整环境搭建...
- 未能为数据库 '*'中得对象'*'分配空间,因文件组'PRIMARY'已满
- sql server left join 重复数据原因图
- 包含实时功能的ASP.NET系统结构
- 【数据平台】基于pyhs2库Python作为client driver连接HiveServer
- 对程序错误的处理——Windows核心编程学习手札之一
- latex下的表格处理
- 安装opencv3.0.0与配置Visual studio 2008