动态感知Nacos服务地址和ribbon远程调用优雅上下线.pdf

动态感知Nacos服务地址和ribbon远程调⽤优雅

上下线

背景

远程调⽤⼀般都会⽤ribbon，尽管使⽤feign，还是⽤的ribbon做的负载均衡，远程调⽤。但是ribbon

会每隔30s刷新注册表信息，这样就会导致如果服务下线了，由于注册表没有及时更新，那远程调⽤就

会报错。

ribbon默认实现如下。

om.netflix.loadbalaner.PollingServerListUpdater
这个类是ribbon更新注册表的

核⼼类。

nacos
动态更新地址原理

Nacos客⼾端中有⼀个HostReactor类，它的功能是实现服务的动态更新，基本原理是：

•客⼾端发起时间订阅后，在HostReactor中有⼀个UpdateTask线程，每10s发送⼀次Pull请求，获

得服务端必威体育精装版的地址列表

•对于服务端，它和服务提供者的实例之间维持了⼼跳检测，⼀旦服务提供者出现异常，则会发送⼀

个Push消息给Nacos客⼾端，也就是服务端消费者

•服务消费者收到请求之后，使⽤HostReactor中提供的processServiceJSON解析消息，并更新本地

服务地址列表

改造ribbon默认更新策略

基于上⾯的理论，是不是可以监听nacos事件更新事件，如果有更新，就重新刷新下ribbon的注册表。

1.覆盖ServerListUpdater,⾃⼰定义⼀个NacosDynamicServerListUpdater代码如下；

1publilassNaosDynamiServerListUpdaterimplementsServerListUpdater{

2privatestatiLoggerlog=LoggerFatory.getLogger(NaosDynamiServerListUp

3

4privateCopyOnWriteArrayListLBUpdaterlbUpdaters=newCopyOnWriteArrayLis

5

6privateNamingServienamingServie;

7

8@Value(${ribbon.PollingServerListUpdater.initial-delay:1000})

9privatelonginitialDelay;

10@Value(${ribbon.PollingServerListUpdater.refresh-interval:30000})

11privatelongrefreshInterval;

12

13privateNaosDisoveryPropertiesproperties;

14

15publiNaosDynamiServerListUpdater(NamingServienamingServie,NaosDiso

16this.namingServie=namingServie;

17this.properties=properties;

18}

19

20@Override

21publivoidstart(UpdateAtionupdateAtion){

22NaosDynamiServerListUpdater.LBUpdaterlbUpdater=newNaosDynamiServ

23this.lbUpdaters.add(lbUpdater);

24lbUpdater.start();

25log.info(naosdslu-started:{},lbUpdater:{},PollingServerListUpdate

26newObjet[]{this,lbUpdater.getIdentity(),this.initialDelay,t

27}

28

29@Override