文章目录

• 一、部署RocketMQ
• 二、部署MySQL
• • 1、开启mysql的binlog写入功能
  • 2、创建一个有相关权限的mysql slave账号
• 三、部署 Canal
• • 1、修改conf/canal.properties配置文件
  • 2、修改conf/example/instance.properties配置文件
• 四、实际操作

一、部署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 

四、实际操作

表的结构和数据

修改后的数据：

消息队列里面的消息：

可以看到有旧数据，新数据，数据库名，表名，语句类型等相关信息。