es 节点发现

es 节点发现

PeerFinder -> activate -> handleWakeUpconfigureHostResover 线程池开启节点发现线程 PeerFinder::lambda

configuredHostsResolver.resolveConfiguredHosts(providedAddresses -> { synchronized (mutex) { lastResolvedAddresses = providedAddresses; logger.trace(“probing resolved transport addresses {}”, providedAddresses); providedAddresses.forEach(this::startProbe); } });

lambda表达式 对每一个 配置的节点地址，做startProbe 探测每一个地址 使用 generic 线程池，用transportService 做握手，如果是 master节点 监听器listener 更新peer信息，如果是本地节点或者 数据节点 peersByAddress 移除这个地址，如果超时发生错误 peersByAddress也移除这个地址