使用Nacos实现服务注册与发现（二）

前言

• 前面的文章已经说了什么是Spring Cloud Alibaba，以及为什么选择使用SCA，这里我们就使用Spring Cloud Alibaba如何完成微服务的架构搭建展开讲解。

• 大家都知道作为微服务项目中一个必不可少的功能就是：服务的注册和发现，而市面上实现此功能的技术有很多，像Zookeeper，Eureka，consul等。

• 而作为阿里巴巴最新的开源项目之一，Nacos核心定位是“一个更易于帮助构建云原生应用的动态服务发现、配置和服务管理平台”，项目地址：https://nacos.io/zh-cn/
  

  

Naco提供了两个核心功能：服务注册与发现，动态管理配置

1. 服务注册与发现

• Nacos提供基于DNS和基于RPC的服务发现，既能被用来支持https/http的服务注册与发现，也支持RPC如dubbo的服务注册与发现。

• 与Dubbo使用的zookeeper相比而言，两者差异还是比较大的，zookeeper是一种分布式的协调服务，它天生是作为分布式数据一致性场景下的解决方案，所以zookeeper是CP（一致性和分区容错性）,它牺牲了可用性来保证一致性，在极端情况下（master选举期间）服务会对外停止服务，对于服务可用要求比较高的系统是难以接受的。Nacos是一种去中心话的架构，属于CAP理论里的AP(可用性和分区容器性)架构，支持最终一致性，在分布式服务发现与注册场景下具有很不错的性能。目前dubbo官方也支持使用Nacos代替zookeeper。

• 而相比Spring Cloud Eureka来说，Nacos更加强大。Nacos=Spring Cloud Eureka + Spring Cloud Config.

2. 动态配置服务
动态修改配置并实时生效对于服务端的同学来说并不陌生，这种服务能够让我们的服务拥有更多的灵活性，不需要重启服务即可做到配置实时生效，非常适合于“配置优先”的服务开发。

接下来我们将使用Nacos完成服务的注册和发现功能。

使用Nacos实现服务注册与发现

安装Nacos

下载地址：https://github.com/alibaba/nacos/releases
本文版本：1.0.0

下载完成之后，解压。根据不同平台，执行不同命令。

• Linux/Unix/Mac
  启动命令(standalone代表着单机模式运行，非集群模式):
  sh startup.sh -m standalone

• Windows
  启动命令：
  cmd startup.cmd
  或者双击startup.cmd运行文件。

附：startup.sh脚本位于Nacos解压后的bin目录下。

这里主要介绍Spring Cloud与Nacos的集成使用，对于Nacos的高级配置，后续再补充, 因为我们开发环境是window所以才使用第二种方式启动。

启动完成之后，访问：http://127.0.0.1:8848/nacos/，可以进入Nacos登陆页面：

如果使用Nacos 0.8.0以上版本，会出现登录页面，默认用户名密码为：nacos

登陆成功后会进入Nacos的服务管理页面，具体如下：

构建应用接入Nacos注册中心

在完成了Nacos服务的安装和启动之后，下面我们就可以编写两个应用（服务提供者和服务消费者）来验证服务的注册与发现了。

服务提供者

第一步：创建一个SpringBoot工程，命名为：alibaba-nacos-discovery-server.

第二步：编辑pom.xml，加入必要的依赖配置，详细如下：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.2.RELEASE</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.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
            <optional>true</optional>
        </dependency>
    </dependencies>

上述配置主要分三部分：

• parent： 定义Spring Boot的版本
• dependencyManagement： Spring Cloud的版本以及Spring Cloud Alibaba的版本 ，由于Spring Cloud Alibaba还未纳入Spring Cloud主版本管理，所以需要单独引入
• dependencies： 当前应用需要使用的依赖内容。这里新加入了Nacos的服务注册与发现版本模块： spring-cloud-starter-alibaba-nacos-discovery。 由于 dependencyManagement中已经引入了版本，所以这里就不用指定具体的版本号了。

第三步： 创建应用主类，编写对外提供服务的测试HTTP接口:

@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(NacosDiscoveryServerApplication.class, args);
    }
}

@SpringBootApplication定义是一个SpringBoot应用，@EnableDiscoveryClient开启Spring Cloud的服务注册与发现，由于这里引入了spring-cloud-starter-alibaba-nacos-discovery模块，所以Spring Cloud Common中定义了那些与服务治理相关接口将使用Nacos的实现。这点不论我们使用Eureka、Consule还是其他Spring Cloud整合的注册中心都是一样，这也是Spring Cloud做了封装后的好处所在。

@RestController
@Slf4j
public class TestController {

    @GetMapping("/hello")
    public String hello(@RequestParam String name) {
        log.info("invoked name = {}", name);
        return "hello " + name;
    }
}

第四步：配置服务器名称和Nacos服务器地址， application.yml

server:
  port: 9001 #服务端口
spring:
  application:
    name: alibaba-nacos-discovery-server #服务实例名称
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #Nacos服务器地址

第五步：启动上面的应用。这里为了方便测试使用命令行方式启动在启动时添加 -Dserver.port=9002的形式在本机的不同端口启动多个实例。

pom.xml添加maven打包插件：

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

打包：mvn clean package
运行：
java -jar -Dserver.port=9001 alibaba-nacos-discovery-server-1.0-SNAPSHOT.jar
java -jar -Dserver.port=9002 alibaba-nacos-discovery-server-1.0-SNAPSHOT.jar

启动完毕后看到下面日志，证明注册完毕:

2019-07-09 15:19:32.234  INFO 11988 --- [           main] o.s.c.a.n.registry.NacosServiceRegistry  : nacos registry, alibaba-nacos-discovery-server 10.10.50.9:9002 register finished

实例全部启动完毕后，就可以在Nacos管理页面http://127.0.0.1:8848/nacos/ 来查看服务列表：

这里会显示当前注册的所有服务，以及每个服务集群数目、实例数、健康实例数。单击详情，我们还能看到每个服务具体的实例信息，如图所示：

服务消费者

接下来，实现一个应用来消费上已经注册到Nacos的服务。

第一步: 创建一个Spring Boot应用，命名为：alibaba-nacos-discovery-client

第二步： 编辑pom.xml文件中的依赖内容，同上面服务提供者一样即可。

第三步： 创建应用主类，编写一个消费者HTTP接口，在该接口中调用服务提供者提供的接口服务。

@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(NacosDiscoveryClientApplication.class, args);
    }
}

@Slf4j
@RestController
public class TestController {

    @Autowired
    private LoadBalancerClient loadBalancerClient;

    @GetMapping("/test")
    public String test() {
        // 通过spring cloud common中的负载均衡接口选取服务提供节点实现接口调用
        ServiceInstance serviceInstance = loadBalancerClient.choose("alibaba-nacos-discovery-server");
        String url = serviceInstance.getUri() + "/hello?name=" + "wolf";
        RestTemplate restTemplate = new RestTemplate();
        String result = restTemplate.getForObject(url, String.class);
        return "Invoke : " + url + ", return : " + result;
    }
}

这里使用了Spring Cloud Common中的 LoadBalancerClient 接口来实现服务实例的负载均衡调用。使用实例名称获取可方案的URI，拼接上服务提供方的接口规则来发起调用。

第四步： 配置服务名称和Nacos地址，让服务消费者可以发现已经注册到Nacos的服务实例。

server:
  port: 9003 #服务端口
spring:
  application:
    name: alibaba-nacos-discovery-client #服务实例名称
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #Nacos服务器地址

第五步： 启动消费者，通过curl或postman工具发起调用测试，下面以postman为例：

通过测试发现，两次不同的请求，真正调用的服务提供方实例是不同的，也就是说，通过 LoadBalancerClient接口在获取服务实例的时候，已经实现了服务提供方实例的负载均衡。

但是这样的实现还是很繁琐，后面的文章我们会讲解其它更方便优雅的调用方式。