数据同步的解决方案Canal

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 [email protected]'%' 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）启动服务：

[[email protected] 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项目使用

监听器类实现

 

自定义监听