Canal实现数据同步的原理:
1.是根据模拟mysql slave的主从交互协议,伪装自己是mysql slave,向mysql master发送dump请求。
2.mysql master收到dump请求后,开始推送 binary log给canal
3.canal解析binary log对象(原始byte流)处理。
mysql开启binlog模式
(1)查看当前mysql是否开启binlog模式。
SHOW VARIABLES LIKE '%log_bin%'
如果log_bin的值为OFF是未开启,为ON是已开启。
(2)修改/etc/my.cnf 需要开启binlog模式。
[mysqld] log-bin=mysql-bin binlog-format=ROW server_id=1
修改完成之后,重启mysqld的服务。
(3) 进入mysql
mysql -h localhost -u root -p
(4)创建账号 用于测试使用
使用root账号创建用户并授予权限
create user canal@'%' IDENTIFIED by 'canal'; GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT,SUPER ON *.* TO 'canal'@'%'; FLUSH PRIVILEGES;
canal服务端安装配置
(1)下载地址canal
https://github.com/alibaba/canal/releases/tag/canal-1.0.24
(2)下载之后 上传到linux系统中,解压缩到指定的目录/usr/local/canal
解压缩之后的目录结构如下:
(3)修改 exmaple下的实例配置
vi conf/example/instance.properties
修改如图所示的几个参数。
一定要注释掉下面这个参数,这样就会扫描全库
#canal.instance.defaultDatabaseName =
(3)启动服务:
[root@localhost canal]# ./bin/startup.sh
(4)查看日志:
cat /usr/local/canal/logs/canal/canal.log
这样就表示启动成功了。
SpringBoot集成Canal
我们这里使用的一个开源的项目,它实现了springboot与canal的集成。比原生的canal更加优雅。
https://github.com/chenqian56131/spring-boot-starter-canal
下载后,本地进入
cmd进入目录,mvn insrall,加载pom坐标。
Springboot项目使用
监听器类实现
自定义监听