1. 微服務(wù)之間內(nèi)部調(diào)用實(shí)現(xiàn)方法介紹
在系列三業(yè)務(wù)領(lǐng)域驅(qū)動(dòng)微服務(wù)設(shè)計(jì)的文章中推捐,我們初步劃分了三個(gè)領(lǐng)域:身份認(rèn)證限界上下文锥忿、打車(chē)管理限界上下文季惩、運(yùn)營(yíng)報(bào)表限界上下文。其中運(yùn)營(yíng)報(bào)表限界上下文是打車(chē)管理上下文的下游衣赶。這意味著在落地中,運(yùn)營(yíng)報(bào)表微服務(wù)要調(diào)用打車(chē)管理微服務(wù)提供的接口厚满,來(lái)統(tǒng)計(jì)業(yè)務(wù)數(shù)據(jù)府瞄,生成運(yùn)營(yíng)報(bào)表,運(yùn)營(yíng)報(bào)表微服務(wù)是打車(chē)管理微服務(wù)的內(nèi)部消費(fèi)者碘箍。
在微服務(wù)的開(kāi)發(fā)中遵馆,我們還會(huì)碰到很多微服務(wù)之間內(nèi)部相互調(diào)用的情況鲸郊,特別是對(duì)數(shù)據(jù)服務(wù)的調(diào)用。在Spring Cloud中货邓,有兩種方式可以秆撮,一種是使用RestTemplate,另一種是使用Feign框架逻恐。
RestTemplate調(diào)用另一個(gè)微服務(wù)的接口我們?cè)?a href="http://www.reibang.com/p/2bf723319535" target="_blank">系列五負(fù)載均衡的文章中已經(jīng)講過(guò)具體的實(shí)現(xiàn)像吻,本章不再累述。
Feign是聲明式Web服務(wù)客戶(hù)端复隆,所謂聲明式拨匆,指的是在代碼中,將要調(diào)用的其它內(nèi)部微服務(wù)提供的Restful API聲明為自己的接口挽拂,該接口使用FeignClient注解惭每。聲明后,在本微服務(wù)中就可以通過(guò)接口注入的方式消費(fèi)其它微服務(wù)的提供的Restful API了亏栈。
Feign也內(nèi)置有負(fù)載均衡Ribbon台腥,會(huì)采用輪訓(xùn)式的負(fù)載均衡方式。
2. 代碼實(shí)現(xiàn)及驗(yàn)證
本次代碼實(shí)現(xiàn)模擬兩個(gè)場(chǎng)景:通過(guò)Feign實(shí)現(xiàn)內(nèi)部調(diào)用绒北;通過(guò)Feign實(shí)現(xiàn)負(fù)載均衡的內(nèi)部調(diào)用黎侈;
2.1 新建一個(gè)項(xiàng)目:
在start.spring.io里新建一個(gè)名為“reports”的項(xiàng)目,在依賴(lài)項(xiàng)里額外增加對(duì)feign的依賴(lài)闷游,下載并將該項(xiàng)目導(dǎo)入到NetBeans里峻汉。
2.2 通過(guò)Feign實(shí)現(xiàn)內(nèi)部調(diào)用
1) 在主程序除添加@EnableEurekaClient注解外,同時(shí)添加@EnableFeignClients注解脐往。@EnableFeignClients注解用于開(kāi)啟Feign的功能
2) ?配置Feign Clients項(xiàng)目的屬性休吠,端口設(shè)為2266,微服務(wù)的名稱(chēng)為reporting-service业簿,reporting-service和其它微服務(wù)一樣注冊(cè)在端口號(hào)為1111的Eureka Server上瘤礁。具體配置如下所示:
3) 在BOOKINGCAR-SERVICE微服務(wù)的OrderController包里,新建一個(gè)數(shù)據(jù)服務(wù)的接口getOrderName梅尤,該接口通過(guò)Order ID來(lái)獲取訂單名稱(chēng)
4) 在REPORTING-SERVICE項(xiàng)目下新建一個(gè)package柜思,名為"com.accenture.j2c.bookingcar.reports.clientinterface",在該package下新建一個(gè)OrderClient接口,在該接口里會(huì)將BOOKINGCAR-SERVICE提供的getOrderName的restful API聲明為REPORTING-SERVICE里的OrderClient接口里的一個(gè)方法巷燥。
具體實(shí)現(xiàn)可以分為兩步:
第一步:通過(guò)FeignClient注解酝蜒,首先到Eureka Server找到名字為“BOOKINGCAR-SERVICE"的微服務(wù);
第二步:使用RequestMapping注解聲明BOOKINGCAR-SERVICE微服務(wù)提供的getOrderName的Restful API的入口矾湃, getOrderName的入口為”{BOOKINGCAR-SERVICE}/v1/order/name/{id}"亡脑。
代碼如下:
5) 在REPORTING-SERVICE項(xiàng)目下新建一個(gè)Rest Controller的package,名字為“com.accenture.j2c.bookingcar.reports.controller”,在該包下新建一個(gè)OrderController類(lèi)霉咨,注入REPORTING-SERVICE下的OrderClient接口蛙紫,新建一個(gè)feign_getOrderName接口,在該接口里通過(guò)調(diào)用OrderClient接口中的getOrderName的方法實(shí)現(xiàn)對(duì)BOOKINGCAR-SERVICE微服務(wù)中g(shù)etOrderName的Restful API接口的調(diào)用途戒,代碼如下:
6) 驗(yàn)證
啟動(dòng)Eureka Server, BOOKINGCAR-SERVICE, REPORTING-SERVICE坑傅,打開(kāi)Eureka注冊(cè)中心,顯示如下:
BOOKINGCAR-SERVICE和REPORTINGCAR-SERVICE這兩個(gè)微服務(wù)都已經(jīng)啟動(dòng)喷斋,其中BOOKINGCAR-SERVICE的接口為2227唁毒,REPORTING-SERVICE微服務(wù)的端口為2266。
點(diǎn)擊BOOKIGNCAR-SERVICE后提供的鏈接星爪,輸入請(qǐng)求參數(shù)“v1/order/name/1",獲得id為1的訂單名稱(chēng)
點(diǎn)擊REPORTING-SERVICE后的提供的鏈接浆西,輸入請(qǐng)求參數(shù)“v1/order/1",結(jié)果為:
我們發(fā)現(xiàn)REPORTING-SERVICE里的結(jié)果同BOOKINGCAR-SERVICE里的結(jié)果保持一致,這說(shuō)明了REPORTING-SERVICE已經(jīng)能調(diào)用另一微服務(wù)BOOKINGCAR-SERVICE里開(kāi)放的接口顽腾。
2.3 通過(guò)Feign實(shí)現(xiàn)內(nèi)部調(diào)用的負(fù)載均衡
1) 在REPORTING-SERVICE的"com.accenture.j2c.bookingcar.reports.clientinterface"包下近零,新建一個(gè)接口LBTestClient,在該接口里會(huì)將BOOKINGCAR-SERVICE提供的findServicePort的restful API聲明為REPORTING-SERVICE里的LBTestClient接口里的一個(gè)方法抄肖。BOOKINGCAR-SERVICE里的findServiceReport接口在之前已經(jīng)定義好久信,本次示例繼續(xù)使用該接口:
REPORTING-SERVICE里的LBTestClient接口聲明如下:
2) 在REPORTING-SERVICE里的“com.accenture.j2c.bookingcar.reports.controller“包下,新建一個(gè)類(lèi)LBTestController,在該控制器類(lèi)中注入LBTestClient接口漓摩,新建一個(gè)feign_getPort接口裙士,在該接口里通過(guò)調(diào)用LBTestClient接口中的方法實(shí)現(xiàn)對(duì)BOOKINGCAR-SERVICE微服務(wù)中findServicePort的Restful API接口的調(diào)用,代碼如下:
3) 驗(yàn)證:
重新啟動(dòng)一個(gè)端口號(hào)為2228的BOOKINGCAR-SERVICE微服務(wù)實(shí)例管毙,啟動(dòng)后腿椎,在EUREKA注冊(cè)中心可以看到BOOKINGCAR-SERVICE有兩個(gè)實(shí)例在運(yùn)行,端口號(hào)分別為2227和2228锅风,見(jiàn)下圖:
點(diǎn)擊REPORTING-SERVICE后提供的鏈接,輸入負(fù)載均衡驗(yàn)證的參數(shù)"v1/port"鞍泉,運(yùn)行后顯示結(jié)果如下:
再次運(yùn)行皱埠,結(jié)果如下:
上面結(jié)果驗(yàn)證了Feign內(nèi)置的Ribbon負(fù)載均衡已經(jīng)發(fā)揮作用
3. 總結(jié)
?在Spring Cloud里,微服務(wù)之間的相互調(diào)用可以通過(guò)RestTemplate和Feign兩種方式實(shí)現(xiàn)咖驮。Feign同時(shí)內(nèi)置了Ribbon負(fù)載均衡边器,代碼更加清晰,推薦使用Feign來(lái)實(shí)現(xiàn)微服務(wù)間的相互調(diào)用托修。
代碼:https://github.com/shuxingliu/microservices
利用Spring Cloud實(shí)現(xiàn)微服務(wù)(六)- 服務(wù)網(wǎng)關(guān)
利用Spring Cloud實(shí)現(xiàn)微服務(wù)(五)- 負(fù)載均衡
利用Spring Cloud實(shí)現(xiàn)微服務(wù)(四)- 微服務(wù)實(shí)現(xiàn)與注冊(cè)
利用Spring Cloud實(shí)現(xiàn)微服務(wù)(三)- 業(yè)務(wù)領(lǐng)域驅(qū)動(dòng)微服務(wù)設(shè)計(jì)
利用Spring Cloud實(shí)現(xiàn)微服務(wù)(二)--領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)