instance的lazy启动在HA模式下不成立

在HA模式下，instance的lazy启动不成立。

首先看CanalController的代码

for (Map.Entry<String, InstanceConfig> entry : instanceConfigs.entrySet()) { final String destination = entry.getKey(); InstanceConfig config = entry.getValue(); // 创建destination的工作节点 if (!config.getLazy() && !embededCanalServer.isStart(destination)) { // HA机制启动 ServerRunningMonitor runningMonitor = ServerRunningMonitors.getRunningMonitor(destination); if (!runningMonitor.isStart()) { runningMonitor.start(); } }

    if (autoScan) {
        instanceConfigMonitors.get(config.getMode()).register(destination, defaultAction);
    }
}

lazy模式下，ServerRunningMonitor不会启动，那么在zookeeper的/otter/canal/destinations/destination/cluster节点下不会有数据，running节点也不会有数据

再看ClusterNodeAccessStrategy的代码 public SocketAddress nextNode() { if (runningAddress != null) {// 如果服务已经启动，直接选择当前正在工作的节点 return runningAddress; } else if (!currentAddress.isEmpty()) { // 如果不存在已经启动的服务，可能服务是一种lazy启动，随机选择一台触发服务器进行启动 return currentAddress.get(0);// 默认返回第一个节点，之前已经做过shuffle } else { throw new CanalClientException("no alive canal server"); } }

由于cluster和running节点都不存在，此处会进入else分支，客户端会一直报错，没办法触发laze启动。

原提问者GitHub用户lulu2panpan