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 ApplicationEvent之事件发布与监听机制详解

    SpringBoot ApplicationEvent之事件发布与监听机制详解

    本文将深入探讨SpringBoot的事件机制,介绍其核心概念、实现方法及最佳实践,帮助开发者构建更加灵活、可维护的应用架构,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2025-04-04
  • SpringBoot集成RabbitMQ实现用户注册的示例代码

    SpringBoot集成RabbitMQ实现用户注册的示例代码

    这篇文章主要介绍了SpringBoot集成RabbitMQ实现用户注册的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • Java连接数据库实现方式

    Java连接数据库实现方式

    文章讲述了Java连接MySQL数据库的详细步骤,包括下载和导入JDBC驱动、创建数据库和表、以及编写连接和读取数据的代码
    2024-11-11
  • SparkStreaming整合Kafka过程详解

    SparkStreaming整合Kafka过程详解

    这篇文章主要介绍了SparkStreaming整合Kafka过程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧
    2023-01-01
  • Java struts2请求源码分析案例详解

    Java struts2请求源码分析案例详解

    这篇文章主要介绍了Java struts2请求源码分析案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • Spring执行sql脚本文件的方法

    Spring执行sql脚本文件的方法

    这篇文章主要介绍了Spring执行sql脚本文件的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2019-03-03
  • Java解析调用webservice服务的返回XML串详解

    Java解析调用webservice服务的返回XML串详解

    这篇文章主要介绍了Java解析调用webservice服务的返回XML串详解的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-07-07
  • SpringBoot+Vue静态资源刷新后无法访问的问题解决方案

    SpringBoot+Vue静态资源刷新后无法访问的问题解决方案

    这篇文章主要介绍了SpringBoot+Vue静态资源刷新后无法访问的问题解决方案,文中通过代码示例和图文讲解的非常详细,对大家解决问题有一定的帮助,需要的朋友可以参考下
    2024-05-05
  • Springboot中加入druid连接池

    Springboot中加入druid连接池

    这篇文章主要介绍了Springboot中加入druid连接池,Druid是目前最好的数据库连接池。在功能、性能、扩展性方面,都超过其他数据库连接池,同时加入了日志监控,下面来看看文章的具体内容吧
    2022-01-01
  • 使用新版Maven-mvnd快速构建项目

    使用新版Maven-mvnd快速构建项目

    本文主要介绍了使用新版Maven-mvnd来快速构建项目,相比于Maven,mvnd可以显著提高构建速度,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧
    2025-01-01

最新评论