微服务Spring Cloud Alibaba之我见

如果你正在寻找一个Spring Cloud Netflix的替代方案，建议可以看下这篇和Spring Cloud Alibaba相关的文章。

Spring Cloud还支持另一个流行的阿里巴巴开源组件--Sentinel，他负责流量控制、并发、断路和负载保护。

1. 运行Nacos服务器

cmd nacos/bin/startup.cmd -m standalone

默认情况下，Nacos从端口8848开始。它提供/nacos/v1下的HTTP API，以及地址http://localhost:8848/nacos下的管理web控制台。如果查看日志，您会发现它只是一个使用SpringFramework编写的应用程序。

org.springframework.cloudspring-cloud-dependenciesFinchley.SR2pomimportorg.springframework.cloudspring-cloud-alibaba-dependencies0.2.0.RELEASEpomimport

Spring Cloud Alibaba为当前支持的组件提供了三个启动器。这些是使用Nacos进行服务发现的spring-cloud-starter-alibaba-nacos-discovery、用于分布式配置的spring-cloud-starter-alibaba-nacos-config以及用于限流降级的spring-cloud-starter-alibaba-sentinel。

org.springframework.cloudspring-cloud-starter-alibaba-nacos- discoveryorg.springframework.cloudspring-cloud-starter-alibaba-nacos- configorg.springframework.cloudspring-cloud-starter-alibaba-sentinel

3. 使用Nacos启用分布式配置

spring:application:name: employee-servicecloud:nacos:  config:    server-addr: localhost:8848

我们的应用程序尝试与Nacos连接，并获取在文件中提供的与属性spring.application.name的值同名的配置。目前，Spring Cloud Alibaba只支持.properties文件，因此我们需要在文件employee-service.properties内创建配置。

好消息是，它在修改了Nacos之后会动态刷新应用程序配置。在应用程序中，您唯一要做的就是注释应该用@RefreshScope或@ConfigurationProperties刷新的bean。

@Repository@ConfigurationProperties(prefix = "repository")public class EmployeeRepository {private List < Employee > employees = new ArrayList < > ();public List < Employee > getEmployees() {return employees;}public void setEmployees(List < Employee > employees) {this.employees = employees;}public Employee add(Employee employee) {employee.setId((long)(employees.size() + 1));employees.add(employee);return employee;}public Employee findById(Long id) {Optional < Employee > employee = employees.stream().filter(a - > a.getId().equals(id)).findFirst();if (employee.isPresent())return employee.get();elsereturn null;}public List < Employee > findAll() {return employees;}public List < Employee > findByDepartment(Long departmentId) {return employees.stream().filter(a -> a.getDepartmentId().equals(departmentId)).collect(Collectors.toList());}public List < Employee > findByOrganization(Long organizationId) {return employees.stream().filter(a -> a.getOrganizationId().equals(organizationId)).collect(Collectors.toList());}}

现在，您可以更改一些属性值，如下图所示。然后，如果调用在端口8090（http://localhost:8090）上可用的employee-service，您应该会看到具有修改值的雇员的完整列表。

对于我们另外两个微服务，部门服务和组织服务，应该创建相同的配置属性。假设您已经完成了，那么您应该在Nacos上具有以下配置条目。

4. 使用Nacos启用服务发现

spring: application:   name: employee-service cloud: nacos:  discovery:    server-addr: localhost:8848

最后一步是通过使用@EnableDiscoveryClient注释主类来为应用程序启用发现客户端。

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

如果您为所有的微服务提供相同的实现并运行它们，您将在Nacos Web控制台中看到以下已注册的应用程序列表。

@FeignClient(name = "employee-service")public interface EmployeeClient {@GetMapping("/department/{departmentId}")List < Employee > findByDepartment(@PathVariable("departmentId") Long departmentId);}

不要忘记为Spring Boot应用程序启用Feign客户端。

@SpringBootApplication@EnableDiscoveryClient@EnableFeignClients@EnableSwagger2public class DepartmentApplication {public static void main(String[] args) {SpringApplication.run(DepartmentApplication.class, args);}}

org.springframework.cloudspring-cloud-starter-alibaba-nacos-discoveryorg.springframework.cloudspring-cloud-starter-alibaba-nacos-configorg.springframework.cloudspring-cloud-starter-netflix-zuul

在包括所需的依赖项之后，我们需要为应用程序启用Zuul代理和发现客户端。

@SpringBootApplication@EnableDiscoveryClient@EnableZuulProxy@EnableSwagger2public class ProxyApplication {public static void main(String[] args) {SpringApplication.run(ProxyApplication.class, args);}}

以下是为我们的三个示例微服务定义的Zuul路由的配置：

zuul:  routes:  department:    path: /department/**  serviceId: department-serviceemployee:  path: /employee/**  serviceId: employee-serviceorganization:  path: /organization/**  serviceId: organization-service

在运行网关之后，它为所有定义的微服务公开的API公开了Swagger2规范。假设您已经在端口8080上运行了它，那么您可以在地址http://localhost:8080/swagger-ui.html下访问它。由于这个原因，您可以从一个单独的位置调用方法。