Canal监听MySQL的实现步骤 目录 1.Mysql数据库开启binlog模式 2.Docker下Canal容器安装 3.Canal Client项目搭建 1.Mysql数据库开启binlog模式 注意:Mysql容器,此处Mysql版本为5.7 #进入容器 docker exec -it mysql /bin/bash #进入配置目录 cd /etc/mysql/mysql.conf.d #修改配置文件
目录
- 1、Mysql数据库开启binlog模式
- 2、Docker下Canal容器安装
- 3、Canal Client项目搭建
1、Mysql数据库开启binlog模式
注意:Mysql容器,此处Mysql版本为5.7
(1) 修改mysqld.cnf配置文件,添加如下配置:
(2) 创建账号 用于测试使用,使用root账号创建用户并授予权限
(3) 重启mysql容器
2、Docker下Canal容器安装
(1)拉取canal镜像
(2)创建Canal容器
(3)进入容器,修改核心配置canal.properties 和instance.properties,canal.properties 是canal自身的配置,instance.properties是需要同步数据的数据库连接配置。
修改canal.properties的id,不能和mysql的server-id重复,如下图:
修改instance.properties,配置数据库连接地址:
这里的canal.instance.filter.regex
有多种配置,如下:
可以参考地址如下: https://github.com/alibaba/canal/wiki/AdminGuide
mysql 数据解析关注的表,Perl正则表达式.
多个正则之间以逗号(,)分隔,转义符需要双斜杠(\\)
常见例子:
1. 所有表:.* or .*\\..*
2. canal schema下所有表: canal\\..*
3. canal下的以canal打头的表:canal\\.canal.*
4. canal schema下的一张表:canal.test1
5. 多个规则组合使用:canal\\..*,mysql.test1,mysql.test2 (逗号分隔)
注意:此过滤条件只针对row模式的数据有效(ps. mixed/statement因为不解析sql,所以无法准确提取tableName进行过滤)
配置完成后,设置开机启动,并记得重启canal。
3、Canal Client项目搭建
(1)引入依赖
注意:canal依赖stater在中央仓库是不存在的,需要手动放进本地仓库或者你公司里面的nexus
这里以放进本地仓库为例:
- 首先解压spring-boot-starter-canal-master.zip
- 在spring-boot-starter-canal-master\starter-canal文件夹下执行mvn clean install
- 此时在本地仓库就会存在jar包
- 引入依赖
(2)启动类编写
(3)监听器编写
到此就可以实现Canal监听Mysql
项目gitee地址:test-canal
详情可以查看:
https://github.com/alibaba/canal (阿里官方)
https://github.com/alibaba/canal/wiki/AdminGuide (阿里官方)
https://github.com/chenqian56131/spring-boot-starter-canal (自制starter)
到此这篇关于Canal监听MySQL的实现步骤的文章就介绍到这了,更多相关Canal监听MySQL内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!