Tôi biết đây là câu hỏi cũ. Tôi chỉ đăng ở đây để tham khảo cho một số người khác như tôi.
Tôi cũng đang tìm kiếm điều này. Sau đầu của @sbridges, tôi nghĩ rằng tôi có thể làm như thế này.
PathChildrenCache pathcache = new PathChildrenCache(client, "/some/path", true);
PathChildrenCacheListener listner1 = new PathChildrenCacheListener() {
Map<String, PathChildrenCache> listener2s = new HashMap<String, PathChildrenCache>();
@Override
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
String path = event.getData().getPath();
if(event.getType() == Type.CHILD_ADDED) {
PathChildrenCache cache2 = new PathChildrenCache(client, path, true);
cache2.getListenable().addListener(this);
cache2.start();
listener2s.put(path, cache2);
}
else if(event.getType() == Type.CHILD_REMOVED) {
PathChildrenCache cache2 = listener2s.remove(path);
if(cache2 != null) cache2.close();
}
System.out.println("" + Thread.currentThread().getId() + "\t" + event);
}
};
pathcache.getListenable().addListener(listner1);
Nếu ai đó tìm thấy điều gì sai, vui lòng cho tôi biết.
Nguồn
2014-11-05 13:33:19
Bạn có thể mất các sự kiện của trẻ giữa nhận thông báo (CHILD_ADDED) và đăng ký đồng hồ của bạn trên con – dk14