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