Canal集成指南

CREATE USER 'canal'@'%' IDENTIFIED BY 'canal123';  # 创建canal用户，密码为canal123
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';  # 授予必要的权限
FLUSH PRIVILEGES;  # 刷新权限

canal.deployer-1.1.8/
├── bin/                  # 启动脚本目录
├── conf/                 # 配置文件目录
│   ├── canal.properties   # 全局配置文件
│   ├── example/          # 示例instance配置目录
│   │   └── instance.properties
│   └── logback.xml       # 日志配置文件
├── lib/                  # 依赖库目录
├── logs/                 # 日志文件目录
└── plugin/               # 插件目录

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

import java.util.List;

@Component
@ConfigurationProperties(prefix = "canal")
public class CanalProperties {
    private String username;
    private String password;
    private CanalServerProperties server;
    private CanalPoolProperties pool;
    private String subscribe;
    private String filterRegex;
    private String blackRegex;

    // Getters and Setters
    public String getUsername() { return username; }
    public void setUsername(String username) { this.username = username; }
    public String getPassword() { return password; }
    public void setPassword(String password) { this.password = password; }
    public CanalServerProperties getServer() { return server; }
    public void setServer(CanalServerProperties server) { this.server = server; }
    public CanalPoolProperties getPool() { return pool; }
    public void setPool(CanalPoolProperties pool) { this.pool = pool; }
    public String getSubscribe() { return subscribe; }
    public void setSubscribe(String subscribe) { this.subscribe = subscribe; }
    public String getFilterRegex() { return filterRegex; }
    public void setFilterRegex(String filterRegex) { this.filterRegex = filterRegex; }
    public String getBlackRegex() { return blackRegex; }
    public void setBlackRegex(String blackRegex) { this.blackRegex = blackRegex; }
}

class CanalServerProperties {
    private String host;
    private int port;
    private String destination;
    private List<CanalClusterServerProperties> cluster;

    // Getters and Setters
    public String getHost() { return host; }
    public void setHost(String host) { this.host = host; }
    public int getPort() { return port; }
    public void setPort(int port) { this.port = port; }
    public String getDestination() { return destination; }
    public void setDestination(String destination) { this.destination = destination; }
    public List<CanalClusterServerProperties> getCluster() { return cluster; }
    public void setCluster(List<CanalClusterServerProperties> cluster) { this.cluster = cluster; }
}

class CanalClusterServerProperties {
    private String host;
    private int port;

    // Getters and Setters
    public String getHost() { return host; }
    public void setHost(String host) { this.host = host; }
    public int getPort() { return port; }
    public void setPort(int port) { this.port = port; }
}

class CanalPoolProperties {
    private int maxActive;
    private int maxIdle;
    private int minIdle;
    private int timeout;

    // Getters and Setters
    public int getMaxActive() { return maxActive; }
    public void setMaxActive(int maxActive) { this.maxActive = maxActive; }
    public int getMaxIdle() { return maxIdle; }
    public void setMaxIdle(int maxIdle) { this.maxIdle = maxIdle; }
    public int getMinIdle() { return minIdle; }
    public void setMinIdle(int minIdle) { this.minIdle = minIdle; }
    public int getTimeout() { return timeout; }
    public void setTimeout(int timeout) { this.timeout = timeout; }
}