Dubbo-聊聊注册中心的设计( 五 ) _生活百科

缓存设计注册中心有两份缓存，一份在内存，一份在磁盘。该方法的作用是将内存中的缓存数据保存在磁盘文件中，该方法有错误重试，最大重试次数是3，重试采用另一个线程去执行重试，不是当前线程。本地缓存设计相当于是一种容错机制，当网络抖动等原因而导致订阅失败时，Consumer端的Registry就可以通过getCacheUrls()方法获取本地缓存，从而得到最近注册的服务提供者。
//将内存中的文件写到磁盘上 public void doSaveProperties(long version) { //版本号判断防止重复写 if (version < lastCacheChanged.get()) { return; } //判断磁盘文件是否为空 if (file == null) { return; } // Save try { //lock文件，用于加锁操作 File lockfile = new File(file.getAbsolutePath() + ".lock"); if (!lockfile.exists()) { lockfile.createNewFile(); } //RandomAccessFile提供对文件的读写操作 try (RandomAccessFile raf = new RandomAccessFile(lockfile, "rw"); FileChannel channel = raf.getChannel()) { //获取锁 FileLock lock = channel.tryLock(); if (lock == null) { throw new IOException("Can not lock the registry cache file " + file.getAbsolutePath() + ", ignore and retry later, maybe multi java process use the file, please config: dubbo.registry.file=xxx.properties"); } // Save try { if (!file.exists()) { file.createNewFile(); } try (FileOutputStream outputFile = new FileOutputStream(file)) { //从内存缓存中获取数据写入文件 properties.store(outputFile, "Dubbo Registry Cache"); } } finally { lock.release(); } } } catch (Throwable e) { //发生异常时，重试次数+1 savePropertiesRetryTimes.incrementAndGet(); //重试次数大于抛出异常 if (savePropertiesRetryTimes.get() >= MAX_RETRY_TIMES_SAVE_PROPERTIES) { logger.warn("Failed to save registry cache file after retrying " + MAX_RETRY_TIMES_SAVE_PROPERTIES + " times, cause: " + e.getMessage(), e); savePropertiesRetryTimes.set(0); return; } //再次对比版本信息，如果版本已过期，返回不再处理 if (version < lastCacheChanged.get()) { savePropertiesRetryTimes.set(0); return; } else { //重试线程 registryCacheExecutor.execute(new SaveProperties(lastCacheChanged.incrementAndGet())); } logger.warn("Failed to save registry cache file, will retry, cause: " + e.getMessage(), e); } } //磁盘中文件加载到内存中 private void loadProperties() { if (file != null && file.exists()) { InputStream in = null; try { in = new FileInputStream(file); properties.load(in); if (logger.isInfoEnabled()) { logger.info("Load registry cache file " + file + ", data: " + properties); } } catch (Throwable e) { logger.warn("Failed to load registry cache file " + file, e); } finally { if (in != null) { try { in.close(); } catch (IOException e) { logger.warn(e.getMessage(), e); } } } } }

Dubbo-聊聊注册中心的设计( 五 )

经验总结扩展阅读

在恋爱关系中|男人不会珍惜的两种女人，你是其中之一吗？

2022年10月12日走亲访友黄道吉日 2022年农历九月十七宜走亲访友吗

固态硬盘格式化选什么格式比较好固态硬盘格式化选哪种格式比较好

浅谈是什么意思

创造与魔法魔法深海旧日遗蜕技能介绍

一千多的女表什么牌子好点,能推荐一些适合女生的手表品牌吗？价格不超过1千的

英雄联盟手游绑定端游账号

要跟着美容生物钟来护肤

这四种体质的女性，很容易怀孕，看看你是不是？

发型昆明正规美容美发学校带你了解美容美发的作用

女士高档手表品牌推荐,女士手表排行榜10强女士手表推荐

三无车辆是哪三无,三无车辆交警怎么处理

深零设计师姚工|合肥夫妇家中的高级场面，130平坚决沙发不靠墙，效果不是一般的实用

2022年属鸡农历九月提车黄道吉日

涂一层素颜也能美翻天，谁用谁爱上......这个防晒隔离太绝了

芋圆是开水下锅还是冷水下锅

hosts文件位置?

诗经多少篇

广东珠海中考时间2022年具体时间广东珠海中考时间及科目安排

什么样的鸡蛋是坏的鸡蛋是坏的能吃吗