今天有寫文章的時間了,開心。延續上一篇的話題繼續,順便放上一篇的傳送門:點這里。
服務調用
既然服務注冊已經搞完了,那么現在就開始調用這些注冊好的服務。先做一下准備動作,把consul容器跑起來:
打開控制台確認正常:
然后多跑幾個應用程序模擬多點部署:
程序跑完以后檢察一下服務列表:
戳進去看看:
一切准備就緒,完美。然后進入編碼環節。老規矩,直接上碼:
public static string Convert(string consulUri, string centerName, string reqUri) { ConsulClient client = new ConsulClient(x => { x.Address = new Uri(consulUri); x.Datacenter = centerName; }); //獲取consul中注冊的服務列表
var consulServiceList = client.Agent.Services().Result.Response; //統一請求地址
Uri uri = new Uri(reqUri); //取出分組名稱
string groupName = uri.Host; //匹配出對應的服務
var serviceList = consulServiceList.Where(x => x.Value.Service.ToLower().Equals(groupName.ToLower())).ToArray(); //隨機訪問策略
var service = serviceList[new Random().Next(serviceList.Length)].Value; return $"{uri.Scheme}://{service.Address}:{service.Port}{uri.PathAndQuery}"; }
上面是自行封裝的方法,作用很簡單:把通用的請求地址轉換為實際發起請求的地址,比如調用起來是這樣的:
string realUri = ConsulService.Convert("http://127.0.0.1:8700", "dc1", "http://shenzhen-ma/v1/client/base/index");
發現了么,分組名稱“shenzhen-ma”直接替代了具體的ip和端口。這樣做真的可以拿到請求結果么?隨便寫一個測試用的controller:
public async Task<IActionResult> Post() { string realUri = ConsulService.Convert("http://127.0.0.1:8700", "dc1", "http://shenzhen-ma/v1/client/base/index"); string result = await Service.Tool.HttpHelper.Get(realUri); return Ok(result); }
看請求結果:
5001應用程序請求到了5004的數據。多試幾下再看看:
很顯然,通過統一的請求地址,實際的請求分發到了不同的節點上。
復盤一波
到剛才,我已經完成了服務調用這個關鍵步驟。consul做了什么呢?它幫我們把統一的請求地址轉換成了真實發生作用的請求地址。未來如果增加了新的服務器,無需調整,它自己就能夠發現新的服務——這就是大家廣泛理解的服務發現。實際上,這個功能就賦予了我們動態增加節點的能力。能伸能縮,是微服務的一個重要特征。當然,因為沒有配置健康檢查,我的consul現在還不能自動移除不可用的服務,能伸不能縮,很尷尬。這個么,時間有限,放在下一篇文章去寫。這一篇文章能講清楚服務調用,並由此能理解什么是服務發現,我覺得就達標。