本篇内容主要讲解“EurekaServer自动装配方法及启动流程”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“EurekaServer自动装配方法及启动流程”吧!
创新互联公司是一家集网站建设,乐山企业网站建设,乐山品牌网站建设,网站定制,乐山网站建设报价,网络营销,网络优化,乐山网站推广为一体的创新建站企业,帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿,时刻以成就客户成长自我,坚持不断学习、思考、沉淀、净化自己,让我们为更多的企业打造出实用型网站。
@EnableEurekaServer
注解我们知道,在使用Eureka作为注册中心的时候,我们会在启动类中增加一个@EnableEurekaServer
注解,这个注解我们是一个自定义的EnableXXX系列的注解,主要作用我们之前也多次提到了,就是引入配置类而已。看一下源码吧
@Target({ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented @Import({EurekaServerMarkerConfiguration.class}) public @interface EnableEurekaServer { }
引入了一个配置类EurekaServerMarkerConfiguration
,看一下这个类的具体内容
@Configuration public class EurekaServerMarkerConfiguration { @Bean public Marker eurekaServerMarkerBean() { return new Marker(); } class Marker { } }
现在看这里好像难以理解,这是啥意思,搞个空的类干啥的,不要着急,接着往下看
既然注解上没有找到我们想要的东西,那么就看一下spring.factories
文件吧,这里自动配置的实现类是EurekaServerAutoConfiguration
由于这个类涉及的代码实在是太多了,这里就不贴了,咱们直接来解析这个类:
看名字就知道了这个类是负责Eureka的初始化工作的,这个类实现了SmartLifecycle
接口,所以在spring初始化和销毁的时候,就会分别调用它的start和stop方法
首先看一下start方法
public void start() { new Thread(new Runnable() { @Override public void run() { try { //启动EurekaServer eurekaServerBootstrap.contextInitialized(EurekaServerInitializerConfiguration.this.servletContext); log.info("Started Eureka Server"); publish(new EurekaRegistryAvailableEvent(getEurekaServerConfig())); EurekaServerInitializerConfiguration.this.running = true; publish(new EurekaServerStartedEvent(getEurekaServerConfig())); } catch (Exception ex) { // Help! log.error("Could not initialize Eureka servlet context", ex); } } }).start(); }
这个代码好像比较直接了当啊,直接就起个线程启动了EurekaServer,然后发布了一些启动事件,来看启动的过程吧
public void contextInitialized(ServletContext context) { try { //初始化执行环境 initEurekaEnvironment(); //初始化上下文 initEurekaServerContext(); context.setAttribute(EurekaServerContext.class.getName(), this.serverContext); } catch (Throwable e) { log.error("Cannot bootstrap eureka server :", e); throw new RuntimeException("Cannot bootstrap eureka server :", e); } }
这里一共包含初始化环境和初始化上下文两个分支
这个不是很重要,可以过滤掉
protected void initEurekaEnvironment() throws Exception { log.info("Setting the eureka configuration.."); //AWS相关的东西,可以忽略 String dataCenter = ConfigurationManager.getConfigInstance() .getString(EUREKA_DATACENTER); if (dataCenter == null) { log.info( "Eureka data center value eureka.datacenter is not set, defaulting to default"); ConfigurationManager.getConfigInstance() .setProperty(ARCHAIUS_DEPLOYMENT_DATACENTER, DEFAULT); } else { ConfigurationManager.getConfigInstance() .setProperty(ARCHAIUS_DEPLOYMENT_DATACENTER, dataCenter); } //设置 Eureka 环境,默认为test String environment = ConfigurationManager.getConfigInstance() .getString(EUREKA_ENVIRONMENT); if (environment == null) { ConfigurationManager.getConfigInstance() .setProperty(ARCHAIUS_DEPLOYMENT_ENVIRONMENT, TEST); log.info( "Eureka environment value eureka.environment is not set, defaulting to test"); } else { ConfigurationManager.getConfigInstance() .setProperty(ARCHAIUS_DEPLOYMENT_ENVIRONMENT, environment); } }
protected void initEurekaServerContext() throws Exception { // 设置json与xml序列化工具 JsonXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(), XStream.PRIORITY_VERY_HIGH); XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(), XStream.PRIORITY_VERY_HIGH); if (isAws(this.applicationInfoManager.getInfo())) { this.awsBinder = new AwsBinderDelegate(this.eurekaServerConfig, this.eurekaClientConfig, this.registry, this.applicationInfoManager); this.awsBinder.start(); } EurekaServerContextHolder.initialize(this.serverContext); log.info("Initialized server context"); // 同步Eureka集群数据 int registryCount = this.registry.syncUp(); this.registry.openForTraffic(this.applicationInfoManager, registryCount); // 注册监控统计信息 EurekaMonitors.registerAllStats(); }
这个方法中同步集群数据和注册监控信息都涉及的内容比较多,所以本篇文章就不再展开了,请关注我留意后续文章
看到这里就揭开了开篇@EnableEurekaServer
注解注入的那个bean的含义了。也就是说如果咱们的启动类没有使用@EnableEurekaServer
注解的话,这个自动配置类就不会执行,那也就没有Eureka的事了
深入这个注解发现这个还是使用的@Import
注解的机制引入了两个类,这个注解在之前的源码解析文章中也多次提到了,这里就不展开了
EurekaDashboardProperties
这个类比较简单,主要是Eureka的控制台的相关配置
//控制台默认路径 private String path = "/"; //是否开启控制台 private boolean enabled = true;
InstanceRegistryProperties
,这个类是控制Eureka的注册时的配置信息
//每分钟续约次数 @Value("${eureka.server.expectedNumberOfRenewsPerMin:1}") private int expectedNumberOfRenewsPerMin = 1; //默认打开的通信数量 @Value("${eureka.server.defaultOpenForTrafficCount:1}") private int defaultOpenForTrafficCount = 1;
相信大家比较熟悉这个注解,加载Eureka的配置文件而已
配置文件中也仅仅只包含这个信息
spring.http.encoding.force=false
EurekaServerAutoConfiguration
类上几个注解就解析完了,接着看一下这个类中注入的几个比较重要的类吧
EurekaServerConfig如果当前应用允许注册到其他Eureka服务中时,也就是属性eureka.client.fetch-registry
为true时。就设置属性registrySyncRetries
的值为5,这个属性的意思是当Eureka服务器启动时尝试去获取集群里其他服务器上的注册信息的次数
这个就是Eureka自己的controller了,控制台的相关信息就是从这里获取的
设置Eureka的序列化工具
集群注册信息同步相关的类,请期待后续深入解析文章
到此,相信大家对“EurekaServer自动装配方法及启动流程”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!