SpringBoot整合canal

1.修改mysql

mysql镜像采用8.2,canal镜像尽量和121保持一致

镜像来源

修改msql配置文件my.conf

# 配置MySQL replaction需要定义，不要和canal的slaveId重复
server_id=1

#设置binary log文件的存放地址和文件名，叫做mysql-bin
log-bin=/var/lib/mysql/mysql-bin

#指定对哪个database记录
binlog-do-db=patrol_robot_dev

# 选择ROW(行)模式
binlog-format=ROW

完整的my.cnf如下：

[mysqld]
server_id=1
log-bin=/var/lib/mysql/mysql-bin
    
##指定对哪个database记录
binlog-do-db=patrol_robot_dev

### 选择ROW(行)模式
binlog-format=ROW

skip-host-cache
skip-name-resolve
datadir=/var/lib/mysql
socket=/var/run/mysqld/mysqld.sock
secure-file-priv=/var/lib/mysql-files
user=mysql
sql_mode = "STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION"
max_allowed_packet = 512M
pid-file=/var/run/mysqld/mysqld.pid
log-error=/logs/mysql/error.log
general_log=OFF
[client]
socket=/var/run/mysqld/mysqld.sock

!includedir /etc/mysql/conf.d/

查看是否打开binlog模式

show VARIABLES LIKE 'log_bin';

查看binlog日志文件列表

show BINARY logs;

查看当前正在写入的binlog文件

show MASTER STATUS;

查看binlog格式

SHOW VARIABLES LIKE 'binlog_format';

创建canal用户

-- 创建用户 用户名：canal 密码：Canal@123456
create user 'canal'@'%' identified by 'Canal@123456';

-- 授权 *.*表示所有库
grant SELECT, REPLICATION SLAVE, REPLICATION CLIENT on *.* to 'canal'@'%';

-- 修改canal的插件
ALTER USER 'canal'@'%' IDENTIFIED WITH mysql_native_password BY 'Canal@123456';

-- 刷新权限
FLUSH PRIVILEGES;

2.安装canal

创建docker网络

#创建canal网络
docker network create canal-test

#查询创建的网络信息
docker network ls

#查询当前网络的信息
docker network inspect canal-test

拉取canal镜像并启动

docker pull canal/canal-server

docker-启动命令

docker run -p 11111:11111 --name canal \
    -e canal.destinations=test \
    -e canal.instance.master.address=mysql:3306  \
    -e canal.instance.dbUsername=canal  \
    -e canal.instance.dbPassword=Canal@123456  \
    -e canal.instance.connectionCharset=UTF-8 \
    -e canal.instance.tsdb.enable=true \
    -e canal.instance.gtidon=false  \
    -e canal.instance.filter.regex=patrol_robot_dev..*
    --network canal-test \
    --restart=always \
    -d canal/canal-server

docker-compose启动脚本

version: '3.2'
services: 
 canal:
    networks:
      basic_net:
    ports:
      - "11111:11111"
    depends_on:
      mysql:
        condition: service_healthy
    image: canal/canal-server:latest
    container_name: basic-canal
    restart: always
    privileged: true
    environment:
      - TZ=Asi