Java 类org.apache.curator.framework.recipes.cache.TreeCacheEvent 实例源码

项目：redirector 文件：SnapshotManager.java

@Override
public void onChanged(TreeCacheEvent event) {
    ChildData data = event.getData();
    if (data == null) {
        return;
    }

    String path = data.getPath();
    switch (event.getType()) {
        case NODE_ADDED:
        case NODE_REMOVED:
        case NODE_UPDATED: {
            boolean isFullHostPath = StringUtils.isNotBlank(path) && path.split(RedirectorConstants.DELIMETER).length == 7;
            if (isFullHostPath && path.contains(RedirectorConstants.DELIMETER + applicationName + RedirectorConstants.DELIMETER)) {
                snapshotNeeded = true;
            }
            break;
        }
    }
}

项目：redirector 文件：ZKStacksCache.java

@Override
public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
    try {
        lock.lock();
        if (!stacksCacheAvailable) {
            log.info("Stack cache is NOT initialized, event intercepted: " + event.getType().name());
        }
        if (event.getType() == TreeCacheEvent.Type.INITIALIZED) {
            stacksCacheAvailable = true;
            stacksCacheAvailability.signalAll();
            log.info("stacks cache is initialized");
        } else if (listener.isPresent() && stacksCacheAvailable && event.getType() != TreeCacheEvent.Type.CONNECTION_LOST
            && event.getType() != TreeCacheEvent.Type.CONNECTION_SUSPENDED) {
            listener.get().onChanged(event);
        }
    } finally {
        lock.unlock();
    }
}

项目：mpush 文件：ZKCacheListener.java

@Override
public void childEvent(CuratorFramework curator, TreeCacheEvent event) throws Exception {
    ChildData data = event.getData();
    if (data == null) return;
    String dataPath = data.getPath();
    if (Strings.isNullOrEmpty(dataPath)) return;
    if (dataPath.startsWith(watchPath)) {
        switch (event.getType()) {
            case NODE_ADDED:
                listener.onServiceAdded(dataPath, Jsons.fromJson(data.getData(), CommonServiceNode.class));
                break;
            case NODE_REMOVED:
                listener.onServiceRemoved(dataPath, Jsons.fromJson(data.getData(), CommonServiceNode.class));
                break;
            case NODE_UPDATED:
                listener.onServiceUpdated(dataPath, Jsons.fromJson(data.getData(), CommonServiceNode.class));
                break;
        }
        Logs.RSD.info("ZK node data change={}, nodePath={}, watchPath={}, ns={}");
    }
}

项目：ElasticJob 文件：JobOperationListenerManager.java

@Override
protected void dataChanged(final CuratorFramework client, final TreeCacheEvent event, final String path) {
    if (!serverNode.isLocalJobPausedPath(path)) {
        return;
    }
    JobScheduleController jobScheduleController = JobRegistry.getInstance().getJobScheduleController(jobName);
    if (null == jobScheduleController) {
        return;
    }
    if (Type.NODE_ADDED == event.getType()) {
        jobScheduleController.pauseJob();
    }
    if (Type.NODE_REMOVED == event.getType()) {
        jobScheduleController.resumeJob();
        serverService.clearJobPausedStatus();
    }
}

项目：stroom-stats 文件：StroomPropertyServiceImpl.java

private void treeCacheChangeHandler(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) {
    switch (treeCacheEvent.getType()) {
        case INITIALIZED: {
            //cache is ready so release a permit allowing the application to continue initialising
            initialisedSemaphore.release();
            break;
        }
        case NODE_ADDED: {
            if (!treeCacheEvent.getData().getPath().equals(pathToCache)) {
                LOGGER.info("Curator TreeCache property added: " + childDataToLogString(treeCacheEvent.getData()));
            } else {
                LOGGER.info("Curator TreeCache path added: " + treeCacheEvent.getData().getPath());
            }
            break;
        }
        case NODE_REMOVED: {
            LOGGER.info("Curator TreeCache property removed: " + childDataToLogString(treeCacheEvent.getData()));
            break;
        }
        case NODE_UPDATED: {
            LOGGER.info("Curator TreeCache property updated: " + childDataToLogString(treeCacheEvent.getData()));
            break;
        }
        case CONNECTION_LOST: {
            LOGGER.debug("Connection to Zookeeper lost");
            break;
        }
        case CONNECTION_RECONNECTED: {
            LOGGER.debug("Connection to Zookeeper re-established");
            break;
        }
        case CONNECTION_SUSPENDED: {
            LOGGER.debug("Connection to Zookeeper suspended");
            break;
        }
    }
}

项目：stroom-stats 文件：CuratorTest.java

private static void checkTreeCache(CuratorFramework curatorFramework, String path) throws Exception {
    final Semaphore semaphore = new Semaphore(0);
    TreeCache treeCache = TreeCache.newBuilder(curatorFramework, path)
            .setCacheData(true)
            .setMaxDepth(3)
            .build();

    if (treeCache == null) {
        LOGGER.error("treeCache is null");
    }

    treeCache.getListenable().addListener((client, event) -> {
        if (event.getType().equals(TreeCacheEvent.Type.INITIALIZED)) {
            semaphore.release();
        }
    });

    treeCache.start();

    semaphore.tryAcquire(2, TimeUnit.SECONDS);


    Map<String, ChildData> map = treeCache.getCurrentChildren("/propertyService");

   if (map == null) {
       LOGGER.error("map is null");
   }

    map.entrySet().forEach(entry -> {
        LOGGER.info("{} - {}", entry.getKey(), Bytes.toString(entry.getValue().getData()));
    });
}

项目：elastic-job-cloud 文件：CloudJobConfigurationListener.java

private CloudJobConfiguration getJobConfig(final TreeCacheEvent event) {
    try {
        return CloudJobConfigurationGsonFactory.fromJson(new String(event.getData().getData()));
        // CHECKSTYLE:OFF
    } catch (final Exception ex) {
        log.warn("Wrong Cloud Job Configuration with:", ex.getMessage());
        // CHECKSTYLE:ON
        return null;
    }
}