接口 com.alibaba.otter.canal.client.CanalConnector
的使用

使用CanalConnector的程序包

程序包	说明
com.alibaba.otter.canal.client
com.alibaba.otter.canal.client.impl

com.alibaba.otter.canal.client中CanalConnector的使用

返回CanalConnector的com.alibaba.otter.canal.client中的方法

限定符和类型	方法和说明
static CanalConnector	CanalConnectors.newClusterConnector(List<? extends SocketAddress> addresses, String destination, String username, String password) 创建带cluster模式的客户端链接，自动完成failover切换
static CanalConnector	CanalConnectors.newClusterConnector(String zkServers, String destination, String username, String password) 创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描
static CanalConnector	CanalConnectors.newSingleConnector(SocketAddress address, String destination, String username, String password) 创建单链接的客户端链接

com.alibaba.otter.canal.client.impl中CanalConnector的使用

实现CanalConnector的com.alibaba.otter.canal.client.impl中的类

限定符和类型	类和说明
class	ClusterCanalConnector 集群版本connector实现，自带了failover功能
class	SimpleCanalConnector 基于CanalServerWithNetty定义的网络协议接口，对于canal数据进行get/rollback/ack等操作