canal整合rabbitmq同步mysql数据到redis

简介

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

canalGitHub下载地址
在这里插入图片描述

修改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

# 该项默认是监听的所有表改动, 我只需要监听业务需要的表(pms_product, pms_guarantee)
#canal.instance.filter.regex=.*\\..*
canal.instance.filter.regex=business.pms_product,business.pms_guarantee

修改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之类的
在这里插入图片描述


版权声明:本文为GebiMr_hu原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。