赞
踩
服务下线时,客户端经常无法感知到。从而导致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
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。