2013 中国网站建设市场 pdf,个人网站审批,电商小程序怎么做,住房和城乡建设部网站村镇建设毫无疑问#xff0c;微服务架构是目前的主流#xff0c;在微服务架构下#xff0c;服务治理、负载均衡、服务熔断、配置中心、API网关 等都是需要关注的问题#xff0c;当然不是非要全部完善后才能进行微服务开发#xff0c;在很多项目团队中#xff0c;初期可能会将某个… 毫无疑问微服务架构是目前的主流在微服务架构下服务治理、负载均衡、服务熔断、配置中心、API网关 等都是需要关注的问题当然不是非要全部完善后才能进行微服务开发在很多项目团队中初期可能会将某个服务部署成集群然后通过 Nginx 代理做到负载均衡提供服务但随着微服务体量逐渐庞大以上提到需要关注的问题就越来越明显。在 .NET Core 环境下目前比较流行的微服务架构Consul服务治理、配置中心 Polly服务熔断 OcelotAPI网关当然这只是一种组合方式。参考NanoFabric[1]今天主要介绍一下如何通过 Spring Cloud 下的 Eureka 来实现服务注册与发现Spring Cloud 是 Java 平台提供的一套解决方案提供了微服务的基础功能包括 Eureka服务治理、Config配置中心、Hystrix服务熔断、ZuulAPI网关等。至于为什么要将 .NET Core 服务融合 Spring Cloud 来部署毫无疑问这只是一种结合方案如果团队是 Java .NET 如果恰好需要尝试一下也为何不可。SteeltoeSteeltoe[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 的依赖dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-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.ymlspring: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.ymlserver: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 方法添加 AddDiscoveryClientpublic void ConfigureServices(IServiceCollection services)
{services.AddDiscoveryClient(Configuration);services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
}
修改 Startup.cs 的 Configure 方法添加 UseDiscoveryClientpublic 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).UseStartupStartup();
再新建一个项目其他都一致端口改成 5002启动 2 个 base-service 成功后在 Eureka 中查看如下创建 .NET Core 客户端服务客户端服务需要调用基础服务与基础服务的主要不同如下appsettings.json拉取注册信息shouldFetchRegistrytrue添加 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.AddTransientDiscoveryHttpMessageHandler();// 指定 BaseService 内使用的 HttpClient 在发送请求前通过 DiscoveryHttpMessageHandler 解析 BaseAddress 为已注册服务的 host:port
services.AddHttpClient(base-service, c
{c.BaseAddress new Uri(Configuration[services:base-service:url]);
})
.AddHttpMessageHandlerDiscoveryHttpMessageHandler()
.AddTypedClientIBaseService, BaseService();
添加 BaseService 的封装public interface IBaseService
{Taskstring GetValueAsync();
}public class BaseService : IBaseService
{private readonly HttpClient _httpClient;public BaseService(HttpClient httpClient){_httpClient httpClient;}public async Taskstring 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
