mysql +cobar_Cobar源码解析(一)
简介
当业务的数据量和访问量急剧增加的情况下,我们需要对数据进行水平拆分,从而降低单库的压力,并且数据的水平拆分需要对业务透明,屏蔽掉水平拆分的细节。并且,前端业务的高并发会导致后端的数据库连接过多,从而DB的性能低下。
Cobar就是解决这些问题的一款分库分表中间件,Cobar以proxy的形式位于前端应用和后端数据库之间,Cobar对前端暴露的接口是MySQL通信协议,其将前端传输过来的SQL语句按照sharding规则路由到后端的数据库实例上,再合并多个实例返回的结果,从而模拟单库下的数据库行为。
Cobar的使用方法就不多介绍了,本文的主要内容是剖析Cobar的源代码。
Cobar的前端连接模型
结构图如下:
我们先来看CobarServer的代码:
private CobarServer() {
this.config = new CobarConfig();
SystemConfig system = config.getSystem();
MySQLLexer.setCStyleCommentVersion(system.getParserCommentVersion());
this.timer = new Timer(NAME + "Timer", true);
this.initExecutor = ExecutorUtil.create("InitExecutor", system.getInitExecutor());
this.timerExecutor = ExecutorUtil.create("TimerExecutor", system.getTimerExecutor());
this.managerExecutor = ExecutorUtil.create("ManagerExecutor", system.getManagerExecutor());
this.sqlRecorder = new SQLRecorder(system.getSqlRecordCount());
this.isOnline = new AtomicBoolean(true);
this.startupTime = TimeUtil.currentTimeMillis();
}
上面是CobarServer的构造函数,它的限定是private的。
private static final CobarServer INSTANCE = new CobarServer();
public static final CobarServer getInstance() {
return INSTANCE;
}
而CobarServer又有一个私有的静态变量INSTANCE,以及获取这个私有静态变量的静态方法,显然,这是一个单例设计模式,使程序运行的时候全局只有一个CobarServer对象。
我们再来看CobarServer的startup()方法,此方法中构造了一个NIOAcceptor(绑定服务器端口,接受客户端的连接),
server = new NIOAcceptor(NAME + "Server", system.getServerPort(), sf);
构造了一个接收前端连接的非阻塞Acceptor,让我们在来看NIOAcceptor类的代码。
public final class NIOAcceptor extends Thread {
private static final Logger LOGGER = Logger.getLogger(NIOAcceptor.class);
private static final AcceptIdGenerator ID_GENERATOR = new AcceptIdGenerator();
private final int port;
private final Selector selector;
private final ServerSocketChannel serverChannel;
private final FrontendConnectionFactory factory;
private NIOProcessor[] processors;
private int nextProcessor;
private long acceptCount;
public NIOAcceptor(String name, int port, FrontendConnectionFactory factory) throws IOException {
super.setName(name);
this.port = port;
this.selector = Selector.open(); # 生成选择器
this.serverChannel = ServerSocketChannel.open();
this.serverChannel.socket().bind(new InetSocketAddress(port)); # 绑定服务器端口
this.serverChannel.configureBlocking(false); # 设置非阻塞模式
this.serverChannel.register(selector, SelectionKey.OP_ACCEPT); # 监听ACCEPT事件,
this.factory = factory; # 设置前端连接的工厂
}
}
以上的代码都是NIO编程中很常见的操作。下面我们看run()方法,
@Override
public void run() {
final Selector selector = this.selector;
for (;;) {
++acceptCount;
try {
selector.select(1000L); # select操作是阻塞的,若没有监听到相应的事件,则一直阻塞,直到超过1000毫秒,则返回
Set keys = selector.selectedKeys();
try {
for (SelectionKey key : keys) {
if (key.isValid() && key.isAcceptable()) {
accept(); # 接受连接,这个方法很关键
} else {
key.cancel();
}
}
} finally {
keys.clear();
}
} catch (Throwable e) {
LOGGER.warn(getName(), e);
}
}
}
以上的run方法也是常见的NIO中监听事件的套路,其中accept()方法是定义的私有函数,accept方法是为了将channel与selector绑定,代码如下,
private void accept() {
SocketChannel channel = null;
try {
channel = serverChannel.accept(); # 为新的连接分配socket
channel.configureBlocking(false); # 设置为非阻塞模式
# factory将channel进行封装,进行相应的设置,返回一个FrontendConnection,connection本质上就是一个封装好的channel
FrontendConnection c = factory.make(channel);
c.setAccepted(true);
c.setId(ID_GENERATOR.getId()); # 为连接设置ID
NIOProcessor processor = nextProcessor(); # 为连接分配processor,NIOAcceptor中包含了一个NIOProcessor数组,分配的策略即根据下标不断后移,到达数组末尾后又从数组的起始位置开始分配
c.setProcessor(processor);
# 回调NIOProcessor的postRegister方法,而processor的postRegister调用的是NIOReactor类的postRegister方法
processor.postRegister(c);
} catch (Throwable e) {
closeChannel(channel);
LOGGER.warn(getName(), e);
}
}
让我来看NIOProcessor的postRegister方法,
public void postRegister(NIOConnection c) {
reactor.postRegister(c);
}
NIOProcessor类中定义了一个NIOReactor类的成员变量reactor,而postRegister调用的是NIOReactor的postRegister方法。下面让我们来看NIOReactor的postRegister代码,
final void postRegister(NIOConnection c) {
# 只是先将前端连接插入R线程的阻塞队列中,并没有立刻将channel与selector进行绑定
reactorR.registerQueue.offer(c);
# 唤醒R线程的selector,若之前的select操作没有返回的话则立即返回
reactorR.selector.wakeup();
}
既然channel与selector没有立刻进行绑定,那它们是什么时候绑定的呢?我们来看NIOReactor中内部类R的run()方法,
@Override
public void run() {
final Selector selector = this.selector;
for (;;) {
++reactCount;
try {
selector.select(1000L);
# 将connection与selector进行绑定
register(selector);
Set keys = selector.selectedKeys();
try {
for (SelectionKey key : keys) {
Object att = key.attachment();
if (att != null && key.isValid()) {
int readyOps = key.readyOps();
if ((readyOps & SelectionKey.OP_READ) != 0) {
read((NIOConnection) att);
} else if ((readyOps & SelectionKey.OP_WRITE) != 0) {
write((NIOConnection) att);
} else {
key.cancel();
}
} else {
key.cancel();
}
}
} finally {
keys.clear();
}
} catch (Throwable e) {
LOGGER.warn(name, e);
}
}
}
在run方法中,当select方法返回的时候,就会进行channel和selector的绑定,因为当connection插入到阻塞队列中的时候,会对selector进行wakeup(),即select(1000L)方法会立即返回,所以不必担心channel会卡一秒钟才会和selector进行绑定。
我们再来看R线程的register方法,
private void register(Selector selector) {
NIOConnection c = null;
# 将R线程阻塞队列中的所有连接都轮询取出,与selector进行绑定
while ((c = registerQueue.poll()) != null) {
try {
c.register(selector);
} catch (Throwable e) {
c.error(ErrorCode.ERR_REGISTER, e);
}
}
}
总结
关于NIOAcceptor为何先将connection放入Reactor的阻塞队列,而不是直接绑定。笔者的观点是,如果由NIOAcceptor负责绑定则会造成锁竞争,selector的register方法会争用锁,会导致NIOAcceptor线程和R、W线程竞争selector的锁,若acceptor中处理绑定connection的逻辑,则NIOAcceptor就不能快速地处理大量的连接,整个系统的吞吐就会降低。所以Cobar中的设计是将connection的绑定放到R线程的阻塞队列中去,让R线程来完成connection的绑定工作。
图就随意看看吧-.-,有点丑。
以上。
原文链接
mysql +cobar_Cobar源码解析(一)相关推荐
- mysql驱动源码解析_mysql驱动源码分析
注: 本系列文章使用JDK1.5 数据库驱动版本 mysql-connector-java-5.1.8b JAVA连接数据库是其众多功能中的一部分,主要有两种方式连接DataBase: 一种是采用JD ...
- mysql 网络io_分布式 | DBLE 网络模块源码解析(一):网络 IO 基础知识
作者:路路 热爱技术.乐于分享的技术人,目前主要从事数据库相关技术的研究. 本文来源:原创投稿 *爱可生开源社区出品,原创内容未经授权不得随意使用,转载请联系小编并注明来源. 前言 对于计算机学科来说 ...
- MySQL核心参数含义的源码解析
引言 你访问的网站,大部分使用Apache服务器;你访问的网站,大部分使用Linux或BSD操作系统:你访问的网站,大部分使用MySQL数据库;你提交DNS域名查询请求大多由BIND服务器分析处理;你 ...
- python flask源码解析_用尽洪荒之力学习Flask源码
[TOC] 一直想做源码阅读这件事,总感觉难度太高时间太少,可望不可见.最近正好时间充裕,决定试试做一下,并记录一下学习心得. 首先说明一下,本文研究的Flask版本是0.12. 首先做个小示例,在p ...
- Spring Boot Profile使用详解及配置源码解析
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 作者 | 二师兄 来源 | 程序新视界 在实践的过程中我 ...
- sharding-jdbc源码解析之sql解析
2019独角兽企业重金招聘Python工程师标准>>> 说在前面 本文转自"天河聊技术"微信公众号 本次介绍的是sharding-jdbc的源码解析部分的sql解 ...
- MyBatis源码- SqlSession门面模式 selectList 源码解析
文章目录 Pre 工程概览 pom.xml mybatis-config.xml UserMapper 测试类 selectList 源码解析 附 SQL log4j.properties app.p ...
- mysql dba系统学习(2)了解mysql的源码目录及源文件
了解mysql的源码目录 包括客户端代码,服务端代码,测试工具和其他库文件 Mysql源码结构 Bdb 伯克利DB表引擎 BUILD 构建工程的脚本 Client 客户端 Cmd-line-utils ...
- dubbo源码解析-集群容错架构设计
前言 本来是想把整个dubbo源码解析一次性弄完,再做成一个系列来发布的,但是正巧最近有位好朋友要去杭州面试,就和我交流了一下.本着对dubbo源码略有心得的心态,在交流过程中也发表了个人的一些粗劣的 ...
- Mybatis运行原理及源码解析
Mybatis源码解析 一.前言 本文旨在mybatis源码解析,将整个mybatis运行原理讲解清楚,本文代码地址: https://github.com/lchpersonal/mybatis-l ...
最新文章
- android联动动画,利用 CollapsingToolbarLayout 完成联动的动画效果
- 【黑金视频连载】FPGA NIOSII视频教程(12)--时间戳定时器实验
- python第三方库安装方法-Python第三方库安装
- HDU 1874 畅通工程续 (Dijkstra , Floyd , SPFA, Bellman_Ford 四种算法)
- c# 配置文件App.config操作类库
- 我的电脑能装苹果吗?
- 深度学习:智能时代的核心驱动力量
- 推荐一款好用的Bootstrap后台管理框架——Ace Admin
- SysLoad3.exe木马病毒地分析及清除方法
- 基因工程-5-目的基因导入受体细胞的方法
- 谈谈反向代理Nginx
- JAVA 实现 名单按姓氏笔画为序排列
- mysql实现经纬度查询并按距离排序
- 浅谈如何做好项目管理
- 最全app上传渠道入口 拿去即用
- 计算机英语 自我介绍,计算机专业英文自我介绍
- (linux-x86-ARM)麒麟V10安装DBeaver21.3通用的数据库管理工具和 SQL 客户端
- 谷歌学术403异常处理
- 计算机术语CAE是指,计算机应用基础 1
- unity探索者之Shader Graph所有节点详解-Utility篇
热门文章
- 南大周志华、俞扬、钱超最新力作:演化学习:理论与算法进展一书导读
- 计算机组装与维修第3版,计算机组装与维护(第3版)
- PostgreSQL13.1-CN-v1.0中文手册.chm下载
- 小鸡模拟器android,安卓小鸡模拟器运行总结~
- 系统之家 linux下载,迅雷Linux版下载_迅雷Linux版官方版1.0.0.1 - 系统之家
- 批量发送邮件的软件——邮件群发机器人
- 【UCHome二次开发】UCHome模板语法…
- e会学c语言程序设计基础网课答案,C程序设计(双语版)习题答案
- 多系统对接的实现方案
- iOS视频录制及gif图片制作