当前位置：首页 > article >正文

Eureka的缓存原理分析

article 2025/2/28 7:47:26

上一篇介绍了Eureka的缓存机制，Eureka的缓存机制就像个"善意的谎言"——它为了让系统更抗压，会悄悄把服务信息藏在小本本里。咱们今天就扒开它的口袋，看看里面到底揣着什么秘密~

扒开Eureka的缓存小棉袄：源码里的温柔陷阱

大家好呀~ 上次咱们聊了Eureka缓存的基本套路，今天我要带你们钻进源码的密室，看看这个温柔体贴的缓存机制，到底藏着多少欲说还休的小心思！（撸起袖子准备开干）

一、客户端缓存：那个偷偷定闹钟的DiscoveryClient

1. 定时刷新的小妖精

让我们看看DiscoveryClient这个管家婆的日常：

// 这个定时任务就是缓存更新的心脏
private void initScheduledTasks() {
    // 缓存刷新定时器（默认30秒）
    cacheRefreshTask = new TimerTask() {
        public void run() {
            refreshRegistry(); // ← 重点在这里！
        }
    };
    scheduler.schedule(
        cacheRefreshTask,
        clientConfig.getRegistryFetchIntervalSeconds() * 1000 // 默认30秒
    );
}

这个定时任务就像你家冰箱的自动补货系统，每隔30秒就打开冰箱（本地缓存）检查食材（服务列表）是否新鲜。

2. 增量更新的小心机

void refreshRegistry() {
    // 偷偷用增量更新节省流量（就像只下载APP更新包）
    boolean success = fetchRegistry(remoteRegionsModified);
    if (success) { // 更新成功就改写"最后更新时间"
        lastSuccessfulRegistryFetchTimestamp = System.currentTimeMillis();
    }
}

这里藏着个彩蛋：当disable-delta=true时，就会变成全量更新（就像每次都要重新下载整个APP），这个开关在配置里可以玩哦！

二、服务端缓存：三层套娃的魔法秀

1. 读写分离的鸳鸯锅

看ResponseCacheImpl这个核心类：

public class ResponseCacheImpl implements ResponseCache {
    // 只读缓存（展示给客户看的）
    private final ConcurrentMap<Key, Value> readOnlyCacheMap = new ConcurrentHashMap<>();
    
    // 可写缓存（真实数据存放地）
    private final LoadingCache<Key, Value> readWriteCache;
    
    // 定时把鸳鸯锅的红汤（可写缓存）倒到白汤（只读缓存）
    timer.schedule(getCacheUpdateTask(), 
        serverConfig.getResponseCacheUpdateIntervalMs() // 默认30秒
    );
}

这像极了火锅店的鸳鸯锅：后厨（可写缓存）不断加料，服务员（只读缓存）定时从前台取走最新汤底。

2. 缓存键的千层套路

// 看看这个神奇的缓存Key
static class Key {
    // 包含这些要素才能打开缓存宝箱
    private final String entityName;  // 服务名
    private final EurekaAccept accept; // 数据格式
    private final String clientVersion; // 客户端版本
    // 还有5个隐藏要素...
}

每个Key都像特工接头暗号，必须所有要素匹配才能拿到缓存。这就是为什么不同客户端可能看到不同缓存结果的原因！

三、心跳续约：缓存保鲜的魔法药水

1. 服务端的续约日记

// 服务端处理心跳的核心方法
public boolean renew(String appName, String serverId) {
    // 在注册表里找到这个服务实例
    Lease<InstanceInfo> lease = registry.get(appName).get(serverId);
    lease.renew(); // ← 这里更新了最后续约时间！
    return true;
}

每次心跳就像给食物贴新的保质期标签，如果超时未续约（默认90秒），这个实例就会被扔进待清理列表。

2. 清理线程的午夜凶铃

// 定时清理过期实例的线程
protected void postInit() {
    evictionTask = new TimerTask() {
        public void run() {
            evict(); // ← 开始大扫除！
        }
    };
    // 默认每60秒扫一次
    timer.schedule(evictionTask, 
        serverConfig.getEvictionIntervalTimerInMs() 
    );
}

这个定时任务就像你家冰箱的自动清理功能，定期把过期的酸奶（失效实例）扔出去。

四、缓存雪崩防御：随机抖动的艺术

看看客户端怎么避免集体刷新导致的雪崩：

// 计算下次刷新时间时加了随机扰动
int delay = getRefreshIntervalDelay();
timer.schedule(task, delay);

private int getRefreshIntervalDelay() {
    // 基础间隔
    int delay = clientConfig.getRegistryFetchIntervalSeconds() * 1000;
    // 加个随机扰动（最多15秒）
    int jitter = (int) (Math.random() * clientConfig.getCacheRefreshExecutorExponentialBackOffBound());
    return delay + jitter;
}

这个随机抖动就像让不同班级错峰吃饭，避免食堂被挤爆。源码里这个设计真是贴心小棉袄~

五、最佳实践：和源码对话的配置秘籍

根据源码启示，推荐这样配置：

eureka:
  client:
    registry-fetch-interval-seconds: 20  # 比默认30更积极
    cache-refresh-executor-exponential-back-off-bound: 10 # 抖动上限
    
  server:
    eviction-interval-timer-in-ms: 30000  # 加快失效检测
    response-cache-update-interval-ms: 15000 # 更快同步缓存

这些数字不是随便写的！对照源码中的时间常量调整，就像给缓存机制装上涡轮增压。

六、写给源码的情书：那些动人的设计细节

双重检查锁的温柔：

if (shouldFetchRegistry()) { // 先快速检查
    synchronized (lock) {    // 再上锁确认
        if (shouldFetchRegistry()) {
            fetchRegistry(); // 真正干活
        }
    }
}