---

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

四、实际操作

表的结构和数据

修改后的数据：

消息队列里面的消息：

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