如何使用Spring Cloud构建微服务架构？

　　@RestController public class StatisticsController { @Autowired private StatisticsService statisticsService; @RequestMapping(value = "/{accountName}", method = RequestMethod.PUT) public void saveStatistics(@PathVariable String accountName, @Valid @RequestBody Account account) { statisticsService.save(accountName, account); } }

　　在 Account 服务中，如果要调用 Statistics 服务，都应该通过 StatisticsServiceClient 接口进行调用。

　　例如，Account 服务中的 AccountServiceImpl 要调用 updateStatistics() 方法，就可以在该类的实现中通过 @autowired 注入 StatisticsServiceClient 接口：

　　@Service public class AccountServiceImpl implements AccountService { @Autowired private StatisticsServiceClient statisticsClient; @Autowired private AccountRepository repository; @Override public void saveChanges(String name, Account update) { //... statisticsClient.updateStatistics(name, account); } }

　　Notification 服务对 Account 服务的调用如法炮制。

　　服务容错保护

　　在微服务架构中，微服务之间可能存在依赖关系，例如 Notification Service 会调用 Account Service，Account Service 调用 Statistics Service。

　　真实产品中，微服务之间的调用会更加寻常。倘若上游服务出现了故障，就可能会因为依赖关系而导致故障的蔓延，最终导致整个系统的瘫痪。

　　Spring Cloud Hystrix 通过实现断路器(Circuit Breaker)模式以及线程隔离等功能，实现服务的容错保护。

　　仍然参考前面的例子，现在系统的微服务包括：

　　上游服务：demo-service

　　下游服务：demo-consumer

　　Eureka 服务器：eureka-server

　　假设上游服务可能会出现故障，为保证系统的健壮性，需要在下游服务中加入容错包含功能。

　　首先需要在 demo-consumer 服务中添加对 Hystrix 的依赖：

　　<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId> </dependency>

　　然后在 demo-consumer 的应用程序类中加入 @EnableCircuitBreaker 开启断路器功能：

　　@EnableCircuitBreaker @EnableDiscoveryClient @SpringBootApplication public class ConsumerApplication { @Bean @LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(ConsumerApplication.class, args) } }

　　注意：Spring Cloud 提供了 @SpringCloudApplication 注解简化如上代码。该注解事实上已经包含了前面所述的三个注解。

　　@SpringCloudApplication 注解的定义如下所示：

（编辑：PHP编程网 - 湛江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!