安装zk(这里略过...)
canal服务的HA部署其实特别简单，解压之后只需配置两个文件即可（canal.properties；instance.properties）
修改配置文件canal.properties
#zk集群
canal.zkServers=192.168.1.111:2181,....
#集群配置必须是spring/default-instance.xml
canal.instance.global.spring.xml = classpath:spring/default-instance.xml
canal.destinations = example
(这个example就是conf目录里的实例，如果要建别的实例'test'就建个test目录，把example里面的instance.properties文件拷贝到test的实例目录下就好了，然后在这里的配置就是canal.destinations = example,test)
修改配置文件instance.properties
canal.instance.mysql.slaveId=2222
canal.instance.master.address=192.168.1.115:3306
在另外一台机器上再做一次上面同样的操作，
instance.properties中的canal.instance.mysql.slaveId（canal伪装的mysql slave的编号，不能与mysql数据库与其他的slave重复。）
至此HA集群模式配置好了。HA模式在启动的时候要两台机器都启动canal服务，然后由zookeeper自动管理active和standby状态。
客户端连接服务的时候就可以采用集群方式连接了
基于zookeeper动态获取canal server的地址，建立链接，其中一台server发生crash，可以支持failover
CanalConnector connector = CanalConnectors.newClusterConnector("192.168.1.111:2181", "example", "", "");
理解canal的server和instance
server代表一个canal运行实例，相当于一个jvm
instance相当于一个数据队列，即一个mysql实例 （1个server可以对应多个instance)
server对应的properties配置文件：
canal.properties (系统根配置文件)
instance对应的properties配置文件：
instance.properties (instance级别的配置文件，每个instance一份)
可以监听多个数据库，每个数据库一个文件名一个配置文件，就像刚刚上面介绍的example和test这俩个实例
保存在Zookeeper中的数据节点
节点路径 描述
/otter/canal 根目录
/otter/canal/cluster Canal集群节点信息
/otter/canal/destinations Canal所有Instance的信息
/otter/canal/cluster路径的展开如下：
其实就是挂载了所有集群节点的host:port信息
/otter/canal/cluster
- 192.168.56.1:11111
- 172.17.0.1:11111
/otter/canal/destinations路径会相对复杂，展开的信息如下：
/otter/canal/destinations
- Instance标识
- running 记录当前为此Instance提供服务状态为running的Canal节点 [EPHEMERAL类型]
- cluster 记录当前为此Instance提供服务的Canal集群节点列表
- Client序号标识
- filter 订阅信息
- running 客户端当前正在读取的running节点 [EPHEMERAL类型]
- cluster 记录当前读取此Instance的客户端节点列表
- cursor 记录客户端读取的position信息
# 例如
/otter/canal/destinations
- example
- running -> {"active":true,"address":"192.168.1.111:11111"}
- cluster
- 192.168.1.111:11111
- 192.168.1.114:12111
- 1001
- filter -> .*\\..*
- running ->{"active":true,"address":"192.168.1.3:54554","clientId":1001}
- cluster ->
- cursor->{"@type":"com.alibaba.otter.canal.protocol.position.LogPosition","identity":{"slaveId":-1,"sourceAddress":{"address":"docker_server","port":3306}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000002","position":6343,"serverId":1,"timestamp":1608527997000}}
