Nacos服务发现并发启动scheduleUpdate定时任务的流程分析

 更新时间:2023年02月23日 09:18:17   作者:秃秃爱健身  
这篇文章主要介绍了Nacos服务发现并发启动scheduleUpdate定时任务,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

一、前言

博主今天复习Nacos源码的时候,发现了一个算是有意思的细节点,这里分享一下。

二、服务发现“懒加载”机制

当nacos客户端运⾏起来之后,它只是去做服务注册、配置获取等操作;并不会立即去请求服务信息;当第一次请求时候,才会去获取服务,即懒加载机制

1、服务发现流程

Client端做服务发现时,无论是否能从本地缓存中获取到服务实例信息,都会启动一个定时任务(每秒做一次服务实例信息的更新)。然而由于可能多个请求同时要做服务发现,这样总不能每一次做服务发现时都去启动一个定时任务做服务实例信息更新吧。所以肯定要有一个机制去确保针对某一个Cluster下的Service,当前Client只会启动一个定时任务。

2、HostReactor#scheduleUpdateIfAbsent()

HostReactor#scheduleUpdateIfAbsent()方法负责启动做服务实例信息更新的定时任务。
从方法名也能看出来:是当定时任务不存在时,才会启动一个定时任务。

private final Map<String, ScheduledFuture<?>> futureMap = new HashMap<String, ScheduledFuture<?>>();

public void scheduleUpdateIfAbsent(String serviceName, String clusters) {
    if (futureMap.get(ServiceInfo.getKey(serviceName, clusters)) != null) {
        return;
    }
    
    synchronized (futureMap) {
        if (futureMap.get(ServiceInfo.getKey(serviceName, clusters)) != null) {
            return;
        }
        
        ScheduledFuture<?> future = addTask(new UpdateTask(serviceName, clusters));
        futureMap.put(ServiceInfo.getKey(serviceName, clusters), future);
    }
}

看一下这个代码逻辑:

  • 为了防止一个实例开启多个这种定时任务,会用一个Map来去重,针对这个Map的数据添加会采用一个类似双重检查锁的机制,确保Map添加数据的线程安全性。
  • 如果futureMap中已经有了当前服务,则方法直接返回。
  • 这一步是为了减少不必要的同步操作。
  • 否则,对futureMap对象加synchronized锁;同步代码块需要再进一步判断futureMap不为空。
  • 因为在多线程并发场景下,可能多个线程判断futureMap中都没有当前服务,都进入到同步代码块,一个线程进入同步代码块,将当前服务添加到futureMap中。
  • 其他线程获取到锁之后再进入到同步代码块,再次判断futureMap中是否含有当前服务,如果含有,则方法直接返回。
  • 假如同步代码中不判空,会重复执行将当前服务添加到futureMap中的操作。

既然是DCL的变种版,为了futureMap没有被volatile关键字修饰,不会有指令重排序的问题吗?

  • 并不会,futureMap.put()是Map的添加数据操作,和对象初始化是两种场景。

3、DCL

Double check Lock确保类单例的代码如下:

public class DoubleCheckLazySingleton {

    private volatile static DoubleCheckLazySingleton singleton;

    private DoubleCheckLazySingleton() {
    }

    public DoubleCheckLazySingleton getSingleton() {
        if (singleton == null) {
            synchronized (this) {
                //只有在singleton为null的时候才创建实例
                if (singleton == null) {
                    singleton = new DoubleCheckLazySingleton();
                }
            }
        }
        return singleton;
    }
}

到此这篇关于Nacos服务发现并发启动scheduleUpdate定时任务的文章就介绍到这了,更多相关Nacos服务发现内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • SpringBoot数据库初始化datasource配置方式

    SpringBoot数据库初始化datasource配置方式

    这篇文章主要为大家介绍了SpringBoot数据库初始化datasource配置方式,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-12-12
  • Java1.8中StringJoiner的使用及源码详析

    Java1.8中StringJoiner的使用及源码详析

    在看String类时,看到有使用StringJoiner类,所以顺便看了下StringJoiner类,下面这篇文章主要给大家介绍了关于Java 1.8中StringJoiner的使用及源码分析的相关资料,需要的朋友可以参考借鉴,下面来一起看看吧
    2018-08-08
  • MyBatis的五种批量插入详解

    MyBatis的五种批量插入详解

    这篇文章主要介绍了MyBatis的五种批量插入详解,MyBatis是一款半自动的ORM持久层框架,具有较高的SQL灵活性,支持高级映射(一对一,一对多),动态SQL,延迟加载和缓存等特性,但它的数据库无关性较低,需要的朋友可以参考下
    2023-08-08
  • java定义数组的三种类型总结

    java定义数组的三种类型总结

    下面小编就为大家带来一篇java定义数组的三种类型总结。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-10-10
  • spring boot对敏感信息进行加解密的项目实现

    spring boot对敏感信息进行加解密的项目实现

    本文主要介绍了spring boot对敏感信息进行加解密的项目实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Java list如何根据id获取子节点

    Java list如何根据id获取子节点

    这篇文章主要介绍了Java list如何根据id获取子节点,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • 详解Java中的BigDecimal

    详解Java中的BigDecimal

    这篇文章主要介绍了Java中的BigDecimal的使用方法,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-09-09
  • java 线程池的实现原理、优点与风险、以及4种线程池实现

    java 线程池的实现原理、优点与风险、以及4种线程池实现

    这篇文章主要介绍了java 线程池的实现原理、优点与风险、以及4种线程池实现包括了:配置线程池大小配置,线程池的实现原理等,需要的朋友可以参考下
    2023-02-02
  • 详解SpringBoot如何使用Redis和Redis缓存

    详解SpringBoot如何使用Redis和Redis缓存

    这篇文章主要为大家详细介绍了SpringBoot如何使用Redis和Redis缓存,文中的示例代码讲解详细,对我们学习SpringBoot有一定的帮助,需要的可以参考一下
    2022-06-06
  • 图解分析Javaweb进程与线程

    图解分析Javaweb进程与线程

    这篇文章主要介绍了Javaweb进程与线程的知识,本篇文章通过简要的案例,讲解了它的基础原理与使用,以下就是详细内容,需要的朋友可以参考下
    2022-03-03

最新评论