这样构建微服务架构，实在是太轻松了！

本文摘要：作者：Alexander Lukyanchikov 译者：Oopsguy原文：dzone.com/articles/microservice-architecture-with-spring-cloud-and-do【编者的话】如何使用Spring Boot、Spring Cloud、Docker和Netflix的一些开源工具来构建一个微服务架构。

作者：Alexander Lukyanchikov 译者：Oopsguy原文：dzone.com/articles/microservice-architecture-with-spring-cloud-and-do【编者的话】如何使用Spring Boot、Spring Cloud、Docker和Netflix的一些开源工具来构建一个微服务架构。本文通过使用Spring Boot、Spring Cloud和Docker构建的观点型应用示例，提供了相识常见的微服务架构模式的起点。该代码可以在GitHub上获得，而且在Docker Hub上提供了镜像。

您只需要一个下令即可启动整个系统。https://github.com/sqshq/PiggyMetrics我选择了一个老项目作为这个系统的基础，它的后端以前是单一应用。此应用提供了处置惩罚小我私家财政、整理收入开销、治理储蓄、分析统计和建立简朴预测等功效。功效服务整个应用剖析为三个焦点微服务。

它们都是可以独立部署的应用，围绕着某些业务功效举行组织。账户服务包罗一般用户输入逻辑和验证：收入/开销记载、储蓄和账户设置。统计服务盘算主要的统计参数，并捕捉每一个账户的时间序列。

数据点包罗基于钱币和时间段正常化后的值。该数据可用于跟踪账户生命周期中的现金流量动态。通知服务存储用户的联系信息和通知设置（如提醒和备份频率）。摆设事情人员从其它服务收集所需的信息并向订阅的客户发送电子邮件。

注意每一个微服务拥有自己的数据库，因此没有措施绕过API直接会见持久数据。在这个项目中，我使用MongoDB作为每一个服务的主数据库。

拥有一个多种类持久化架构（polyglot persistence architecture）也是很有意义的。服务间（Service-to-service）通信是很是简朴的：微服务仅使用同步的REST API举行通信。现实中的系统的常见做法是使用互动气势派头的组合。例如，执行同步的GET请求检索数据，并通过消息署理（broker）使用异步方法执行建立/更新操作，以便排除服务缓和冲消息之间的耦合。

然而，这带给我们是最终的一致性。基础设施服务漫衍式系统中常见的模式，可以资助我们形貌焦点服务是怎样事情的。Spring Cloud提供了强大的工具，可以增强Spring Boot应用的行为来实现这些模式。我会简要先容一下：设置服务Spring Cloud Config是漫衍式系统的水平扩展集中式设置服务。

它使用了当前支持的当地存储、Git和Subversion等可拔插存储库层（repository layer）。在此项目中，我使用了native profile，它简朴地从当地classpath下加载设置文件。您可以在设置服务资源中检察shared目录。现在，当通知服务请求它的设置时，设置服务将响应回shared/notification-service.yml和shared/application.yml（所有客户端应用之间共享）。

客户端使用只需要使用sprng-cloud-starter-config依赖构建Spring Boot应用，自动设置将会完成其它事情。现在您的应用中不需要任何嵌入的properties，只需要提供有应用名称和设置服务url的bootstrap.yml即可：spring:application:name:notification-servicecloud:config:uri:http://config:8888fail-fast:true使用Spring Cloud Config，您可以动态更改应用设置好比，EmailService bean使用了@RefreshScope注解。这意味着您可以更改电子邮件的内容和主题，而无需重新构建和重启通知服务应用。

首先，在设置服务器中更改须要的属性。然后，对通知服务执行刷新请求：curl -H "Authorization: Bearer #token#" -XPOST http://127.0.0.1:8000/notifications/refresh。您也可以使用webhook来自动执行此历程。http://cloud.spring.io/spring-cloud-config/spring-cloud-config.html#_push_notifications_and_spring_cloud_bus注意动态刷新存在一些限制。

@RefreshScope不能和@Configuraion类一同事情，而且不会作用于@Scheduled方法。fail-fast属性意味着如果Spring Boot应用无法毗连到设置服务，将会立刻启动失败。当您一起启动所有应用时，这很是有用。

下面有重要的宁静提示授权服务卖力授权的部门被完全提取到单独的服务器，它为后端资源服务提供OAuth2令牌。授权服务器用于用户授权以及在周边内举行宁静的机械间通信。在此项目中，我使用密码凭据作为用户授权的授权类型（因为它仅由当地应用UI使用）和客户端凭据作为微服务授权的授权类型。

Spring Cloud Security提供了利便的注解和自动设置，使其在服务器端或者客户端都可以很容易地实现。您可以在文档中相识到更多信息，并在授权服务器代码中检查设置明细。

授权服务器代码：https://github.com/sqshq/PiggyMetrics/tree/master/auth-service/src/main/java/com/piggymetrics/auth从客户端来看，一切都与传统的基于会话的授权完全相同。您可以从请求中检索Principal工具、检查用户角色和其它基于表达式会见控制和@PreAuthorize注解的内容。PiggyMetrics（帐户服务、统计服务、通知服务和浏览器）中的每一个客户端都有一个规模：用于后台服务的服务器、用于浏览器展示的UI。

所以我们也可以掩护控制器制止受到外部会见，例如：@PreAuthorize("#oauth2.hasScope('server')")@RequestMapping(value="accounts/{name}",method=RequestMethod.GET)publicList<DataPoint>getStatisticsByAccountName(@PathVariableStringname){returnstatisticsService.findByAccountName(name);}API网关您可以看到，有三个焦点服务。它们向客户端袒露外部API。在现实系统中，这个数量可以很是快速地增长，同时整个系统将变得很是庞大。实际上，一个庞大页面的渲染可能涉及到数百个服务。

理论上，客户端可以直接向每个微服务直接发送请求。可是这种方式是存在挑战和限制的，如果需要知道所有端点的地址，划分对每一段信息执行http请求，将效果合并到客户端。另一个问题是，这不是web友好协议，可能只在后端使用。

通常一个更好的方法是使用API网关。它是系统的单个入口点，用于通过将请求路由到适当的后端服务或者通过挪用多个后端服务并聚合效果来处置惩罚请求。此外，它还可以用于认证、insights、压力测试、金丝雀测试（canary testing）、服务迁移、静态响应处置惩罚和主动变换治理。

聚合效果：http://techblog.netflix.com/2013/01/optimizing-netflix-api.htmlNetflix开源这样的边缘服务，现在用Spring Cloud，我们可以用一个@EnabledZuulProxy注解来启用它。在这个项目中，我使用Zuul存储静态内容（UI应用），并将请求路由到适当的微服务。以下是一个简朴的基于前缀（prefix-based）路由的通知服务设置：zuul:routes:notification-service:path:/notifications/**serviceId:notification-servicestripPrefix:false这意味着所有以/notification开头的请求将被路由到通知服务。您可以看到，内里没有硬编码的地址。

Zuul使用服务发现机制来定位通知服务实例以及断路器和负载平衡器，如下所述。服务发现另一种常见的架构模式是服务发现。它允许自动检测服务实例的网络位置，由于自动扩展、故障和升级，它可能会动态分配地址。服务发现的关键部门是注册。

我使用Netflix Eureka举行这个项目，当客户端需要卖力确定可以用的服务实例（使用注册服务器）的位置和跨平台的负载平衡请求时，Eureka就是客户端发现模式的一个很好的例子。使用Spring Boot，您可以使用spring-cloud-starter-eureka-server依赖、@EnabledEurekaServer注解和简朴的设置属性轻松构建Eureka注册中心（Eureka Registry）。

使用@EnabledDiscoveryClient注解和带有应用名称的bootstrap.yml来启用客户端支持：spring:application:name:notification-service现在，在应用启动时，它将向Eureka服务器注册并提供元数据，如主机和端口、康健指示器URL、主页等。Eureka吸收来自附属于某服务的每个实例的心跳消息。如果心跳失败凌驾设置的时间表，该实例将从注册表中删除。

此外，Eureka还提供了一个简朴的界面，您可以通过它来跟踪运行中的服务和可用实例的数量：http://localhost:8761负载平衡器、断路器和Http客户端Netflix OSS提供了另一套很棒的工具。RibbonRibbon是一个客户端负载平衡器，可以很好地控制HTTP和TCP客户端的行为。与传统的负载平衡器相比，每次线上挪用都不需要分外的跳跃——您可以直接联系所需的服务。它与Spring Cloud和服务发现是集成在一起的，可开箱即用。

Eureka客户端提供了可用服务器的动态列表，因此Ribbon可以在它们之间举行平衡。HystrixHystrix是断路器模式的一种实现，它可以通过网络会见依赖来控制延迟和故障。中心思想是在具有大量微服务的漫衍式情况中停止级联故障。

这有助于快速失败并尽快恢复——自我修复在容错系统中是很是重要的。除了断路器控制，在使用Hystrix，您可以添加一个备用方法，在主下令失败的情况下，该方法将被挪用以获取默认值。此外，Hystrix生成每个下令的执行效果和延迟的怀抱，我们可以用它来监视系统的行为。FeignFeign是一个声明式HTTP客户端，能与Ribbon和Hystrix无缝集成。

实际上，通过一个spring-cloud-starter-feign依赖和@EnabledFeignClients注解，您可以使用一整套负载平衡器、断路器和HTTP客户端，并附带一个合理的的默认设置。以下是账户服务的示例：@FeignClient(name="statistics-service")publicinterfaceStatisticsServiceClient{@RequestMapping(method=RequestMethod.PUT,value="/statistics/{accountName}",consumes=MediaType.APPLICATION_JSON_UTF8_VALUE)voidupdateStatistics(@PathVariable("accountName")StringaccountName,Accountaccount);}您需要的只是一个接口您可以在Spring MVC控制器和Feign方法之间共享@RequestMapping部门以上示例仅指定所需要的服务ID——statistics-service，这得益于Eureka的自动发现（但显然您可以使用特定的URL会见任何资源）。

监控仪表盘在这个项目设置中，Hystrix的每一个微服务都通过Spring Cloud Bus（通过AMQP broker）将指标推送到Turbine。监控项目只是一个使用了Turbine和Hystrix仪表盘的小型Spring Boot应用。

让我们看看系统行为在负载下：账户服务挪用统计服务和它在一个变化的模拟延迟下的响应。响应超时阈值设置为1秒。

日志分析集中式日志记载在实验查找漫衍式情况中的问题时很是有用。Elasticsearch、Logstash和Kibana技术栈可让您轻松搜索和分析您的日志、使用率和网络运动数据。

在我的另一个项目中已经有现成的Docker设置。宁静高级宁静设置已经凌驾了此观点性项目的规模。为了更真实地模拟真实系统，请思量使用https和JCE密钥库来加密微服务密码和设置服务器的properties内容（有关详细信息，请参阅文档）。

基础设施自动化部署微服务比部署单一的应用的流程要庞大得多，因为它们相互依赖。拥有完全基础设置自动化是很是重要的。

我们可以通过连续交付的方式获得以下利益：随时公布软件的能力。任何构建都可能最终成为一个刊行版本。构建工件（artifact）一次，凭据需要举行部署。

这是一个简朴的连续交付事情流程，在这个项目的实现：在此设置中，Travis CI为每一个乐成的Git推送建立了标志镜像。因此，每一个微服务在Docker Hub上的都市有一个latest镜像，而较旧的镜像则使用Git提交的哈希举行标志。如果有需要，可以轻松部署任何一个，并快速回滚。如何运行全部？这真的很简朴，我建议您实验一下。

请记着，您将要启动8个Spring Boot应用、4个MongoDB实例和RabbitMq。确保您的机械上有4GB的内存。

您可以随时通过网关、注册中心、设置、认证服务和账户中心运行重要的服务。运行之前安装Docker和Docker Compose。设置情况变量：CONFIG_SERVICE_PASSWORD, NOTIFICATION_SERVICE_PASSWORD, STATISTICS_SERVICE_PASSWORD, ACCOUNT_SERVICE_PASSWORD, MONGODB_PASSWORD生产模式在这种模式下，所有最新的镜像都将从Docker Hub上拉取。只需要复制docker-compose.yml并执行docker-compose up -d即可。

开发模式如果您想自己构建镜像（例如，在代码中举行一些修改），您需要克隆所有堆栈（repository）并使用Mavne构建工件（artifact）。然后，运行docker-compose -f docker-compose.yml -f docker-compose.dev.yml up -ddocker-compose.dev.yml继续了docker-compose.yml，附带分外设置，可在当地构建镜像，并袒露所有容器端口以利便开发。重要的端点（Endpoint）localhost:80 —— 网关localhost:8761 —— Eureka仪表盘localhost:9000 —— Hystrix仪表盘localhost:8989 —— Turbine stream（Hystrix仪表盘泉源）localhost:15672 —— RabbitMq治理注意所有Spring Boot应用都需要运行设置服务器才气启动。

得益于Spring Boot的fail-fast属性和docker-compsoe的restart:always选项，我们可以同时启动所有容器。这意味着所有依赖的容器将实验重新启动，直到设置服务器启动运行为止。

此外，服务发现机制在所有应用启动后需要一段时间。在实例、Eureka服务器和客户端在其当地缓存中都具有相同的元数据之前，任何服务都不行用于客户端发现，因此可能需要3次心跳。默认的心跳周期为30秒。

-End-加小编微信：xiaobaito，免费获取一份架构师资料。还可以邀请加入咱们的「菜鸟架构」技术群一起讨论技术，克制发广告及垃圾信息哦。热门阅读免费获取一份架构资料！你还在使用fastjson，性能太差了吧！面试官问你的缺点是什么，这么回覆漂亮！Sprinig Boot + Redis 实现接口幂等性！Spring Boot 的自动设置这么牛面试必问：CPU 占用高，如何一击即中！面试再问 Spring Cloud，这20000 字总结！Java8 通用 Builder，它不香吗？。

本文来源：ROR体育在线登录-www.yixiangjituan.com