Spring Cloud Alibaba：Nacos Discovery 服务注册与发现

Nacos Discovery 是什么？

服务发现是微服务架构体系中最关键的组件之一。

若是尝试着用手动的方式来给每个客户端来配置全部服务提供者的服务列表是一件很是困难的事，并且也不利于服务的动态扩缩容。Nacos Discovery 能够帮助用户将服务自动注册到 Nacos 服务端而且可以动态感知和刷新某个服务实例的服务列表。

除此以外，Nacos Discovery 也将服务实例自身的一些元数据信息，例如 host，port，健康检查URL，主页等-注册到 Nacos 。
关于 Nacos 的安装及启动请查看文章：Spring Cloud Alibaba：Nacos 安装及使用
本篇将详细介绍 Nacos Discovery 服务注册与发现的一些技术实践。

快速接入

添加依赖

启动好 Nacos 服务端。而后在项目中添加依赖。

<dependency>
 <groupId>com.alibaba.cloud</groupId>
 <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

一个完整的 pom.xml 的配置以下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.xingtuai.example</groupId>
 <artifactId>nacos-discovery-test</artifactId>
 <version>1.0-SNAPSHOT</version>
 <name>nacos-discovery-test</name>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>${spring.boot.version}</version>
 <relativePath/>
 </parent>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
 <dependencyManagement>
 <dependencies>
 <dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-dependencies</artifactId>
 <version>${spring.cloud.version}</version>
 <type>pom</type>
 <scope>import</scope>
 </dependency>
 <dependency>
 <groupId>com.alibaba.cloud</groupId>
 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
 <version>${spring.cloud.alibaba.version}</version>
 <type>pom</type>
 <scope>import</scope>
 </dependency>
 </dependencies>
 </dependencyManagement>
 <dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-actuator</artifactId>
 </dependency>
 <dependency>
 <groupId>com.alibaba.cloud</groupId>
 <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

注：在本项目的源代码中，依赖统一使用 dependencies 模块管理，且其中 dependencyManagement 节点也在 dependencies 模块中配置，上例仅演示必要的配置项，在项目源代码中有些许区别。

启动 Provider 服务提供者

Nacos Discovery 服务注册与发现中，通常有两个角色，一个是 Provider 服务提供者，一个是 Consumer 服务消费者。他们都须要将自身注册到 Naocs 中，这一步叫服务注册。服务提供者向外提供服务，服务消费者经过各类方式调用服务提供者完成业务功能。且一个服务，既能够做为提供者，同时也能够做为消费者。
1. 配置 application.yml
要使用 Nacos ，须要在 application.yml 或者 bootstrap.yml 中配置一些基本参数。以下所示：

# Nacos 相关参数
nacos:
 server-addr: 192.168.9.17:8848 username: nacos password: nacos # 命名空间，用做环境隔离
 namespace: 904174a3-d51f-43ed-a456-c4fd7386ecb3  spring:
 application: name: nacos-discovery-provider main: allow-bean-definition-overriding: true cloud: nacos: # 权限认证，nacos.core.auth.enabled=true 时须要添加
 username: ${nacos.username} password: ${nacos.password} discovery: server-addr: ${nacos.server-addr} # 命名空间，用做环境隔离
 namespace: ${nacos.namespace} # 分组，通常按照项目进行分组
 group: SPRING_CLOUD_EXAMPLE_GROUP # 自定义元数据
 metadata: # 版本
 version: 1.0 # 地域
 region: hangzhou```
上述配置比较完善，若是须要简化配置，则以下所示：

spring:
application: name: nacos-discovery-provider cloud: nacos: discovery: server-addr: 192.168.9.17:8848 `
2. 开启服务发现
在项目启动类上添加注解 @EnableDiscoveryClient 便可。以下所示：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class NacosDiscoveryProviderApplication {
 public static void main(String[] args) {
 SpringApplication.run(NacosDiscoveryProviderApplication.class, args);
 }
}

3. 建立 REST 接口
服务提供者须要提供接口以供消费者进行调用，通常使用 RESTful 风格的 HTTP 接口。以下所示：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping
public class TestController {
 @GetMapping("/echo/{message}")
 public String echo(@PathVariable String message) {
 return "Hello Nacos Discovery " + message; }
}

4. 验证
启动 Provider 服务提供者后，打开 Nacos 控制台，能够看到服务已经注册上去了，由于我使用的是 dev 开发环境的命名空间，因此服务注册在 dev 的命名空间内。

启动 Consumer 服务消费者

Consumer 服务消费者的依赖的配置基本与 Provider 服务提供者相同，可是却要比它更复杂一点。由于在 Consumer 端须要去调用 Provider 端的 REST 服务。而调用方式也有不少种。
1. RestTemplate 方式
依赖、配置与 Provider 一致。
而后建立 RestTemplate 配置类。以下所示：

import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
@Component
public class RestTemplateConfig {
 @Bean public RestTemplate restTemplate(){
 return new RestTemplate();
 }
}

而后调用 Provider 服务提供者。以下所示：

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
@Slf4j
@RestController
@RequestMapping
public class BaseTestController {
 @Resource private LoadBalancerClient loadBalancerClient;
 @Resource private RestTemplate restTemplate;
 @Value("${spring.application.name}")
 private String appName;
 @GetMapping("/echo")
 public String echoAppName() {
 // 使用 LoadBalanceClient 和 RestTemplate 结合的方式来访问
 // LoadBalanceClient 提供负载均衡的功能，并从 Nacos 中根据服务名获取服务实例
 ServiceInstance serviceInstance = loadBalancerClient.choose("nacos-discovery-provider");
 String url = String.format("http://%s:%s/echo/%s", serviceInstance.getHost(), serviceInstance.getPort(), appName);
 log.info("request url: {}", url);
 return restTemplate.getForObject(url, String.class);
 }
}

启动项目后，打开浏览器请求：http://localhost:8080/echo
查看返回结果进行验证。
2. Feign 方式
首先须要添加 Feign 的依赖，以下所示：

<!-- Spring Cloud Feign -->
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

添加完依赖之后，须要在项目启动类中添加 @EnableFeignClients 注解以开启功能。以下所示：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class NacosDiscoveryConsumerApplication {
 public static void main(String[] args) {
 SpringApplication.run(NacosDiscoveryConsumerApplication.class, args);
 }
} ```
而后须要建立一个接口类 `FeignService`，在类中为 Provider 服务提供者提供的服务接口提供对应的访问方法。以下所示：

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**

• nacos-discovery-provider 为服务提供者的服务名

*/@FeignClient("nacos-discovery-provider")
public interface FeignService {
/* 接口定义

• Provider 服务提供者对应的 REST 接口
• • @param message
• @return */ @GetMapping("/echo/{message}")

public String echo(@PathVariable String message);
}

在 Controller 中调用 `FeignService` 接口实现对 Provider 端的调用。代码以下：

import com.xingtuai.cloud.nacos.discovery.service.FeignService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@Slf4j
@RestController
@RequestMapping("feign")
public class FeignTestController {
@Resource private FeignService feignService;
@Value("${spring.application.name}")
private String appName;
@GetMapping("/echo")
public String echoAppName() {
return feignService.echo(appName);
}
}

启动项目后，打开浏览器请求：[http://localhost:8080/feign/echo](http://localhost:8080/feign/echo)
查看返回结果进行验证。
## 多环境隔离
`Nacos Discovery` 与 `Nacos Config` 的环境隔离是同样的，都是经过命名空间 `namespace` 进行区分。
具体请参考以前的文章：[Spring Cloud Alibaba：Nacos Config 配置中心](http://jemgeek.com/archives/2020/spring-cloud-nacos-config.html)
在实际开发中，经过这种方式能够很是好的对各类环境进行隔离区分，避免服务管理的混乱。
## 结合 Sentinel 熔断
`Sentinel` 是阿里微服务生态中一个比较重要的组件，功能也比较多，在此仅简单介绍。后续会有专题对其进行详细的研究实践。
此处结合，主要是在 Feign 调用的时候，进行处理。在调用失败时，能够进行熔断。
首先须要添加依赖，以下所示：

<!-- Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

在 `application.yml` 中进行配置，以下所示：

nacos:
server-addr: 192.168.9.17:8848 username: nacos password: nacos namespace: 904174a3-d51f-43ed-a456-c4fd7386ecb3sentinel:
dashboard: 192.168.9.17:8883 spring:
application: name: nacos-discovery-sentinel main: allow-bean-definition-overriding: true cloud: nacos: # 权限认证，nacos.core.auth.enabled=true 时须要添加
username: ${nacos.username} password: ${nacos.password} # Nacos 服务注册与发现
discovery: server-addr: ${nacos.server-addr} namespace: ${nacos.namespace} group: SPRING_CLOUD_EXAMPLE_GROUP # Spring Cloud Alibaba Sentinel 配置
sentinel: transport: # Sentinel 控制台
dashboard: ${sentinel.dashboard}
feign:
# 开启 feign 对 sentinel 的支持
sentinel: enabled: true`
建立一个 FeignService 接口方法失败时的回调类 FeignServiceFallback ，代码以下：

public class FeignServiceFallback implements FeignService {
 @Override public String echo(String message) {
 return "echo fallback, please try again."; }
}

当访问 echo(String message) 方法失败时，将会进入此回调，返回你须要的数据格式。
除此以外还须要建立一个配置类 FeignConfig ，代码以下：

import com.xingtuai.cloud.nacos.discovery.service.fallback.FeignServiceFallback;
import org.springframework.context.annotation.Bean;
public class FeignConfig {
 @Bean public FeignServiceFallback feignServiceFallback() {
 return new FeignServiceFallback();
 }
}

而后须要改造一下 FeignService 接口，将 FeignServiceFallback 及 FeignConfig 设置在注解 @FeignClient 中，改造以下：

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
 * nacos-discovery-provider 为服务提供者的服务名
 */@FeignClient(name = "nacos-discovery-provider", fallback = FeignServiceFallback.class, configuration = FeignConfig.class)
public interface FeignService {
 /** * 接口定义
 * Provider 服务提供者对应的 REST 接口
 * * @param message
 * @return */ @GetMapping("/echo/{message}")
 public String echo(@PathVariable String message);
}

正常访问时，接口将返回正常的数据，可是当接口出现异常，好比服务提供者下线了，访问失败的话。那么将会调用 FeignServiceFallback 中的 echo(String message) 方法并返回。这样就避免返回异常，而是返回一个可控的数据，能够用作服务熔断。
Sentinel 相关的知识与实践还有不少，后续会作专题分享，在此再也不赘述。

项目源代码

GitHub - spring-cloud-example

更多技术文章欢迎关注个人博客主页：http://JemGeek.com

点击阅读原文