Ribbon结合eureka实时刷新，服务下线实时刷新

「爱情、让人受尽委屈。」 2023-06-19 02:56 15阅读 0赞

服务下线时，客户端经常无法感知到。从而导致feign使用ribbon负载均衡的时候，在服务下线之后，ribbon中的server list来不及更新，仍会负载一部分流量到已下线的服务。

解决办法：   1.服务下线升级时，通过DiscoveryClient的shutdown（）方法通知注册中心。

2.然后使用消息广播通知客户端即时刷新同步注册中心。

3.通知ribbon即时跟eureka client同步。

实现：通过研究源码，发现在eureka client更新列表的方法为 DiscoveryClient.refreshRegistry。在另外ribbon有一个serverist的实现 EurekaNotificationServerListUpdater。这个类可以接收eureka客户端的更新事件，从而更新自己的列表，达到和eureka的同步。ribbon默认的更新机制是通过PollingServerListUpdater维护的线程去同步，那么我们可以利用配置让ribbon使用事件监听机制 更新。这里有一个坑，导致我研究了几天才解决。EurekaNotificationServerListUpdater无法通过配置文件使用，但可以通过类配置。

代码方面只写重要的两部分，一个是通过反射调用DiscoveryClient的refreshRegistry方法，此方法会触发更新事件。所以我们只需要配置好ribbon使用EurekaNotificationServerListUpdater更新。下面只写重点部分，至于方法的触发方法 可以有多种，比如你可以写在监听消息的onMessage方法中。

public void refresh() {
    
    try {
    
    Method method = DiscoveryClient.class.getDeclaredMethod("refreshRegistry");
    
    method.setAccessible(true);
    
    method.invoke(SpringUtil.getBean(DiscoveryClient.class));
    
    } catch (Exception e) {
    
    e.printStackTrace();
    
    }
    
    }

另外写一个配置类

@Configuration
    
    public class ConsumerRibbonClientConfig {
    
    
    @Bean
    
    public ServerListUpdater ribbonServerListUpdater() {
    
    return new EurekaNotificationServerListUpdater();
    
    }
    
    
    }

这样每次服务下线就可以通过广播消息触发ribbon更新了。

上面方案不够完善，当你按上面的思路实现之后，会发现，服务下线之后仍然有延迟。问题就在于，eureka server的缓存机制。eureka server中维护了两个缓存：readWriteCacheMap和readOnlyCacheMap 。客户端需要从readOnlyCacheMap中获取服务列表，而前者负责更新操作，更新完的数据会定时和readOnlyCacheMap进行同步。默认时间是30s。为了达到实时同步，可以选择禁用readOnlyCacheMap，但是这样会牺牲一定的性能。eureka server 在对readWriteCacheMap 进行操作时，需要加锁。具体的禁用配置如下，这里同时也禁用了eureka的保护模式：

server:
    
    port: 8761
    
    eureka:
    
    client:
    
    register-with-eureka: false
    
    fetch-registry: false
    
    service-url:
    
    defaultZone: http://localhost:8761/eureka/
    
    server:
    
    enable-self-preservation: false #禁用保护模式
    
    use-read-only-response-cache: false #禁用readOnlyCacheMap