JarCastingzknotify-cache
ZooKeeper通知更新的本地缓存
- 缓存按需延迟懒加载
- 通知加载可设置随机延迟，防止所有节点同时加载造成数据源瞬时压力过大
- 旧的缓存内容可定制清理回调
- 只支持Java8
Get Started
ReloadableCache<List<String>> cache = ZkNotifyReloadCache.<List<String>> newBuilder()
.withCacheFactory(this::buildFromSource) // 配置cache构建方法，必须
.withNotifyZkPath("/notifyPath1") // zk监听变更的路径，必须
.withCuratorFactory(this::getCuratorFactory) // 提供zkClient的工场方法，必须
.withMaxRandomSleepOnNotifyReload(30*1000) // zk通知reload时随机最大延迟时间，可选
.withOldCleanup(this::cleanup) // 旧数据的清理方法，可选
.enableAutoReload(1, TimeUnit.MINUTES) // 打开自动定时加载，可选
.build();
List<String> content = cache.get(); // 获取内容，第一次调用本方法时才初始化
cache.reload(); // 通过zk通知所有节点更新
private List<String> buildFromSource() {
// 从数据源加载数据
}
private CuratorFramework getCuratorFactory() {
// 返回一个初始化好的CuratorFramework
}
private void cleanup(List<String> list) {
// 清理旧对象操作
}