0
点赞
收藏
分享

微信扫一扫

canal数据库监听

J简文 2022-05-13 阅读 47

log-bin=mysql-bin # 开启 binlog

binlog-format=ROW # 选择 ROW 模式

server_id=1 # 配置 MySQL replaction 需要定义,不要和 canal 的 slaveId 重复

授权 canal 链接 MySQL 账号具有作为 MySQL slave 的权限, 如果已有账户可直接 grant

CREATE USER canal IDENTIFIED BY 'canal';

GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';

-- GRANT ALL PRIVILEGES ON *.* TO 'canal'@'%' ;

FLUSH PRIVILEGES;

wget https://github.com/alibaba/canal/releases/download/canal-1.1.5/canal.deployer-1.1.5.tar.gz

mkdir /data/soft/canal

tar zxvf canal.deployer-1.1.5.tar.gz -C /data/soft/canal

#更改配置文件 /conf/example/instance.properties

canal.instance.master.address=127.0.0.1:3306

canal.instance.dbUsername=canal

canal.instance.dbPassword=canal

canal.instance.connectionCharset = UTF-8

#默认数据库 暂时无用

canal.instance.defaultDatabaseName = liexin_canal

设置过滤条件(这里只需要liexin_canal库里面的所有表)

canal.instance.filter.regex=liexin_canal\\..*

为下面mq模式绑定mq创建好的routing key

canal.mq.topic=canal_ex_routing


mq模式

在rabbitmq页面创建好exchange,Queues,并绑定好routing key,

exchange的Type:direct

更改/conf/canal.properties文件

canal.serverMode = rabbitMQ

rabbitmq.host =192.168.1.237

rabbitmq.virtual.host =/

rabbitmq.exchange =交换器名

rabbitmq.username =huntadmin

rabbitmq.password =jy2y2900

rabbitmq.deliveryMode =2

启动:

sh /data/canal/bin/startup.sh

停止:

sh /data/canal/bin/stop.sh

重启:

sh /data/canal/bin/restart.sh

客户端解析的event_type:

1 : 新增

2 : 更新

3 : 删除

以下还未测试

若需要监控多台数据库 则需在/data/canal/conf/ 下新建一个example,并且将instance.properties中对应的信息更改, 然后还需在canal.properties中的canal.destinations字段导入文件名,用逗号隔开

举报

相关推荐

0 条评论