没有合适的资源?快使用搜索试试~ 我知道了~
首页Canal集群化部署.docx
资源详情
资源评论
资源推荐

Canal 集群化部署
Canal 介绍
名称:
译意: 水道管道沟渠
语言: 纯 开发
定位: 基于数据库增量日志解析,提供增量数据订阅消费,目前主要支持了
关键词:
基于日志增量订阅&消费支持的业务
数据库镜像
数据库实时备份
! 多级索引 "卖家和买家各自分库索引#
$ %&
' 业务 % 刷新
( 价格变化等重要业务消息
)
工作原理
mysql 主备复制实现

从上层来看,复制分成三步:
将改变记录到二进制日志"#中(这些记录叫做二进制日志事件,
,可以通过 %* 进行查看);
将 的 拷贝到它的中继日志"#;
! 重做中继日志中的事件,将改变反映它自己的数据。
canal 的工作原理
原理相对比较简单:
模拟 的交互协议,伪装自己为 ,向 发送
& 协议
收到 & 请求,开始推送 给 "也就是 #
! 解析 对象"原始为 流#

canal 配置加载
配置方式有两种:
+,-.: 基于 管理的配置方式,目前 内部配
置使用这种方式。大家可以实现 ,,/,,连接各自的管理系统,即可完成接入。
0,-.:基于本地 1 的配置方式,目前开源版本已经自带
该功能所有代码,建议使用
Instance.xml 配置文件
目前默认支持的 1 有以下几种:
1
&21
! 1
在介绍 配置之前,先了解一下 如何维护一份增量订阅消费的关系信息:
解析位点 " 模块会记录,上一次解析 到了什么位置,对应组件为:
,34+#
消费位点 " 在接收了客户端的 后,就会记录客户端提交的最后位点,对应的
组件为:,++#
对应的两个位点组件,目前都有几种实现:

5"1 中使用#
6
1&5
&55"&21 中使用,集合了 67 模式,先写内存,定
时刷新数据到 6 上#
1 介绍:
55所有的组件"88#都选择了内存版模式,记录位点的都选择了 模式,重启后
又会回到初始位点进行解析
55特点:速度最快,依赖最少"不需要 6#
55场景:一般应用在 ,或者是出现问题后,进行数据分析的场景,不应该将其应用于生产环
境
5
&21 介绍:
55 选择了内存模式,其余的 依赖的位点管理选择了持久化模式,目前持久化的方式主
要是写入 6,保证数据集群共享5
55特点:支持 9:
55场景:生产环境,集群化部署5
5
1 介绍:
55主要针对需要进行多库合并时,可以将多个物理 合并为一个逻辑 ,提供客户端访
问。
55场景:分库业务。 比如产品数据拆分了 $ 个库,每个库会有一个 ,如果不用 ,业务
上要消费数据时,需要启动 $ 个客户端,分别链接 $ 个 实例。使用 后,可以在
上合并为一个逻辑 ,只需要启动 个客户端,链接这个逻辑 即可5
5
1 设计初衷:
5允许进行自定义扩展,比如实现了基于数据库的位点管理后,可以自定义一份自己的 1,
整个 设计中最大的灵活性在于此
术语
剩余19页未读,继续阅读



















wodetiankong516
- 粉丝: 31
- 资源: 11
上传资源 快速赚钱
我的内容管理 收起
我的资源 快来上传第一个资源
我的收益
登录查看自己的收益我的积分 登录查看自己的积分
我的C币 登录后查看C币余额
我的收藏
我的下载
下载帮助

会员权益专享
最新资源
- ARM Cortex-A(armV7)编程手册V4.0.pdf
- ABB机器人保养总结解析.ppt
- 【超详细图解】菜鸡如何理解双向链表的python代码实现
- 常用网络命令的使用 ipconfig ping ARP FTP Netstat Route Tftp Tracert Telnet nslookup
- 基于单片机控制的DC-DC变换电路
- RS-232接口电路的ESD保护.pdf
- linux下用time(NULL)函数和localtime()获取当前时间的方法
- Openstack用户使用手册.docx
- KUKA KR 30 hA,KR 60 hA机器人产品手册.pdf
- Java programming with JNI
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈



安全验证
文档复制为VIP权益,开通VIP直接复制

评论0