毫無疑問，微服務架構是目前的主流，在微服務架構下，服務治理、負載均衡、服務熔斷、配置中心、API網關 等都是需要關注的問題，當然不是非要全部完善后才能進行微服務開發，在很多項目團隊中，初期可能會將某個服務部署成集群，然后通過 Nginx 代理做到負載均衡提供服務，但隨著微服務體量逐漸龐大，以上提到需要關注的問題就越來越明顯。在 .NET Core 環境下，目前比較流行的微服務架構：Consul（服務治理、配置中心）+ Polly（服務熔斷）+ Ocelot（API網關），當然這只是一種組合方式。參考：NanoFabric^[1]

今天主要介紹一下如何通過 Spring Cloud 下的 Eureka ?來實現服務注冊與發現，Spring Cloud 是 Java 平臺提供的一套解決方案，提供了微服務的基礎功能，包括 Eureka（服務治理）、Config（配置中心）、Hystrix（服務熔斷）、Zuul（API網關）等。

至于為什么要將 .NET Core 服務融合 Spring Cloud 來部署，毫無疑問，這只是一種結合方案，如果團隊是 Java + .NET， 如果恰好需要，嘗試一下也為何不可。

Steeltoe

Steeltoe^[2] 是 .NET 與 Spring Cloud 結合的橋梁，Steeltoe 客戶端庫使 .NET Core 和 .NET Framework 應用程序能夠輕松利用 Spring Cloud 的 Eureka、Hystrix、Config Server、云平臺服務 等核心組件。更多資料請參考官方文檔：http://steeltoe.io/docs/

搭建 Eureka Server

在 IntelliJ IDEA 中新建項目，選 Spring Initializr 完成項目創建

在 pom.xml 添加 eureka-server 的依賴

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency>

在啟動類上添加 EnableEurekaServer 注解

@EnableEurekaServer @SpringBootApplication public class EurekaServiceApplication {public static void main(String[] args) {SpringApplication.run(EurekaServiceApplication.class, args);} }

修改配置文件，模擬搭建 Eureka Server 集群

application.yml

spring:application:# 服務名name: eureka-serviceprofiles:# 默認使用 server1 配置active: server1eureka:instance:# 超過這個時間沒收到心跳就剔除這個服務，這個配置一般為服務刷新時間配置的三倍，默認90slease-expiration-duration-in-seconds: 15# 服務刷新時間，默認30slease-renewal-interval-in-seconds: 5client:# eureka client 刷新本地緩存時間，默認30sregistry-fetch-interval-seconds: 5server:# eureka server 刷新 readCacheMap 的時間，client 讀取的是 readCacheMap，默認30sresponse-cache-update-interval-ms: 3000# 服務下線任務定時，默認60seviction-interval-timer-in-ms: 3000

application-server1.yml

server:port: 8001eureka:instance:hostname: server1 client:service-url:defaultZone: http://server2:8002/eureka/,http://server3:8003/eureka/

application-server2.yml 和 application-server3.yml 與 server1 類似，只需 port、hostname、defaultZone 作調整。hostname 對應的名稱需要修改電腦的 C:\Windows\System32\drivers\etc\HOSTS 文件添加映射關系

127.0.0.1 server1 127.0.0.1 server2 127.0.0.1 server3

修改啟動配置

啟動成功，訪問：http://server1:8001 (當前 Availability Zones 為 3）

創建 .NET Core 基礎服務

基礎服務只提供服務，不引用其他服務

創建 .NET Core WebApi 項目

NuGet 添加 Steeltoe.Discovery.ClientCore 引用（目前版本 2.1.1）

修改 Startup.cs 的 ConfigureServices 方法，添加 AddDiscoveryClient

public void ConfigureServices(IServiceCollection services) {services.AddDiscoveryClient(Configuration);services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1); }

修改 Startup.cs 的 Configure 方法，添加 UseDiscoveryClient

public void Configure(IApplicationBuilder app, IHostingEnvironment env) {if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}app.UseMvc();app.UseDiscoveryClient(); }

修改配置文件 appsettings.json，更多配置請參考 eureka-client-settings^[3]

{"spring": {"application": {"name": "base-service"}},"eureka": {"client": {"serviceUrl": "http://server1:8001/eureka/","shouldRegisterWithEureka": true,"shouldFetchRegistry": false // 不需要獲取注冊信息，只提供服務},"instance": {"port": 5001}} }

修改 program.cs，添加 UseUrls，端口與 appsettings.json port 一致

public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>WebHost.CreateDefaultBuilder(args).UseUrls("http://*:5001").UseStartup<Startup>();

再新建一個項目，其他都一致，端口改成 5002

啟動 2 個 base-service 成功后在 Eureka 中查看如下：

創建 .NET Core 客戶端服務

客戶端服務需要調用基礎服務

與基礎服務的主要不同如下：

appsettings.json，拉取注冊信息（shouldFetchRegistry=true），添加 base-service url

{"spring": {"application": {"name": "client-service"}},"eureka": {"client": {"serviceUrl": "http://server1:8001/eureka/","shouldRegisterWithEureka": true,"shouldFetchRegistry": true},"instance": {"port": 6001}},"services": {"base-service": {"url": "http://base-service/"}} }

修改 Startup.cs 的 ConfigureServices 方法

services.AddDiscoveryClient(Configuration); services.AddTransient<DiscoveryHttpMessageHandler>();// 指定 BaseService 內使用的 HttpClient 在發送請求前通過 DiscoveryHttpMessageHandler 解析 BaseAddress 為已注冊服務的 host:port services.AddHttpClient("base-service", c => {c.BaseAddress = new Uri(Configuration["services:base-service:url"]); }) .AddHttpMessageHandler<DiscoveryHttpMessageHandler>() .AddTypedClient<IBaseService, BaseService>();

添加 BaseService 的封裝

public interface IBaseService {Task<string> GetValueAsync(); }public class BaseService : IBaseService {private readonly HttpClient _httpClient;public BaseService(HttpClient httpClient){_httpClient = httpClient;}public async Task<string> GetValueAsync(){var result = await _httpClient.GetStringAsync("api/values");return result;} }

啟動 client-service 成功后在 Eureka 中查看如下：

通過訪問 http://server1:6001/api/values 查看調用 base-service 返回結果，因為 base-service 有 2 個服務，所以會自動做到負載均衡

參考資料

[1]

NanoFabric: https://github.com/geffzhang/NanoFabric

[2]

Steeltoe: http://steeltoe.io/

[3]

eureka-client-settings: http://steeltoe.io/docs/steeltoe-discovery/#1-2-2-eureka-client-settings

總結

以上是生活随笔為你收集整理的.NET Core + Spring Cloud：服务注册与发现的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。