文章目录
一、部署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
四、实际操作
表的结构和数据
修改后的数据：
消息队列里面的消息：
可以看到有旧数据，新数据，数据库名，表名，语句类型等相关信息。