简介
Canal是模拟Mysql主从复制原理。将自己伪装成Slave。向主库发起dump协议，拿到bin_log日志，解析之后对数据做相关操作
????
mysql配置
[mysqld]
server_id=1
# 开启binlog
log-bin=mysql-bin
# 选择ROW模式（三种模式,Statement:日志文件小,row:日志文件大,但是粒度细，mixed:混合模式）
binlog_format=ROW
# 需要开启binlog的数据库（如果不指定，表示所有mysql里面的库都开启binlog）
binlog-do-db=canal-test
修改后重启mysql服务让配置生效
linux: sudo systemctl restart mysql
windows: net stop mysql , net start mysql
// 查看是否开启binlog
SHOW VARIABLES like 'log_bin'
// 查看binlog信息
SHOW BINARY LOGS
为canal创建用户然后赋权
# 创建一个用户叫canal密码为admin123
CREATE USER 'canal'@'%' IDENTIFIED BY 'admin123';
# 为canal用户赋予查询，副本，副本客户端权限
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';
# 刷新权限
FLUSH PRIVILEGES;
安全起见只给该用户select的权限，insert update delete都不需要给
下载canal
修改conf/example/instance.properties
# 该项相当于sliverid 不能和之前mysql的server_id一样
canal.instance.mysql.slaveId=80
# 监控哪个mysql地址,根据实际需求更改
canal.instance.master.address=127.0.0.1:3306
# 刚才建的canal用户的用户名密码，如果使用root这里就填root和root密码
canal.instance.dbUsername=canal
canal.instance.dbPassword=admin123
......
# (因为要整合rabbitmq) 该项为路由键
canal.mq.topic=queue.order
修改conf/canal.properties
# tcp, kafka, rocketMQ, rabbitMQ, pulsarMQ
canal.serverMode = rabbitMQ
##################################################
######### RabbitMQ #############
##################################################
# 这里为rabbitmq地址 不能带端口
rabbitmq.host =192.168.1.107
rabbitmq.virtual.host =/
# 发送到哪个交换机，这个交换机需要提前建好
rabbitmq.exchange =exchange.direct.user
# rabbitmq的账号密码，guest不行
rabbitmq.username =root
rabbitmq.password =root123
rabbitmq.deliveryMode =
canal.serverMode是支持的中间件，默认tcp, 我需要整合rabbitmq所以选择rabbitmq
数据库，数据库账户，rabbitmq交换机，rabbitmq路由键都准备好了
注意：数据库地址或者账号密码错误的话canal是能正常启动的
启动canal
canal/bin/startup.bat 或者 startup.sh
启动后有问题去看日志文件：
canal/logs/canal/canal.log
canal/logs/example/example.log
canal/logs/example/meta.log
修改数据库后rabbitmq能获取到数据，这个时候就能在代码层面监听rabbitmq做业务处理，同步到es、redis之类的
