canal + mysql + rabbitmq步骤(CanalListener): 1. 开启mysql的binlog。 (1) 修改my.ini文件,并重启mysql。 [mysqld] log-bin=mysql-bin #添加这一行就 ok binlog-format=ROW #选择 row 模式 server_id=1 #不能和canal的slaveId重复 (2) 检查配置是否生效 SHOW VARIABLES LIKE ‘%log_bin%’ log_bin = ON 表示开启了 @注意:mysql8默认开启binlog,直接跳过第一步;mysql5.7自己创建my.ini。 2. rabbitmq 创建exchange 和 queue,绑定exchange和queue。 3. 配置canal,cnanal.properties(rabbitmq配置) 和 instance.properties(数据库配置)。 (1) canal.properties canal.serverMode = rabbitMQ rabbitmq.host = mq所在机器的ip rabbitmq.virtual.host = / rabbitmq.exchange = canal.exchange rabbitmq.username = admin rabbitmq.password = admin (2) instance.properties canal.instance.master.address=127.0.0.1:3306 canal.instance.dbUsername=root canal.instance.dbPassword=Mysql的root密码 canal.mq.topic=canal.routing.key (3) 启动canal,验证是否成功 Bin下面双击startup.bat即可启动。D:\canal\logs\下的log没有报错则代表启动成功。