本篇內(nèi)容主要講解“EurekaServer自動裝配方法及啟動流程”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“EurekaServer自動裝配方法及啟動流程”吧!

創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設,樂山企業(yè)網(wǎng)站建設,樂山品牌網(wǎng)站建設,網(wǎng)站定制,樂山網(wǎng)站建設報價,網(wǎng)絡營銷,網(wǎng)絡優(yōu)化,樂山網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

@EnableEurekaServer注解

我們知道，在使用Eureka作為注冊中心的時候，我們會在啟動類中增加一個@EnableEurekaServer注解，這個注解我們是一個自定義的EnableXXX系列的注解，主要作用我們之前也多次提到了，就是引入配置類而已。看一下源碼吧

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import({EurekaServerMarkerConfiguration.class})
public @interface EnableEurekaServer {
}

引入了一個配置類EurekaServerMarkerConfiguration，看一下這個類的具體內(nèi)容

@Configuration
public class EurekaServerMarkerConfiguration {

	@Bean
	public Marker eurekaServerMarkerBean() {
		return new Marker();
	}

	class Marker {
	}
}

現(xiàn)在看這里好像難以理解，這是啥意思，搞個空的類干啥的，不要著急，接著往下看

自動裝配

既然注解上沒有找到我們想要的東西，那么就看一下spring.factories文件吧，這里自動配置的實現(xiàn)類是EurekaServerAutoConfiguration

由于這個類涉及的代碼實在是太多了，這里就不貼了，咱們直接來解析這個類：

1. 引入EurekaServerInitializerConfiguration類

看名字就知道了這個類是負責Eureka的初始化工作的，這個類實現(xiàn)了SmartLifecycle接口，所以在spring初始化和銷毀的時候，就會分別調(diào)用它的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，然后發(fā)布了一些啟動事件，來看啟動的過程吧

public void contextInitialized(ServletContext context) {
                try {
            //初始化執(zhí)行環(huán)境
                        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);
                }
        }

這里一共包含初始化環(huán)境和初始化上下文兩個分支

初始化執(zhí)行環(huán)境

這個不是很重要，可以過濾掉

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 環(huán)境，默認為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集群數(shù)據(jù)
                int registryCount = this.registry.syncUp();
                this.registry.openForTraffic(this.applicationInfoManager, registryCount);

                // 注冊監(jiān)控統(tǒng)計信息
                EurekaMonitors.registerAllStats();
        }

這個方法中同步集群數(shù)據(jù)和注冊監(jiān)控信息都涉及的內(nèi)容比較多，所以本篇文章就不再展開了，請關注我留意后續(xù)文章

@ConditionalOnBean({Marker.class})

看到這里就揭開了開篇@EnableEurekaServer注解注入的那個bean的含義了。也就是說如果咱們的啟動類沒有使用@EnableEurekaServer注解的話，這個自動配置類就不會執(zhí)行，那也就沒有Eureka的事了

@EnableConfigurationProperties({EurekaDashboardProperties.class, InstanceRegistryProperties.class})

深入這個注解發(fā)現(xiàn)這個還是使用的@Import注解的機制引入了兩個類，這個注解在之前的源碼解析文章中也多次提到了，這里就不展開了

EurekaDashboardProperties這個類比較簡單，主要是Eureka的控制臺的相關配置

//控制臺默認路徑
private String path = "/";
//是否開啟控制臺
private boolean enabled = true;

InstanceRegistryProperties，這個類是控制Eureka的注冊時的配置信息

    //每分鐘續(xù)約次數(shù)
    @Value("${eureka.server.expectedNumberOfRenewsPerMin:1}") 
	private int expectedNumberOfRenewsPerMin = 1;
    //默認打開的通信數(shù)量
	@Value("${eureka.server.defaultOpenForTrafficCount:1}")
	private int defaultOpenForTrafficCount = 1;

@PropertySource("classpath:/eureka/server.properties")

相信大家比較熟悉這個注解，加載Eureka的配置文件而已

配置文件中也僅僅只包含這個信息

spring.http.encoding.force=false

自動注入的bean

EurekaServerAutoConfiguration類上幾個注解就解析完了，接著看一下這個類中注入的幾個比較重要的類吧

配置類EurekaServerConfigBeanConfiguration

EurekaServerConfig如果當前應用允許注冊到其他Eureka服務中時，也就是屬性eureka.client.fetch-registry為true時。就設置屬性registrySyncRetries的值為5，這個屬性的意思是當Eureka服務器啟動時嘗試去獲取集群里其他服務器上的注冊信息的次數(shù)

EurekaController

這個就是Eureka自己的controller了，控制臺的相關信息就是從這里獲取的

ServerCodecs

設置Eureka的序列化工具

PeerAwareInstanceRegistry

集群注冊信息同步相關的類，請期待后續(xù)深入解析文章

FilterRegistrationBean

到此，相信大家對“EurekaServer自動裝配方法及啟動流程”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關內(nèi)容可以進入相關頻道進行查詢，關注我們，繼續(xù)學習！

當前名稱：EurekaServer自動裝配方法及啟動流程
URL標題：http://aaarwkj.com/article4/pcssoe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供域名注冊、做網(wǎng)站、全網(wǎng)營銷推廣、網(wǎng)站收錄、Google、網(wǎng)站設計公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)