springboot整合canal

news2024/11/25 2:21:01

该篇博客是基于前两篇的基础上来实现的，如果没有看过可以看一下前面的步骤

使用docker搭建 MYSQL主从_极速小乌龟的博客-CSDN博客docker 上面搭建mysql主从服务器https://blog.csdn.net/qq_35771266/article/details/128101019?spm=1001.2014.3001.5501

ShardingSphere-JDBC读写分离_极速小乌龟的博客-CSDN博客mysql主从 + redis哨兵集群 + canal + 本地缓存的实现。https://blog.csdn.net/qq_35771266/article/details/128101972?spm=1001.2014.3001.5501

一、cannal用户创建

在原来搭建的主库3306上面新创建一个用户，给canal使用。

create user canal@'%';

ALTER USER 'canal'@'%' IDENTIFIED WITH mysql_native_password BY '123456';

GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT,SUPER ON *.* TO 'canal'@'%';

FLUSH PRIVILEGES;

重启mysql容器即可

docker restart  atguigu-mysql-master

二、安装Canal

这里没有设置密码，如果需要设置密码自己加上就行了。

docker run -p 11111:11111 --name canal \
-e canal.destinations=myCannal \
-e canal.instance.master.address=192.168.2.203:3306  \
-e canal.instance.dbUsername=canal  \
-e canal.instance.dbPassword=123456  \
-e canal.instance.connectionCharset=UTF-8 \
-e canal.instance.tsdb.enable=true \
-e canal.instance.gtidon=false  \
-e canal.instance.filter.regex=.*\\..* \
-d canal/canal-server:v1.1.5

注意：IP需要替换为自己的IP

说明:

-p 11111:11111：这是canal的默认监听端口
-e canal.instance.master.address=ip:3306：数据库地址和端口，如果不知道mysql容器地址，可以通过docker inspect 容器id来查看
-e canal.instance.dbUsername=canal：数据库用户名
-e canal.instance.dbPassword=123456 ：数据库密码
-e canal.instance.filter.regex=：要监听的表名称

mysql 数据解析关注的表，Perl正则表达式.
多个正则之间以逗号(,)分隔，转义符需要双斜杠(\\) 
常见例子：
1.  所有表：.*   or  .*\\..*
2.  canal schema下所有表： canal\\..*
3.  canal下的以canal打头的表：canal\\.canal.*
4.  canal schema下的一张表：canal.test1
5.  多个规则组合使用然后以逗号隔开：canal\\..*,mysql.test1,mysql.test2

三、springboot整合canal

1.引入pom

<dependency>
    <groupId>top.javatool</groupId>
    <artifactId>canal-spring-boot-starter</artifactId>
    <version>1.2.1-RELEASE</version>
</dependency>

2.修改配置文件

#canal配置
canal.destination=myCannal
canal.server=192.168.2.203:11111

3.修改实体类

加上了主键@Id 和对应的 @Column(name = "uname") 其实如果此处的命名与数据库一致的haul是可以不用写的。

package com.atguigu.shargingjdbcdemo.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import javax.persistence.Column;
import javax.persistence.Id;


@TableName("t_user")//逻辑表
@Data
public class User {

    @TableId(type = IdType.AUTO)
    @Id
    private Long id;
    @Column(name = "uname")
    private String uname;
}

4.实现监听处理器

package com.atguigu.shargingjdbcdemo.handler;

import com.atguigu.shargingjdbcdemo.entity.User;
import org.springframework.stereotype.Component;
import top.javatool.canal.client.annotation.CanalTable;
import top.javatool.canal.client.handler.EntryHandler;

/**
 * @author Administrator
 */
@CanalTable("t_user")
@Component
public class UserHandler implements EntryHandler<User> {

    @Override
    public void insert(User user) {
        System.out.println("新增用户");
        System.out.println("user = " + user);
    }

    @Override
    public void update(User before, User after) {
        System.out.println("修改用户");
        System.out.println("修改用户before：" + before);
        System.out.println("修改用户after：" + after);
    }

    @Override
    public void delete(User user) {
        System.out.println("删除用户user = " + user);
    }

}