安装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}}