微服务系列--nacos注册中心与服务发现

╰+攻爆jí腚メ 2022-09-04 15:57 273阅读 0赞

### 1、前言 ###

终究还是到了更新关于微服务相关博客的时候了，经过挺长一段时间微服务的自主学习，现在不敢说自己熟悉微服务，但我也能略知一二。微服务嘛，其实入门之后便会发现，其实关于微服务相关的代码量其实少之又少，如果用的是SpringCloud Alibaba这一套，那代码量就更少了，微服务比较难的地方其实是在配置上面，只要配置好了，其实后面也就不关微服务的事了。好了，闲话少话，我这里并没有从SpringCloud的五大组件开始写起，而是选择从SpringCloud Alibaba开始写起，后面如果有时间，则再更新SpringCloud五大组件的内容。

### 2、什么是nacos ###

naocs其实是用java写的一个服务，相比feign，可以说是零代码，因为feign的话，一般来说都会单独使用一个工程来当注册中心，而所谓的注册中心呢，其实就是把消费者和提供者管理起来的一个容器。至于怎么启动nacos，那真的无脑启动，只需要下载后nacos后，双击启动脚本就OK了，当初我刚接触到这玩意的时候，觉得feign完全没有使用的必要了，而且比feign更加强大。

### 3、下载并启动nacos ###

下载官网：

[Releases · alibaba/nacos · GitHub][Releases _ alibaba_nacos _ GitHub]（直链前往）

[https://github.com/alibaba/nacos/releases][Releases _ alibaba_nacos _ GitHub]（网址前往）

如果下载慢，可以从我上传的资源进行下载:

[nacos1.2.1.zip-Java文档类资源-CSDN下载][nacos1.2.1.zip-Java_-CSDN]

我这里使用的是1.2.1的版本，相对来说也比较久了，现在出到2.0以上的版本了，之所以我用这个版本呢，是因为我在刚入门的时候踩了很多坑，好多时候是因为问题出在版本不兼容上了，这是后期我整合ribbon、sentinel、gateway比较适合的一个版本。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70][]

下载之后进行解压，在bin目录下双击startup.cmd，看到此界面便是已成功

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 1][]

打开浏览器，输入localhost:8848/nacos，打开nacos的可视化管理界面，这里有个小bug，有时候用localhost打开之后，会发现是一个空白页面，无法正常显示页面，那可以换成本地ip的方式进行打开，默认用户名和密码都是 nacos

###  4、创建微服务父工程 ###

创建好SpringBoot工程后，导入所需依赖

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.0.RELEASE</version>
            <relativePath/> 
        </parent>
        <packaging>pom</packaging>
        <groupId>com.chen</groupId>
        <artifactId>SpringCloudAliBaBa_Learn</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>SpringCloudAliBaBa_Learn</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Hoxton.SR3</version>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.2.1.RELEASE</version>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <version>2.3.0.RELEASE</version>
                </plugin>
            </plugins>
        </build>
    
    </project>

### 5、创建服务提供者模块 ###

在创建好的SpringBoot工程下，新建一个module，名为provider，导入依赖

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.chen</groupId>
            <artifactId>SpringCloudAliBaBa_Learn</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <groupId>com.chen</groupId>
        <artifactId>provider</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>provider</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
                <version>2.2.1.RELEASE</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <version>2.3.0.RELEASE</version>
                </plugin>
            </plugins>
        </build>
    
    </project>

yml配置，nacos的默认地址就是 localhost:8848，这是我在研究nacos源码的时候发现的，所以说如果你是在本地，那这个配置写不写都无所谓，只要你导入了依赖，启动了nacos，那就会自动将你这个服务注册到nacos里去。

spring:
      cloud:
        nacos:
          discovery:
            # 配置nacos服务地址，如果不配置，默认是localhost:8848
            server-addr: localhost:8848
      application:
        name: provider
    
    server:
      port: 8081

接下来写一个controller进行测试

package com.chen.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.cloud.client.discovery.DiscoveryClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    @RestController
    @RequestMapping("/provider")
    public class ProviderController {
    
        @Autowired
        private DiscoveryClient discoveryClient;
    
        @Value("${server.port}")
        private String port;
    
        @GetMapping("/instances")
        public List<ServiceInstance> instances() {
            List<ServiceInstance> provider = discoveryClient.getInstances("provider");
            return provider;
        }
    
        @GetMapping("/index")
        public String index(){
            return "ok--"+port;
        }
    }

第一个 instances接口，获得provider这个实例名下的所有服务，

第二个index接口，方便我后面新加一个consumer服务进行调用。

将这个服务进行运行，打开nacos，查看服务列表，可以看到这个服务已经注册进来了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 2][]

现在，我们修改这个服务的端口号，改为8082，再次运行，可以看到现在实例数已经变为2了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 3][]

接着我们调第一个接口，[localhost:8081/provider/instances][localhost_8081_provider_instances]

或者是[localhost:8082/provider/instances][localhost_8082_provider_instances]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 4][]

###  6、创建服务消费者模块 ###

同样新建module，引入依赖

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.chen</groupId>
            <artifactId>SpringCloudAliBaBa_Learn</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <groupId>com.chen</groupId>
        <artifactId>consumer</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>consumer</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
                <version>2.2.1.RELEASE</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <version>2.3.0.RELEASE</version>
                </plugin>
            </plugins>
        </build>
    
    </project>

yml配置

spring:
      cloud:
        nacos:
          discovery:
            # 配置nacos服务地址，如果不配置，默认是localhost:8848
            server-addr: localhost:8848
      application:
        name: consumer
    
    server:
      port: 8080

我这里使用RestTemplate进行服务调用

package com.chen.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class ConsumerConfig {
    
        @Bean
        public RestTemplate restTemplate(){
            return new RestTemplate();
        }
    
    }

新建消费者controller，用来调第5步启动成功的那两个服务，这里我用随机数，先获得实例数，再根据实例数的大小随机调取服务

package com.chen.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.cloud.client.discovery.DiscoveryClient;
    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 java.util.List;
    import java.util.concurrent.ThreadLocalRandom;
    
    @RestController
    @RequestMapping("/consumer")
    public class ConsumerController {
    
        @Autowired
        private DiscoveryClient discoveryClient;
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping("/index")
        public String index(){
            List<ServiceInstance> provider = discoveryClient.getInstances("provider");
            int index = ThreadLocalRandom.current().nextInt(provider.size());
            String url = provider.get(index).getUri()+"/provider/index";
            return this.restTemplate.getForObject(url, String.class);
        }
    
    }

启动消费者，发现在nacos中也成功注册进来了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 5][]

现在调消费者的接口，[localhost:8080/consumer/index][localhost_8080_consumer_index]

可以看到结果要么调的是 8081，要么是8082

![20210815162240233.png][]

![20210815162252936.png][]

nacos注册中心和服务发现搭建成功，后面持续整合微服务的其他组件~~~

[Releases _ alibaba_nacos _ GitHub]: https://github.com/alibaba/nacos/releases
[nacos1.2.1.zip-Java_-CSDN]: https://download.csdn.net/download/qq_42109746/21092632
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70]: /images/20220829/254c20ffc0dd4a649e96ba9fa50fe9a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 1]: /images/20220829/bfdacc3c5e9f4b5fa04b1fdebcc8fb63.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 2]: /images/20220829/ba29cb5c72bb457cad0f4202eb06bb7a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 3]: /images/20220829/0955c2b803c3473ca7af209d74974dbb.png
[localhost_8081_provider_instances]: http://localhost:8081/provider/instances
[localhost_8082_provider_instances]: http://localhost:8082/provider/instances
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 4]: /images/20220829/6745d83164b948d1a2130af52b51ebed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70 5]: /images/20220829/f640d7bb12174993a1a7e2c6a4d025e9.png
[localhost_8080_consumer_index]: http://localhost:8080/consumer/index
[20210815162240233.png]: /images/20220829/5335d8c6a8ad4e939e0667cd883f4399.png
[20210815162252936.png]: /images/20220829/6a0a0ed0e5474584a04f6ef260b25852.png