SpringCloud源碼--SpringCloudConfig工作流程

首先,我是前端 轉(zhuǎn) PHP 轉(zhuǎn) JAVA 的以為小白,文中講的不對的地方請?zhí)岢鰜恚矚g迎來噴

起因是我司使用Eureka注冊中心和 Configserver配置中心來達(dá)到多服務(wù)共享配置的問題娃属,我好奇是如何從配置中心獲取配置后爆存,將配置寫入消費(fèi)方的蛉顽。
這便引發(fā)了我4個小時追代碼的過程


Eureka

廢話不多說,首先說說Eureka是個什么東西先较,其實(shí)我也不知道是啥携冤!
首先先上一張看不懂的圖片,好吧我承認(rèn)闲勺,這是我看過理解最快的一張圖片了

image.png

EurekaNetflix 開發(fā)的曾棕,一個基于 REST 服務(wù)的,服務(wù)注冊與發(fā)現(xiàn)的組件

它主要包括兩個組件:Eureka Server 和 Eureka Client

  • Eureka Client:一個Java客戶端菜循,用于簡化與 Eureka Server 的交互(通常就是微服務(wù)中的客戶端和服務(wù)端)
  • Eureka Server:提供服務(wù)注冊和發(fā)現(xiàn)的能力(通常就是微服務(wù)中的注冊中心)

各個微服務(wù)啟動時翘地,會通過 Eureka Client 向 Eureka Server 注冊自己,Eureka Server 會存儲該服務(wù)的信息

也就是說癌幕,每個微服務(wù)的客戶端和服務(wù)端衙耕,都會注冊到 Eureka Server,這就衍生出了微服務(wù)相互識別的話題

  • 同步:每個 Eureka Server 同時也是 Eureka Client(邏輯上的)
       多個 Eureka Server 之間通過復(fù)制的方式完成服務(wù)注冊表的同步序芦,形成 Eureka 的高可用
  • 識別:Eureka Client 會緩存 Eureka Server 中的信息
       即使所有 Eureka Server 節(jié)點(diǎn)都宕掉臭杰,服務(wù)消費(fèi)者仍可使用緩存中的信息找到服務(wù)提供者(筆者已親測)
  • 續(xù)約:微服務(wù)會周期性(默認(rèn)30s)地向 Eureka Server 發(fā)送心跳以Renew(續(xù)約)信息(類似于heartbeat)
  • 續(xù)期:Eureka Server 會定期(默認(rèn)60s)執(zhí)行一次失效服務(wù)檢測功能
       它會檢查超過一定時間(默認(rèn)90s)沒有Renew的微服務(wù),發(fā)現(xiàn)則會注銷該微服務(wù)節(jié)點(diǎn)

Spring Cloud 已經(jīng)把 Eureka 集成在其子項(xiàng)目 Spring Cloud Netflix 里面

以上都是拷貝的谚中,說白了渴杆,Eureka做的就是接口轉(zhuǎn)發(fā)的概念


SpringCloudConfig

Spring Cloud Config 的官方介紹文檔地址如下:
https://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_spring_cloud_config

英語好的自己讀吧,我是懶得看

大致意思是宪塔,Spring Cloud Config 提供一種基于客戶端與服務(wù)端(C/S)模式的分布式的配置管理磁奖。我們可以把我們的配置管理在我們的應(yīng)用之外(config server 端),并且可以在外部對配置進(jìn)行不同環(huán)境的管理某筐,比如開發(fā)/測試/生產(chǎn)環(huán)境隔離比搭,并且還能夠做到實(shí)時更新配置。


現(xiàn)在要看是追源碼了D咸堋I砼怠蜜托!

首先,配置文件中找到了Eureka的配置項(xiàng)

spring.application.name=quickstart-sample
eureka.client.serviceUrl.defaultZone=${QUICKSTART_EUREKAS:http://${QUICKSTART_USERNAME:admin}:${QUICKSTART_PASSWORD:123123}@localhost:20000/eureka/}
spring.cloud.config.profile=framework,test
spring.cloud.config.label=development-wayne
spring.cloud.config.discovery.enabled=true
spring.cloud.config.discovery.serviceId=configserver
spring.cloud.config.username=${QUICKSTART_USERNAME:admin}
spring.cloud.config.password=${QUICKSTART_PASSWORD:123123}

找到這些霉赡,我依舊是一頭霧水橄务,好吧,我自閉了~~我想放棄了~
開了15分鐘小差穴亏,我決定從Maven包下手

在項(xiàng)目中找到spring-cloud-config-client-2.1.0.RELEASE.jar這個JAR包蜂挪,并隨便打開一個文件下載源碼(聽起來好高大上,我大PHP直接看vendor什么時候還要下載源碼嗓化,哼~~)

全局搜索serviceId

image.png

看棠涮,這里有用到誒!刺覆!
那既然有 set 那就一定有 get严肪,我繼續(xù)找下去,找到getServiceId()的調(diào)用方出現(xiàn)了
image.png

無意間看了眼上面谦屑,嗯~~ 我猜這應(yīng)該是心跳吧诬垂,他是定時的從配置中心獲取配置。

繼續(xù)走~


在源碼的127行我發(fā)現(xiàn)了this.config.setUri(uri)字眼伦仍,無奈的看了下下面只剩下catch了,算了很洋,就研究這個config吧充蓝!
image.png

一樣的思維,有set 就一定有 get
image.png

在這里我找到了最終獲取數(shù)據(jù)的地方

response = restTemplate.exchange(uri + path, HttpMethod.GET, entity,
                        Environment.class, args);

接下來就涉及到返回?cái)?shù)據(jù)的地方了喉磁,轉(zhuǎn)眼到spring-cloud-config-server-2.1.0.RELEASE.jar這個包中谓苟,我們可以看到SpringCloudConfig定義了一個名為EnvironmentController這樣的控制器。

在控制器中我們找到了根據(jù)上面uri + path的方式請求的入口协怒,

@RequestMapping("/{name}/{profiles}/{label:.*}")
    public Environment labelled(@PathVariable String name, @PathVariable String profiles,
            @PathVariable String label) {
        if (name != null && name.contains("(_)")) {
            // "(_)" is uncommon in a git repo name, but "/" cannot be matched
            // by Spring MVC
            name = name.replace("(_)", "/");
        }
        if (label != null && label.contains("(_)")) {
            // "(_)" is uncommon in a git branch name, but "/" cannot be matched
            // by Spring MVC
            label = label.replace("(_)", "/");
        }
        Environment environment = this.repository.findOne(name, profiles, label);
        if(!acceptEmpty && (environment == null || environment.getPropertySources().isEmpty())){
             throw new EnvironmentNotFoundException("Profile Not found");
        }
        return environment;
    }

我這里在配置文件中設(shè)置了spring.cloud.config.server.jdbc=true所以我這里是走的數(shù)據(jù)庫涝焙,還有其他的讀取配置方式,可自行查閱
根絕我設(shè)置的jdbc方式
上面的findOne使用了JdbcEnvironmentRepository中的實(shí)現(xiàn)方式
最后在第95行找到了

Map<String, String> next = (Map<String, String>) jdbc.query(this.sql,
                        new Object[] { app, env, label }, this.extractor);

這里的sql可通過配置spring.cloud.config.server.jdbc.sql進(jìn)行復(fù)寫
如果沒有復(fù)寫孕暇,那么就使用JdbcEnvironmentProperties中默認(rèn)的SQL語句SELECT KEY, VALUE from PROPERTIES where APPLICATION=? and PROFILE=? and LABEL=?

好了仑撞,configserver完成了他的任務(wù)(東西好少啊,感覺很容易就找到了)妖滔∷硐回過頭,我們又要看消費(fèi)方拿到了返回值做了些什么W帷沮翔!

ConfigServicePropertySourceLocator文件中我們看到,其實(shí)configserver做了一個攔截曲秉,在啟動的時候把配置寫了進(jìn)去

在同文件104行終于找到了最后的方法采蚀,通過CompositePropertySource將配置加載到程序中

for (PropertySource source : result.getPropertySources()) {
    @SuppressWarnings("unchecked")
    Map<String, Object> map = (Map<String, Object>) source
                            .getSource();
    composite.addPropertySource(new MapPropertySource(source.getName(), map));
}

其實(shí)我想追一下CompositePropertySource的源碼疲牵,但是我餓~~~~~~了,
第一次寫看源碼的筆記,可能有些地方我自己懂了就跳過了榆鼠,如果哪里沒寫出來纲爸,歡迎提出來

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市璧眠,隨后出現(xiàn)的幾起案子缩焦,更是在濱河造成了極大的恐慌,老刑警劉巖责静,帶你破解...
    沈念sama閱讀 216,591評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件袁滥,死亡現(xiàn)場離奇詭異,居然都是意外死亡灾螃,警方通過查閱死者的電腦和手機(jī)题翻,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,448評論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來腰鬼,“玉大人嵌赠,你說我怎么就攤上這事∠ㄉ模” “怎么了姜挺?”我有些...
    開封第一講書人閱讀 162,823評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長彼硫。 經(jīng)常有香客問我炊豪,道長,這世上最難降的妖魔是什么拧篮? 我笑而不...
    開封第一講書人閱讀 58,204評論 1 292
  • 正文 為了忘掉前任词渤,我火速辦了婚禮,結(jié)果婚禮上串绩,老公的妹妹穿的比我還像新娘缺虐。我一直安慰自己,他們只是感情好礁凡,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,228評論 6 388
  • 文/花漫 我一把揭開白布高氮。 她就那樣靜靜地躺著,像睡著了一般把篓。 火紅的嫁衣襯著肌膚如雪纫溃。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,190評論 1 299
  • 那天韧掩,我揣著相機(jī)與錄音紊浩,去河邊找鬼。 笑死,一個胖子當(dāng)著我的面吹牛坊谁,可吹牛的內(nèi)容都是我干的费彼。 我是一名探鬼主播,決...
    沈念sama閱讀 40,078評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼口芍,長吁一口氣:“原來是場噩夢啊……” “哼箍铲!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起鬓椭,我...
    開封第一講書人閱讀 38,923評論 0 274
  • 序言:老撾萬榮一對情侶失蹤颠猴,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后小染,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體翘瓮,經(jīng)...
    沈念sama閱讀 45,334評論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,550評論 2 333
  • 正文 我和宋清朗相戀三年裤翩,在試婚紗的時候發(fā)現(xiàn)自己被綠了资盅。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,727評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡踊赠,死狀恐怖呵扛,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情筐带,我是刑警寧澤今穿,帶...
    沈念sama閱讀 35,428評論 5 343
  • 正文 年R本政府宣布,位于F島的核電站伦籍,受9級特大地震影響荣赶,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜鸽斟,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,022評論 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望利诺。 院中可真熱鬧富蓄,春花似錦、人聲如沸慢逾。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,672評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽侣滩。三九已至口注,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間君珠,已是汗流浹背寝志。 一陣腳步聲響...
    開封第一講書人閱讀 32,826評論 1 269
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人材部。 一個月前我還...
    沈念sama閱讀 47,734評論 2 368
  • 正文 我出身青樓毫缆,卻偏偏與公主長得像,于是被迫代替她去往敵國和親乐导。 傳聞我的和親對象是個殘疾皇子苦丁,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,619評論 2 354

推薦閱讀更多精彩內(nèi)容