概述

canal可以用来监控数据库数据的变化，从而获得新增数据，或者修改的数据。

canal是应阿里巴巴存在杭州和美国的双机房部署，存在跨机房同步的业务需求而提出的。

阿里系公司开始逐步的尝试基于数据库的日志解析，获取增量变更进行同步，由此衍生出了增量订阅&消费的业务。

Canal工作原理

Canal模拟mysql slave的交互协议，伪装自己为mysqlslave，向mysql master发送dump协议

mysql master收到dump请求，开始推送binary log给slave（也就是canal）

canal解析binary log对象（原始为byte流）

同步实现

canal需要使用到mysql

• 使用root账号创建用户并授予权限

• create user canal@'%' IDENTIFIED by 'canal'; GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT,SUPER ON . TO 'canal'@'%'; FLUSH PRIVILEGES;

canal容器安装

下载镜像：

• docker pull docker.io/canal/canal-server

容器安装

• docker run -p 11111:11111 --name canal -d docker.io/canal/canal-server

修改核心配置文件

• 进入容器,修改核心配置canal.properties 和instance.properties，canal.properties 是canal自身的配置，instance.properties是需要同步数据的数据库连接配置。

canal微服务

当用户执行 数据库的操作的时候，binlog 日志会被canal捕获到，并解析出数据。我们就可以将解析出来的数据进行同步到redis中即可。

思路：创建一个独立的程序，并监控canal服务器，获取binlog日志，解析数据，将数据更新到redis中。这样广告的数据就更新了。