一、认识Canal
canal-github仓库
Canal介绍：Canal 是用 Java 开发的基于数据库增量日志解析，提供增量数据订阅&消费的中间件（数据库同步需要阿里的 Otter 中间件，基于 Canal）。
Canal背景：阿里巴巴 B2B 公司，因为业务的特性，卖家主要集中在国内，买家主要集中在国外，所以衍生出了同步杭州和美国异地机房的需求，从 2010 年开始，阿里系公司开始逐步的尝试基于数据库的日志解析，获取增量变更进行同步，由此衍生出了增量订阅&消费的业务。
Canal原理：自己伪装成 Slave，假装从 Master 复制数据，实际上就是主从复制的一个流程（通过增量复制来不断的进行订阅消费数据）
主从复制原理：
1）Master 主库将改变记录，写到二进制日志(Binary Log)中； 2）Slave 从库向 MySQL Master 发送 dump 协议，将 Master 主库的 binary log events 拷贝到它的中继日志(relay log)； 3）Slave 从库读取并重做中继日志中的事件，将改变的数据同步到自己的数据库。
binlog的分类：statement、row、mixed。在canal配合mysql时，mysql需要配置binlog模式为row(推荐)。
statement：记录每一次执行写操作的sql语句，但是可能会产生数据不一致，例如sql语句update tt set create_date=now()，其中就有now()函数，若是其他从结点进行同步就会出现问题。
row：记录每次操作后每行记录的变化，直接记录的是数据，能够保持数据的一致性，缺点就是比较占空间。
mixed：statement 的升级版，默认实质还是statement，对于uuid()、auto_increment会使用row模式处理，还算是比较智能，但是极个别情况还是会造成数据不一致，并且由于默认依旧是statement，实际上就是sql+数据形式。
常用场景：
1、异地数据库的同步。
2、更新缓存。（例如以往的对应某些数据库表字段会设置缓存，处理更新数据库时的字段对缓存进行更新，在高并发的情况下会造成数据一致性问题，此时可以使用canal）
3、抓取数据更新，来进行实时数据分析。
二、安装配置Canal
当前安装的MySQL版本：5.7.36，Canal版本是1.1.5。
Docker的安装可见：快速使用Docker部署MySQL、Redis、Nginx
2.1、Docker快速安装MySQL 5.7.56
canal对于mysql的提前配置文档：canal-quickstart
下载mysql：
docker pull mysql:5.7.36
启动mysql服务：
# 首先运行这个容器（目的是拷贝其中的配置文件） docker run --name mysql5736 \ -p 3306:3306 \ -e MYSQL_ROOT_PASSWORD=root \ -d mysql:5.7.36 # 复制mysql5.7.36的配置文件（注意：若是你使用不同版本的对应位置要进行修改） docker cp mysql5736:/etc/mysql/mysql.conf.d/mysqld.cnf /mydata/mysql/conf
复制的配置文件如下：
# 配置文件中添加如下内容，注意是在在[mysqld]目录中 log-bin=mysql-bin # 开启 binlog binlog-format=ROW # 选择 ROW 模式 server-id=1 # 配置 MySQL replaction 需要定义，不要和 canal 的 slaveId 重复
接着我们进行下面真正启动容器命令：
# 删除之前启动的docker容器（我们需要添加一些新的启动项参数） docker rm -f mysql5736 # 运行docker容器命令 # --name mysql5736：容器名为mysql5736 # /etc/localtime：时间同步 # /mydata/mysql/conf：同步配置文件（这个是关键，上面配置的内容就会覆盖容器中的配置文件） # /mydata/mysql/log：同步日志目录 # /mydata/mysql/data：同步mysql的一些文件内容（对数据进行备份） # MYSQL_ROOT_PASSWORD=root：默认root的密码是root docker run --name mysql5736 \ -p 3306:3306 \ -v /etc/localtime:/etc/localtime \ -v /mydata/mysql/conf:/etc/mysql/mysql.conf.d \ -v /mydata/mysql/log:/var/log/mysql \ -v /mydata/mysql/data:/var/lib/mysql \ -e MYSQL_ROOT_PASSWORD=root \ -d mysql:5.7.36
接下来我们进入到mysql的命令行模式来给root账号授权所有ip能够访问，授权好之后我们可以用navicat来进行连接：
# 使用mysql容器中的命令行 docker exec -it mysql5736 /bin/bash # 使用MySQL命令打开客户端： mysql -uroot -proot --default-character-set=utf8 # 接着创建一个账户，该账号所有ip都能够访问 grant all privileges on *.* to 'root' @'%' identified by 'root'; # 刷新生效 FLUSH PRIVILEGES;
创建canal账号并去授权 canal ，为了之后canal进行连接mysql的账户：
-- 创建用户名密码都是canal的账号 CREATE USER canal IDENTIFIED BY 'canal'; -- 为canal进行授权读取、client从、客户端权限 grant SELECT, REPLICATION SLAVE, REPLICATION CLIENT on *.* to 'canal'@'%'; -- 刷新生效 FLUSH PRIVILEGES;
注意：一定要查看bin-log是否已经开启，下面的命令我们可以去进行一个查看当前mysql的信息：
# 查看binlog日志是否开启 show variables like 'log_%'; # 查看主结点当前状态 show master status
此时我们也可以在对应的/mydata/mysql/data中查看到bin-log日志情况：
2.2、Docker快速安装Canal 1.1.5
Canal下载地址
tar压缩包安装：官方文档
Docker安装的官方文档：Canal Docker QuickStart
拉取Canal的镜像文件：
docker pull canal/canal-server:v1.1.5
首次启动容器，并拷贝配置文件：
# 启动容器（目的是拷贝配置文件） docker run --name canal115 \ -p 11111:11111 \ -id canal/canal-server:v1.1.5 # 提前创建 /mydata/canal/conf目录，接着来执行拷贝配置文件命令 docker cp canal115:/home/admin/canal-server/conf/example/instance.properties /mydata/canal/conf/
复制好配置文件之后，我们来对这个properties进行修改，下面的内容在配置文件中若是注释状态就打开并修改：
# 从机id（与之前mysql配置的id不同） canal.instance.mysql.slaveId=2 # 指定ip地址也是可以的，查看方式docker inspect --format '{{ .NetworkSettings.IPAddress }}' mysql # 容器进行了--link，这里mysql5736就是对应的服务地址 canal.instance.master.address=mysql5736:3306 # 用户名与密码 canal.instance.dbUsername=canal canal.instance.dbPassword=canal # 匹配全部数据库 canal.instance.filter.regex = .\*\\\\..\* canal.mq.topic=example # 目的地队列
执行命令启动canal容器：
# 删除原先的canal服务 docker rm -f canal115 # 启动canal服务 # -i：让容器的标准输入保持打开（特别特别重要，注意不要是-d，一定要加上i） docker run --name canal115 \ -p 11111:11111 \ -v /mydata/canal/conf/instance.properties:/home/admin/canal-server/conf/example/instance.properties \ --link mysql5736:mysql5736 \ -id canal/canal-server:v1.1.5
启动完canal之后，去查看canal实例的日志内容，判断是否已经成功连接到mysql：
# 进入到docker容器 docker exec -it canal115 /bin/bash # 打开日志文件 cd canal-server/logs/example/ # 查看日志文件的最后100行内容 tail -100 example.log
下面是连接成功的情况：
另外贴出连接失败情况（折腾了一天了快，最后终于解决）：
BioSocketChannelPool默认超时时间不够，导致连接出错 、Docker整合canal 踩坑实录
docker安装并使用阿里巴巴Canal(含安装MySQL、开启binlog、Java代码、填坑经验)
解决方案：
1、查看用户名、密码是否由权限。
2、docker运行canal命令检查是否是-id，注意如果是-d我也会出现上面报错！！！
这个解决方案并不是搜索博客解决的，而是看一个实战项目教程，我通过看别人实际能够连接的案例执行命令，找到了这个问题，一定要注意细节！！！
