本文共 1198 字，大约阅读时间需要 3 分钟。

此处将以Alibaba canal([https://github.com/alibaba/canal])为例，说明Canal的使用，Canal作为数据库数据异步实时同步利器，为分库分表条件下数据一致性维护启到重要作用。

流程图

Canal可以实时异步监听多Master数据库数据变化，并异步将数据同步到给其他应用，这些应用不仅可以使ES集群，也可以是其他相关应用。

配置

以canal 1.1.4版本为例，支持mysql最新版本8.x，解压后分别配置如下

配置canal.properties文件：

（1）canal.zkServers 配置zookeeper集群地址；

（2）canal.ip配置为本机的host实际IP地址； （3）canal.register.ip配置为本机的host实际IP地址； （4）canal.destinations配置为数据库分片数，可以通过拷贝其中source目录进行类似配置：

• 执行命令 cp -r source sharding1
• canal.destinations=source,sharding1,sharding2,shardingn

（5）网络配置

• canal.instance.network.receiveBufferSize=65536
• canal.instance.network.sendBufferSize=65536

（6）配置集群支持

• canal.instance.global.sprint.xml=casspath:spring/default-instance.xml 其他注释掉

配置intance.properties文件：

分别进入source,sharding1,sharding2文件目录，找到旗下此文件，以下以source文件为例：

• canal.instance.master.address=master1:3306
• canal.instance.dbUsername=canal
• canal.instance.dbPassword=canal

进入sharding1目录，是种配置master的slave权限，配置如下，其他类似：

• canal.instance.master.address=master2:3306
• canal.instance.dbUsername=canal
• canal.instance.dbPassword=canal

注意，配置时候需要提前在master数据库，创建一个具有slave权限的canal用户，并设置相应的密码canal;

启动

进入bin目录执行命令，可以在命令里面修改JVM参数。

./startup.sh

验证

使用canal用户或所有权用户登录到master数据库，执行命令

show processlist 如果能够正常常看到Dump进程，则说明配置成功。

转载地址：http://pccpi.baihongyu.com/