.NET Core + Spring Cloud:服务注册与发现

PatrickHulda 发布于1年前

毫无疑问,微服务架构是目前的主流,在微服务架构下,服务治理、负载均衡、服务熔断、配置中心、API网关 等都是需要关注的问题,当然不是非要全部完善后才能进行微服务开发,在很多项目团队中,初期可能会将某个服务部署成集群,然后通过 Nginx 代理做到负载均衡提供服务,但随着微服务体量逐渐庞大,以上提到需要关注的问题就越来越明显。在 .NET Core 环境下,目前比较流行的微服务架构:Consul(服务治理、配置中心)+ Polly(服务熔断)+ Ocelot(API网关),当然这只是一种组合方式。参考: NanoFabric

今天主要介绍一下如何通过 Spring Cloud 下的 Eureka 来实现服务注册与发现,Spring Cloud 是 Java 平台提供的一套解决方案,提供了微服务的基础功能,包括 Eureka(服务治理)、Config(配置中心)、Hystrix(服务熔断)、Zuul(API网关)等。

至于为什么要将 .NET Core 服务融合 Spring Cloud 来部署,毫无疑问,这只是一种结合方案,如果团队是 Java + .NET, 如果恰好需要,尝试一下也为何不可。

Steeltoe

Steeltoe 是 .NET 与 Spring Cloud 结合的桥梁,Steeltoe 客户端库使 .NET Core 和 .NET Framework 应用程序能够轻松利用 Spring Cloud 的 Eureka、Hystrix、Config Server、云平台服务 等核心组件。更多资料请参考官方文档: http://steeltoe.io/docs/

搭建 Eureka Server

  1. 在 IntelliJ IDEA 中新建项目,选 Spring Initializr 完成项目创建

  2. 在 pom.xml 添加 eureka-server 的依赖

    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
  3. 在启动类上添加 EnableEurekaServer 注解

    @EnableEurekaServer
    @SpringBootApplication
    public class EurekaServiceApplication {
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaServiceApplication.class, args);
    	}
    }
  4. 修改配置文件,模拟搭建 Eureka Server 集群

    .NET Core + Spring Cloud:服务注册与发现

    application.yml

    spring:
      application:
    	# 服务名
    	name: eureka-service
      profiles:
    	# 默认使用 server1 配置
    	active: server1

    application-server1.yml

    server:
      port: 8001
    
    eureka:
      instance:
    	hostname: server1
    	# 超过这个时间没收到心跳就剔除这个服务,这个配置一般为服务刷新时间配置的三倍,默认90s
    	lease-expiration-duration-in-seconds: 15
    	# 服务刷新时间,默认30s
    	lease-renewal-interval-in-seconds: 5
      client:
    	service-url:
    	  defaultZone: http://server1:8001/eureka/,http://server2:8002/eureka/,http://server3:8003/eureka/
    	# eureka client 刷新本地缓存时间,默认30s
    	registry-fetch-interval-seconds: 5
      server:
    	# eureka server 刷新 readCacheMap 的时间,client 读取的是 readCacheMap,默认30s
    	response-cache-update-interval-ms: 3000
    	# 服务下线任务定时,默认60s
    	eviction-interval-timer-in-ms: 3000

    application-server2.yml 和 application-server3.yml 与 server1 类似,只需 port 和 hostname 作调整。hostname 对应的名称需要修改电脑的 C:\Windows\System32\drivers\etc\HOSTS 文件添加映射关系

    127.0.0.1 server1
    127.0.0.1 server2
    127.0.0.1 server3
  5. 修改启动配置

    .NET Core + Spring Cloud:服务注册与发现

  6. 启动成功,访问: http://server1:8001 ( 当前 Availability Zones 为 3

    .NET Core + Spring Cloud:服务注册与发现

创建 .NET Core 基础服务

基础服务只提供服务,不引用其他服务

  1. 创建 .NET Core WebApi 项目
  2. Nuget 添加 Steeltoe.Discovery.ClientCore 引用(目前版本 2.1.1)
  3. 修改 Startup.cs 的 ConfigureServices 方法,添加 AddDiscoveryClient

    public void ConfigureServices(IServiceCollection services)
    {
    	services.AddDiscoveryClient(Configuration);
    	services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
    }
  4. 修改 Startup.cs 的 Configure 方法,添加 UseDiscoveryClient

    public void Configure(IApplicationBuilder app, IHostingEnvironment env)
    {
    	if (env.IsDevelopment())
    	{
    		app.UseDeveloperExceptionPage();
    	}
    	app.UseMvc();
    	app.UseDiscoveryClient();
    }
  5. 修改配置文件 appsettings.json,更多配置请参考 eureka-client-settings

    {
      "spring": {
    	"application": {
    	  "name": "base-service"
    	}
      },
      "eureka": {
    	"client": {
    	  "serviceUrl": "http://server1:8001/eureka/",
    	  "shouldRegisterWithEureka": true,
    	  "shouldFetchRegistry": false // 不需要获取注册信息,只提供服务
    	},
    	"instance": {
    	  "port": 5001
    	}
      }
    }
  6. 修改 program.cs,添加 UseUrls,端口与 appsettings.json port 一致

    public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
    	WebHost.CreateDefaultBuilder(args)
    	.UseUrls("http://*:5001")
    	.UseStartup<Startup>();
  7. 再新建一个项目,其他都一致,端口改成 5002

  8. 启动 2 个 base-service 成功后在 Eureka 中查看如下:

    .NET Core + Spring Cloud:服务注册与发现

    .NET Core + Spring Cloud:服务注册与发现

    .NET Core + Spring Cloud:服务注册与发现

创建 .NET Core 客户端服务

客户端服务需要调用基础服务

与基础服务的主要不同如下:

  1. 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/"
    	}
      }
    }
  2. 修改 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>();
  3. 添加 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;
    	}
    }
  4. 启动 client-service 成功后在 Eureka 中查看如下:

    .NET Core + Spring Cloud:服务注册与发现

  5. 通过访问 http://server1:6001/api/values 查看调用 base-service 返回结果,因为 base-service 有 2 个服务,所以会自动做到负载均衡

.NET Core + Spring Cloud:服务注册与发现

.NET Core + Spring Cloud:服务注册与发现

查看原文: .NET Core + Spring Cloud:服务注册与发现

  • biggoose
  • blackfrog
  • smallleopard
  • greengorilla
  • organicmouse
  • heavybear
  • GracieMatt
  • JohnAbner