2023-09-15  阅读(0)
原文作者:王伟王胖胖 原文地址:https://blog.csdn.net/wangwei19871103/article/details/105610087

前言

有了springboot的一些基础,可以开始springcloud进阶啦,目前微服务比较流行的大致这三类,zookeeper
+dubbo,spring cloud netflix,alibaba,而netflix这套东西好多都停止维护了,可能要被alibaba的代替了,当然这些都能了解那最好了,以后做计数选型的时候就可以根据不同场景和业务选更好的匹配技术。netflix虽然大多停止维护了,但是还是很经典的,所以还是想从这个经典的微服务框架分析下这些组件的一些原理和源码,更好的理解微服务,其实更多的是一种设计思想,废话不多说,我们开始吧。

初始化基本流程图

202309152310019281.png

EurekaServer注册中心

首先这个这么用的我就不多说了,这些框架用起来确实简单,几个注解就好了,我们还是分析下原理比较好,先从服务端,也就是注册中心开始。如果还没用过的话可以去了解下,不然可能看不懂。我们知道配置注册中心只需要一个注解,加点配置即可,配置怎么加我就不说了,我们来说说注解@EnableEurekaServer

EnableEurekaServer注解

202309152310032152.png
没干什么,就将Marker类注册到容器中,我们可以猜到,这个对象是标记对象,也就是说可能自动配置里会根据这个标记做什么事对吧。

202309152310037603.png
其他什么都没了,因为我们学过springboot自动配置啦,相关的肯定是在spring.factories中啦,一般这种框架命名还是很规范的,其实直接可以去找xxxAutoConfiguration类:

202309152310042814.png

202309152310047335.png

EurekaServerAutoConfiguration

可以看到这里有个条件注解ConditionalOnBean,因为自动配置解析处理是在其他配置类处理完后处理的,所以这个时候容器里已经有Markerbean定义了,所以这个条件满足了,因为可以解析EurekaServerAutoConfiguration了。关于这个类干了点什么,后面会说,但是有个很重要的地方跟初始化有关,就是实例化EurekaServerBootstrap,而这个又依赖EurekaServerContext,后面初始化跟他们有关:

202309152310054356.png
然后,我要说的是被importEurekaServerInitializerConfiguration

202309152310061457.png

EurekaServerInitializerConfiguration

这个名字一样就是初始化的,关键在SmartLifecycle,他用SmartLifecyclestart回调来初始化。

202309152310067108.png
看到了吧,初始化的时候跟EurekaServerBootstrapEurekaServerContext有关。

202309152310072279.png

EurekaServerContext

从依赖关系上看,最早被实例化初始化完成的应该是EurekaServerContext,其实他就是服务上下文,应该是跟我们的服务器相关的,我们来看看他有什么特性,在他的一个initialize方法上有初始化之前注解PostConstruct

2023091523100787210.png
因为他在初始化之前会被处理:

2023091523100851911.png

RefreshablePeerEurekaNodes的start

这个对象是依赖注入进来的,看名字好像是做集群结点启动的。其实他做的就是开一个单线程,然后定时去更新集群结点信息,因为我们集群的话配置文件里会进行相互配置,就是用来做这个相互注册的,默认好像600秒一次。具体怎么做的可以去updatePeerEurekaNodes看看,其实就是拿到其他结点的地址,进行网络通信,只是底层是用Jersey的,当然里面还涉及一些批量任务,延迟执行的,有兴趣可以去看看。

     public void start() {
            taskExecutor = Executors.newSingleThreadScheduledExecutor(//单线程任务
                    new ThreadFactory() {
                        @Override
                        public Thread newThread(Runnable r) {
                            Thread thread = new Thread(r, "Eureka-PeerNodesUpdater");
                            thread.setDaemon(true);
                            return thread;
                        }
                    }
            );
            try {
                updatePeerEurekaNodes(resolvePeerUrls());//更新集群其他结点,里面会创建
                Runnable peersUpdateTask = new Runnable() {
                    @Override
                    public void run() {
                        try {
                            updatePeerEurekaNodes(resolvePeerUrls());//定时更新
                        } catch (Throwable e) {
                            logger.error("Cannot update the replica Nodes", e);
                        }
    
                    }
                };
                taskExecutor.scheduleWithFixedDelay(//启动定时任务
                        peersUpdateTask,
                        serverConfig.getPeerEurekaNodesUpdateIntervalMs(),
                        serverConfig.getPeerEurekaNodesUpdateIntervalMs(),
                        TimeUnit.MILLISECONDS
                );
            } catch (Exception e) {
                throw new IllegalStateException(e);
            }
            for (PeerEurekaNode node : peerEurekaNodes) {
                logger.info("Replica node URL:  {}", node.getServiceUrl());
            }
        }

PeerAwareInstanceRegistryImpl的init

这里做一些服务端要初始化的事,比如需要有缓存,他的缓存同了三级,读缓存,读写缓存,注册表,具体后面会说,然后开启了一个续约阈值更新的定时任务,默认900秒一次,这个跟后面自动保护机制相关。

        @Override
        public void init(PeerEurekaNodes peerEurekaNodes) throws Exception {
            this.numberOfReplicationsLastMin.start();
            this.peerEurekaNodes = peerEurekaNodes;
            initializedResponseCache();//创建服务端缓存,读缓存,读写缓存等
            scheduleRenewalThresholdUpdateTask();//开启续约阈值更新任务
            initRemoteRegionRegistry();
    
            try {
                Monitors.registerObject(this);
            } catch (Throwable e) {
                logger.warn("Cannot register the JMX monitor for the InstanceRegistry :", e);
            }
        }

EurekaServerContext的初始化基本说完了,后面说EurekaServerInitializerConfiguration的初始化。

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。


Java 面试宝典是大明哥全力打造的 Java 精品面试题,它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题,而是一套完整的 Java 知识体系,一套你 Java 知识点的扫盲贴。

它的内容包括:

  • 大厂真题:Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
  • 原创内容:Java 面试宝典内容全部都是大明哥原创,内容全面且通俗易懂,回答部分可以直接作为面试回答内容。
  • 持续更新:一次购买,永久有效。大明哥会持续更新 3+ 年,累计更新 1000+,宝典会不断迭代更新,保证最新、最全面。
  • 覆盖全面:本宝典累计更新 1000+,从 Java 入门到 Java 架构的高频面试题,实现 360° 全覆盖。
  • 不止面试:内容包含面试题解析、内容详解、知识扩展,它不仅仅只是一份面试题,更是一套完整的 Java 知识体系。
  • 宝典详情:https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
  • 宝典总览:https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
  • 宝典进展:https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道,总字数 42w+。大明哥还在持续更新中,下图是大明哥在 2024-12 月份的更新情况:

想了解详情的小伙伴,扫描下面二维码加大明哥微信【daming091】咨询

同时,大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ,回复【面试题】 即可免费领取。

阅读全文