天天看點

net core天馬行空系列-微服務篇:全聲明式http用戶端feign快速接入微服務中心nacos

1.前言

hi,大家好,我是三合,距離上一篇部落格已經過去了整整兩年,這兩年裡,部落客通關了《人生》這個遊戲裡的兩大關卡,買房和結婚。最近閑了下來,那麼當然要繼續寫部落格了,今天這篇部落格的主要内容是,net core/.net6中,如何利用SummerBoot(點我打開詳情介紹)中的feign子產品快速接入微服務中心nacos(點我打開詳情介紹),接下來我會從微服務的概念到feign的使用方法,由淺入深的進行介紹。

2.服務與執行個體

服務與執行個體的關系,可以類比為程式員與你我的關系,程式員是服務,我們是執行個體,比如老闆要實作一個功能,那麼他一般會說,交給程式員開發,而不是說交給張三開發,萬一張三離職了,他還要問還有誰是程式員,然後才能說找誰開發,太麻煩了,畢竟老闆的重點是找人開發出來,而不是具體找哪個人,直接說交給程式員開發,那麼無論公司裡哪個程式員離職或者入職,隻要程式員群體有人就行,服務在這裡就起到了一個統一入口,屏蔽底層細節,減少溝通成本的作用。拉回正題,當我們的系統對外提供了api接口給其他系統調用的時候,我們就可以說這個系統對外提供了服務,當然,為了高可用性,我們一般會部署多個站點進行負載均衡,免得一個站點挂了,整個系統就挂了,在微服務中,我們一般稱呼這一個個站點為一個個服務執行個體,服務與執行個體一般是一對多的關系。

3.nacos的安裝

安裝具體參考nacos官網,部落客這裡推薦使用docker的方式安裝,簡單又快速,免得大家邁出微服務第一步的時候就出師未捷身先死。

4.安裝SummerBoot

在nuget中搜尋Summerboot,安裝即可,SummerBoot支援net core 3.1和.net 6。

5. 服務執行個體注冊與服務調用

我們平時調用其他的系統的接口,一般都需要,ip(域名)+port+具體接口,但在nacos中,則可以簡化為,服務名+具體接口,nacos中,服務是一等公民,我們調用的都是服務,至于哪些服務執行個體聯合一起提供了這些服務,則不是我們關心的内容,換言之,nacos中,服務幫我們屏蔽了一個個站點的細節,我們不用去關心要調用的接口的ip位址和端口号。使用nacos服務中心,分為兩步,服務執行個體注冊和服務調用。

5.1 服務執行個體注冊

我們以程式員的身份入職公司,這一步就是服務執行個體注冊,這樣我們就成為我們公司程式員群體中的一員了。拉回正題,服務執行個體注冊就是将我們的應用注冊為服務的一個執行個體,由服務作為對外統一入口,為其他系統提供接口服務,以供他們調用。這裡提一下nacos檢測執行個體是否存活的心跳機制就是執行個體每5秒鐘向nacos注冊中心發送一個心跳包,确認存活狀态。那麼在feign中是如何注冊服務執行個體的呢,非常簡單,隻需要兩步

5.1.1 在配置檔案appsettings.json/appsettings.Development.json中添加nacos的配置資訊

"nacos": {
    //nacos服務位址,如http://172.16.189.242:8848
    "serviceAddress": "http://172.16.189.242:8848/",
    //是否要把應用注冊為服務執行個體
    "registerInstance": true,
    //命名空間id,如832e754e-e845-47db-8acc-46ae3819b638或者public
    "namespaceId": "dfd8de72-e5ec-4595-91d4-49382f500edf",
    //要注冊的服務名
    "serviceName": "test",
    //服務的分組名
    "groupName": "DEFAULT_GROUP",
    //權重,一個服務下有多個執行個體,權重越高,通路到該執行個體的機率越大,比如有些執行個體所在的伺服器配置高,那麼權重就可以大一些,多引流到該執行個體,與上面的參數lbStrategy設定為WeightRandom搭配使用
    "weight": 1,
    //本應用對外的網絡協定,http或https
    "protocol": "http",
    //本應用對外的端口号,比如5000
    "port": 5000
  }
           

每一個配置參數我都添加了詳細的說明,大家注意這裡,我們把應用對外的端口号和協定都配置了,為什麼沒配置ip呢,因為ip可以自動擷取,就免得大家配置了,這裡weight(即權重)參數是什麼意思呢,我們平時部署應用的伺服器的配置有的高,有的低,比如兩台伺服器,A和B,A是4c8g,B是128c256g,那麼明顯B伺服器配置更高,我們就應該把更多的請求配置設定給B伺服器去處理,畢竟能者多勞嘛,那麼我們在A和B伺服器上部署應用,配置weight參數時,A伺服器上的應用應當配置為1,B配置為32,代表1台B伺服器相當于32台A伺服器,這些配置資訊會作為元資訊上傳到nacos中心,這樣我們在服務調用的時候才會知道,該用怎麼樣的方式,什麼ip什麼端口去請求哪個執行個體上的接口。

5.1.2 在StartUp.cs中添加配置

services.AddSummerBoot();
services.AddSummerBootFeign(it =>
{
	it.AddNacos(Configuration);
});
           

僅需這兩步,我們就完成了服務執行個體注冊,運作web程式,然後大家打開nacos的面闆,就可以看到我們注冊的服務,點開服務,也可以看到服務下面的執行個體,至此,我們的服務就可以對外提供服務了。同時啟動多個應用就意味着注冊了多個服務執行個體,注意要配置好相應的端口号。

5.2 服務調用

老闆說把某個需求交給程式員實作,這就是服務調用。那麼我們如何調用别的微服務系統所提供的服務呢?在feign中,這也是非常簡單的,因為feign本身是一個聲明式http用戶端,我們隻需要定義接口,實作類會由SummerBoot架構自動生成,我們在要用到的地方注入接口即可直接調用。feign服務調用分為三步。

5.2.1 在配置檔案appsettings.json/appsettings.Development.json中添加nacos的配置資訊

"nacos": {
    //nacos服務位址,如http://172.16.189.242:8848
    "serviceAddress": "http://172.16.189.242:8848/",
    //用戶端負載均衡算法,一個服務下有多個執行個體,lbStrategy用來挑選服務下的執行個體,預設為Random(随機),也可以選擇WeightRandom(根據服務權重權重後再随機)
    "lbStrategy": "Random",
  }
           

大家應該可以看到,相比于服務執行個體注冊,我們要調用别的微服務系統所提供的服務,要配置的參數要少的多,隻有2個,nacos服務位址和用戶端負載均衡算法,我這裡要解釋一下什麼叫用戶端負載均衡算法,我們将多個應用注冊為服務執行個體後,當我們要調用這個服務時,feign會先請求nacos的接口,擷取這個服務下所有的健康且存活的執行個體,那麼理論上我們請求這些執行個體中的任何一個都是可以的,那麼如何挑選執行個體呢,這裡就涉及到一個用戶端負載均衡算法,避免伺服器配置設定到的流量旱的旱死,澇的澇死。feign在這裡總共實作了2種算法,1.Random算法,即随機從執行個體清單中挑選出一個執行個體去發起請求,根據統計學,當請求量夠大的時候,命中每個執行個體的機率是相同的,是以随機算法也可以稱為平均算法。2.WeightRandom算法,即根據服務執行個體權重權重後再随機,此時要聯系上面對weight參數的講解,A伺服器上的應用的權重是1,B伺服器上的應用的權重是32,那麼如果根據random算法,配置設定給A和B的流量都是50%,這明顯不合理,是以我們根據權重權重後再随機,1+32=33,那麼此時命中A的機率為1/33,命中B的機率為32/33,這樣就合理多了。

5.2.2 在StartUp.cs中添加配置

services.AddSummerBoot();
services.AddSummerBootFeign(it =>
{
	it.AddNacos(Configuration);
});
           

5.2.3 定義調用微服務的接口

普通的feign接口像下面這樣定義即可。注意,如果傳回值是類的話,該類需要具有無參構造函數,否則會反序列化失敗。

[FeignClient(Url = "http://localhost:5001/home")]
public interface ITestFeign
    {
        [PostMapping("/form")]
        Task<Test> TestForm([Body(BodySerializationKind.Form)] Test tt);

        [GetMapping("/query")]
        Task<Test> TestQuery([Query] Test tt);     

        [PostMapping("/json")]
        Task<Test> TestJson([Body(BodySerializationKind.Json)] Test tt);
}
           

微服務的接口定義就要複雜一些,需要設定微服務的名稱ServiceName,分組名稱NacosGroupName(不填則預設DEFAULT_GROUP),命名空間NacosNamespaceId(不填則預設public),以及MicroServiceMode設為true即可。url不用配置,剩下的就和正常的feign接口一樣。

[FeignClient( ServiceName = "test", MicroServiceMode = true,NacosGroupName = "DEFAULT_GROUP", NacosNamespaceId = "dfd8de72-e5ec-4595-91d4-49382f500edf")]
public interface IFeignService
{
	[GetMapping("/home/index")]
	Task<string> TestGet();
}
           

同時ServiceName,NacosGroupName,NacosNamespaceId也支援從配置檔案中讀取,配置項用${}包裹即可,如配置檔案中配置為

{
  "ServiceName": "test",
  "NacosGroupName": "DEFAULT_GROUP",
  "NacosNamespaceId": "dfd8de72-e5ec-4595-91d4-49382f500edf"
}
           

接口定義為

[FeignClient( ServiceName = "${ServiceName}", MicroServiceMode = true,NacosGroupName = "${NacosGroupName}", NacosNamespaceId = "${NacosNamespaceId}")]
public interface IFeignService
{
	[GetMapping("/home/index")]
	Task<string> TestGet();
}
           

定義完接口,就可以在要用到的地方注入,然後直接調用了,是不是覺得很簡單。

6.結尾

更多feign的用法,可參考SummerBoot文檔,也可以加入QQ群:799648362回報建議。同時,如果你覺得這篇文章還不錯的話,請記得一鍵三連(推薦+關注+github star)

繼續閱讀