自学内容网 自学内容网

使用Canal监听Binlog将数据发送到RocketMQ


一、部署RocketMQ

win11 部署RocketMQ 和可视化界面
可视化界面是源码,需要在本地编译运行,下面是直接编译好的 jar 包
rocketmq-dashboard-1.0.1-SNAPSHOT.jar

二、部署MySQL

网上有许多教程,在这里不在赘述,部署好后,修改配置文件。

1、开启mysql的binlog写入功能

  [mysql]
  log-bin=mysql-bin #添加这一行就 ok   
  binlog-format=ROW #选择 row 模式    
  server_id=1       #不能和canal的slaveId重复

2、创建一个有相关权限的mysql slave账号

# 创建账号
CREATE USER canal IDENTIFIED WITH MYSQL_NATIVE_PASSWORD BY 'canal';
# 给账号赋权限
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%'; 
# 刷新
FLUSH PRIVILEGES;

三、部署 Canal

下载canal.deployer
我下载的是1.1.5的版本,注意,在部署canal的时候,java版本是1.8,不然会报错

1、修改conf/canal.properties配置文件

# 默认为tcp,我这里选择将监听到的消息发送到rocketMQ
canal.serverMode = rocketmq
# 当前server上部署的instance列表,默认为example
canal.destinations = example
# mq的地址和端口
canal.mq.servers = 127.0.0.1:9876
# 创建的mysql slave账号和密码
canal.instance.tsdb.dbUsername = canal
canal.instance.tsdb.dbPassword = canal
##################################################
#########           RocketMQ         #############
##################################################
rocketmq.producer.group = test
rocketmq.enable.message.trace = false
rocketmq.customized.trace.topic =
rocketmq.namespace =
rocketmq.namesrv.addr = 127.0.0.1:9876
rocketmq.retry.times.when.send.failed = 0
rocketmq.vip.channel.enabled = false

2、修改conf/example/instance.properties配置文件

# mysql从服务Id,未被其他mysql服务使用即可
canal.instance.mysql.slaveId = 1234
# mysql主服务的地址和端口
canal.instance.master.address = 127.0.0.1:3306
# 指定要监听的数据库
canal.instance.defaultDatabaseName = canal_test
# username/password 数据库的用户名和密码
canal.instance.dbUsername=root
canal.instance.dbPassword=123456
# 需要监听的表的表达式,我这里只监听了test数据库下的binlog_test表
# 1.  所有表:.*   or  .*\\..*
# 2.  canal schema下所有表: canal\\..*
# 3.  canal下的以canal打头的表:canal\\.canal.*
# 4.  canal schema下的一张表:canal.test1
# 5.  多个规则组合使用:canal\\..*,mysql.test1,mysql.test2 (逗号分隔)
canal.instance.filter.regex=test\\.binlog_test
# rocketMQ的topic,如果使用rabbitMQ此处配置rabbitMQ的routingkey
canal.mq.topic=ROCKET_TEST

四、实际操作

表的结构和数据
在这里插入图片描述
修改后的数据:
在这里插入图片描述
消息队列里面的消息:
在这里插入图片描述
可以看到有旧数据,新数据,数据库名,表名,语句类型等相关信息。


原文地址:https://blog.csdn.net/qq_43302441/article/details/140856276

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!