nacos 实战（史上最全）

时间 2021-01-22 标签 html java mysql git web 面试 redis 算法 spring sql

疯狂创客圈经典图书：《Netty Zookeeper Redis 高并发实战》面试必备 + 面试必备 + 面试必备【博客园总入口】html
疯狂创客圈经典图书：《SpringCloud、Nginx高并发核心编程》大厂必备 + 大厂必备 + 大厂必备【博客园总入口】java
入大厂+涨工资必备：高并发【亿级流量IM实战】实战系列【 SpringCloud Nginx秒杀】实战系列【博客园总入口】mysql

目录：小圈的 springCloud 高并发系列

推荐阅读
nacos 实战（史上最全）
sentinel （史上最全+入门教程）
springcloud + webflux 高并发实战
Webflux（史上最全）
SpringCloud gateway （史上最全）
和 1000+ Java 高并发发烧友、一块儿交流、学习、入大厂、作架构，GO

一、Nacos 优点

问题，既然有了Eureka ，为啥还要用Nacos？

而 Nacos 做为微服务核心的服务注册与发现中心，让你们在 Eureka 和 Consule 以外有了新的选择，开箱即用，上手简洁，暂时也没发现有太大的坑。git

1.1与eureka对比

1 eureka 2.0闭源码了。web

2 从官网来看nacos 的注册的实例数是大于eureka的,面试

3 由于nacos使用的raft协议,nacos集群的一致性要远大于eureka集群.redis

分布式一致性协议 Raft，自 2013 年论文发表，以后就受到了技术领域的热捧，与其余的分布式一致性算法比，Raft 相对比较简单而且易于实现，这也是 Raft 能异军突起的主要因素。算法

Raft 的数据一致性策略

Raft 协议强依赖 Leader 节点来确保集群数据一致性。即 client 发送过来的数据均先到达 Leader 节点，Leader 接收到数据后，先将数据标记为 uncommitted 状态，随后 Leader 开始向全部 Follower 复制数据并等待响应，在得到集群中大于 N/2 个 Follower 的已成功接收数据完毕的响应后，Leader 将数据的状态标记为 committed，随后向 client 发送数据已接收确认，在向 client 发送出已数据接收后，再向全部 Follower 节点发送通知代表该数据状态为committed。spring

1.2与springcloud config 对比

三大优点：

springcloud config大部分场景结合git 使用, 动态变动还须要依赖Spring Cloud Bus 消息总线来经过全部的客户端变化.sql
springcloud config不提供可视化界面
nacos config使用长链接更新配置, 一旦配置有变更后，通知Provider的过程很是的迅速, 从速度上秒杀springcloud原来的config几条街,

二、Spring Cloud Alibaba 套件

目前 Spring Cloud Alibaba 主要有三个组件：

Nacos：一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
Sentinel：把流量做为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
AliCloud OSS: 阿里云对象存储服务（Object Storage Service，简称
OSS），是阿里云提供的海量、安全、低成本、高可靠的云存储服务。您能够在任何应用、任什么时候间、任何地点存储和访问任意类型的数据。

Spring Cloud Alibaba 套件和Spring Cloud Netflix套件类比

仔细看看各组件的功能描述，Spring Cloud Alibaba 套件和Spring Cloud Netflix套件大体的对应关系：

Nacos = Eureka/Consule + Config + Admin
Sentinel = Hystrix + Dashboard + Turbine
Dubbo = Ribbon + Feign
RocketMQ = RabbitMQ
Schedulerx = Quartz
AliCloud OSS、AliCloud SLS 这三个应该是独有的
链路跟踪（Sleuth、Zipkin）不知道会不会在 Sentinel 里
以上只是猜想，待我从坑里爬出来以后再回来更新。也欢迎你们一块儿交流探讨~
这里我就先试试 Nacos。

三、Nacos 的架构和安装

3.一、Nacos 的架构

这是 Nacos 的架构图，能够看到它确实是融合了服务注册发现中心、配置中心、服务管理等功能，相似于 Eureka/Consule + Config + Admin 的合体。

另外经过官方文档发现，Nacos 除了能够和 Spring Cloud 集成，还能够和 Spring、SpringBoot 进行集成。

不过咱们只关注于 Spring Cloud，别的就略过了，直接上手实战吧。

3.二、Nacos Server 的下载和安装

在使用 Nacos 以前，须要先下载 Nacos 并启动 Nacos Server。

安装的参考教程：

http://www.javashuo.com/article/p-cyttksif-oa.html

四、Nacos Server 的运行

4.1两种模式

Nacos Server 有两种运行模式：

standalone
cluster

4.二、standalone 模式

此模式通常用于 demo 和测试，不用改任何配置，直接敲如下命令执行

sh bin/startup.sh -m standalone

Windows 的话就是

cmd bin/startup.cmd -m standalone

而后从 http://cdh1:8848/nacos/index.html 进入控制台就能看到以下界面了

默认帐号和密码为：nacos nacos

4.三、cluster 模式

测试环境，能够先用 standalone 模式撸起来，享受 coding 的快感，可是，生产环境可使用 cluster 模式。

cluster 模式须要依赖 MySQL，而后改两个配置文件：

conf/cluster.conf
conf/application.properties

大体以下：

1： cluster.conf，填入要运行 Nacos Server 机器的 ip

192.168.100.155
192.168.100.156

修改NACOS_PATH/conf/application.properties，加入 MySQL 配置

db.num=1
db.url.0=jdbc:mysql://localhost:3306/nacos_config?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=root

建立一个名为nacos_config的 database，将NACOS_PATH/conf/nacos-mysql.sql中的表结构导入刚才建立的库中，这几张表的用途就本身研究吧

4.4 Nacos Server 的配置数据是存在哪里呢？

问题来了： Nacos Server 的配置数据是存在哪里呢？

咱们没有对 Nacos Server 作任何配置，那么数据只有两个位置能够存储：

内存
本地数据库

若是咱们如今重启刚刚在运行的 Nacos Server，会发现刚才加的 nacos.properties 配置还在，说明不是内存存储的。

这时候咱们打开NACOS_PATH/data，会发现里边有个derby-data目录，咱们的配置数据如今就存储在这个库中。

Derby 是 Java 编写的数据库，属于 Apache 的一个开源项目

若是将数据源改成咱们熟悉的 MySQL 呢？固然能够。

注意：不支持 MySQL 8.0 版本

这里有两个坑：

Nacos Server 的数据源是用 Derby 仍是 MySQL 彻底是由其运行模式决定的：

standalone 的话仅会使用 Derby，即便在 application.properties 里边配置 MySQL 也照样无视；
cluster 模式会自动使用 MySQL，这时候若是没有 MySQL 的配置，是会报错的。

官方提供的 cluster.conf 示例以下

#it is ip
#example
10.10.109.214
11.16.128.34
11.16.128.36
12345

以上配置结束后，运行 Nacos Server 就能看到效果了。

5 实战1：使用Nacos做为注册中心

实战的工程

实战的工程的目录结构以下：

5.1如何使用Nacos Client组件

首先引入 Spring Cloud Alibaba 的 BOM

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.4.RELEASE</version>
    <relativePath/>
</parent>
<properties>
    <spring-cloud.version>Finchley.SR2</spring-cloud.version>
    <spring-cloud-alibaba.version>0.2.0.RELEASE</spring-cloud-alibaba.version>
</properties>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>${spring-cloud-alibaba.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

这里版本号有坑，文档上说和 Spring Boot 2.0.x 版本兼容，可是实测 2.0.6.RELEASE 报错

java.lang.NoClassDefFoundError: org/springframework/core/env/EnvironmentCapable

5.二、演示的模块结构

服务注册中心和服务发现的服务端都是由 Nacos Server 来提供的，咱们只须要提供 Service 向其注册就行了。

这里模拟提供两个 service：provider 和 consumer

alibaba
├── service-provider-demo
│   ├── pom.xml
│   └── src
└── sevice-consumer-demo
│   ├── pom.xml
│   └── src
└── pom.xml

5.三、provider 微服务

step1：在 provider 和 consumer 的 pom 添加如下依赖：

<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>

step2：启动类

使用 Spring Cloud 的原生注解 @EnableDiscoveryClient 开启服务注册与发现

package com.crazymaker.cloud.nacos.demo.starter;

import com.crazymaker.springcloud.standard.context.SpringContextUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.env.Environment;
import springfox.documentation.swagger2.annotations.EnableSwagger2;

import java.util.List;

@EnableSwagger2
@SpringBootApplication
@EnableDiscoveryClient
@Slf4j
public class ServiceProviderApplication {
    public static void main(String[] args) {
        ConfigurableApplicationContext applicationContext =   SpringApplication.run(ServiceProviderApplication.class, args);

        Environment env = applicationContext.getEnvironment();
        String port = env.getProperty("server.port");
        String path = env.getProperty("server.servlet.context-path");
        System.out.println("\n--------------------------------------\n\t" +
                "Application is running! Access URLs:\n\t" +
                "Local: \t\thttp://localhost:" + port + path+ "/index.html\n\t" +
               "swagger-ui: \thttp://localhost:" + port + path + "/swagger-ui.html\n\t" +
                "----------------------------------------------------------");

    }
}

step3：服务提供者的 Rest 服务接口

service-provider-demo 提供一个很是简单的 Rest 服务接口以供访问

package com.crazymaker.cloud.nacos.demo.controller;

import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/echo")
public class EchoController {
    //回显服务
    @RequestMapping(value = "/{string}", method = RequestMethod.GET)
    public String echo(@PathVariable String string) {
        return "echo: " + string;
    }
}

step4：配置文件

spring:
  application:
    name: service-provider-demo
  cloud:
    nacos:
      discovery:
        server-addr: ${NACOS_SERVER:cdh1:8848}
server:
  port: 18080

step5：启动以后，经过swagger UI访问：

5.四、Consumer 微服务演示RPC远程调用

在 NacosConsumerApplication 中集成 RestTemplate 和 Ribbon

@LoadBalanced
@Bean
public RestTemplate restTemplate() {
  return new RestTemplate();
}

消费者的controller 类

package com.crazymaker.cloud.nacos.demo.consumer.controller;

import com.crazymaker.cloud.nacos.demo.consumer.client.EchoClient;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@RequestMapping("/echo")
@Api(tags = "服务- 消费者")
public class EchoConsumerController {


    //注入 @FeignClient 注解配置 所配置的 EchoClient 客户端Feign实例
    @Resource
    EchoClient echoClient;


    //回显服务
    @ApiOperation(value = "消费回显服务接口")
    @RequestMapping(value = "/{string}", method = RequestMethod.GET)
    public String echoRemoteEcho(@PathVariable String string) {
        return "provider echo is:" + echoClient.echo(string);
    }
}

消费者配置文件

spring:
  application:
    name: sevice-consumer-demo
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
server:
  port: 18081

经过swagger UI访问消费者：

访问远程的echo API：

5.5涉及到的演示地址：

服务提供者 service-provider-demo：

http://localhost:18080/provider/swagger-ui.html#/Echo_%E6%BC%94%E7%A4%BA

服务消费者：

[http://localhost:18081/consumer/swagger-ui.html#/服务- 消费者/echoRemoteEchoUsingGET](http://localhost:18081/consumer/swagger-ui.html#/服务- 消费者/echoRemoteEchoUsingGET)

注册中心Nacos：

http://cdh1:8848/nacos/index.html#/serviceManagement?dataId=&group=&appName=&namespace=

5.六、Nacos Console

这时候查看 Nacos Console 也能看到已注册的服务列表及其详情

六、实战2：使用Nacos做为配置中心

6.一、基本概念

1. Profile

Java项目通常都会有多个Profile配置，用于区分开发环境，测试环境，准生产环境，生成环境等，每一个环境对应一个properties文件（或是yml/yaml文件），而后经过设置 spring.profiles.active 的值来决定使用哪一个配置文件。

例子：

spring:
  application:
    name: sharding-jdbc-provider
  jpa:
    hibernate:
      ddl-auto: none
      dialect: org.hibernate.dialect.MySQL5InnoDBDialect
      show-sql: true
  profiles:
     active: sharding-db-table    # 分库分表配置文件
    #active: atomiclong-id    # 自定义主键的配置文件
    #active: replica-query    # 读写分离配置文件

Nacos Config的做用就把这些文件的内容都移到一个统一的配置中心，即方便维护又支持实时修改后动态刷新应用。

2. Data ID

当使用Nacos Config后，Profile的配置就存储到Data ID下，即一个Profile对应一个Data ID

Data ID的拼接格式：${prefix} - ${spring.profiles.active} . ${file-extension}

prefix 默认为 spring.application.name 的值，也能够经过配置项 spring.cloud.nacos.config.prefix 来配置
spring.profiles.active 取 spring.profiles.active 的值，即为当前环境对应的 profile
file-extension 为配置内容的数据格式，能够经过配置项 spring.cloud.nacos.config.file-extension 来配置

3. Group

Group 默认为 DEFAULT_GROUP，能够经过 spring.cloud.nacos.config.group 来配置，当配置项太多或者有重名时，能够经过分组来方便管理

最后就和原来使用springcloud同样经过@RefreshScope 和@Value注解便可

6.2 经过Nacos的console 去增长配置

这回首先要在nacos中配置相关的配置，打开Nacos配置界面，依次建立2个Data ID

nacos-config-demo-dev.yaml 开发环境的配置
nacos-config-demo-test.yaml 测试环境的配置

一、nacos-config-demo-dev.yaml

内容以下图：

二、nacos-config-demo-sit.yaml

内容以下图：

6.3 使用Nacos Config Client组件

问题2：微服务Provider实例上，如何使用Nacos Config Client组件的有哪些步骤？

1 加载nacos config 的客户端依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    <version>${nacos.version}</version>
</dependency>

启动类

package com.crazymaker.cloud.nacos.demo.consumer.starter;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
import org.springframework.boot.autoconfigure.data.redis.RedisRepositoriesAutoConfiguration;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.env.Environment;
import springfox.documentation.swagger2.annotations.EnableSwagger2;

@EnableSwagger2
@EnableDiscoveryClient
@Slf4j
@SpringBootApplication(
        scanBasePackages =
                {
                        "com.crazymaker.cloud.nacos.demo",
                        "com.crazymaker.springcloud.standard"
                },
        exclude = {SecurityAutoConfiguration.class,
                //排除db的自动配置
                DataSourceAutoConfiguration.class,
                DataSourceTransactionManagerAutoConfiguration.class,
                HibernateJpaAutoConfiguration.class,
                //排除redis的自动配置
                RedisAutoConfiguration.class,
                RedisRepositoriesAutoConfiguration.class})
//启动Feign
@EnableFeignClients(basePackages =
        {"com.crazymaker.cloud.nacos.demo.consumer.client"})
public class ConfigDomeProviderApplication
{
    public static void main(String[] args)
    {
        ConfigurableApplicationContext applicationContext = null;
        try
        {
            applicationContext = SpringApplication.run(ConfigDomeProviderApplication.class, args);
            System.out.println("Server startup done.");
        } catch (Exception e)
        {
            log.error("服务启动报错", e);
            return;
        }

        Environment env = applicationContext.getEnvironment();
        String port = env.getProperty("server.port");
        String path = env.getProperty("server.servlet.context-path");
        System.out.println("\n----------------------------------------------------------\n\t" +
                "Application is running! Access URLs:\n\t" +
                "Local: \t\thttp://localhost:" + port + path + "/index.html\n\t" +
                "swagger-ui: \thttp://localhost:" + port + path + "/swagger-ui.html\n\t" +
                "----------------------------------------------------------");

    }
}

控制类：

package com.crazymaker.cloud.nacos.demo.config.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@RequestMapping("/config")
@Api(tags = "Nacos 配置中心演示")
public class ConfigGetController {


    @Value("${foo.bar:empty}")
    private String bar;


    @Value("${spring.datasource.username:empty}")
    private String dbusername;

    //获取配置的内容
    @ApiOperation(value = "获取配置的内容")
    @RequestMapping(value = "/bar", method = RequestMethod.GET)
    public String getBar() {
        return "bar is :"+bar;
    }
    //获取配置的内容
    @ApiOperation(value = "获取配置的db username")
    @RequestMapping(value = "/dbusername", method = RequestMethod.GET)
    public String getDbusername() {
        return "db username is :"+bar;
    }
}

2 bootstrap配置文件

而后是在配置文件(bootstrap.yml)中加入如下的内容：

spring:
  application:
    name: nacos-config-demo-provider
  profiles:
    active:  dev
  cloud:
    nacos:
      discovery:
        server-addr: ${NACOS_SERVER:cdh1:8848}
      config:
        server-addr: ${NACOS_SERVER:cdh1:8848}
        prefix: nacos-config-demo
        group: DEFAULT_GROUP
        file-extension: yaml
server:
  port: 18083
  servlet:
    context-path: /config

6.4 测试结果

启动程序，经过swagger ui访问：

http://localhost:18083/config/swagger-ui.html#

执行结果以下：

6.4 能够端如何与服务端的配置文件相互对应

config.prefix 来对应主配置文件
使用spring.cloud.nacos.config.ext-config 选项来对应更多的文件

eg：

spring:
  application:
    name: nacos-config-demo-provider
  profiles:
    active: dev
  cloud:
    nacos:
      discovery:
        server-addr: ${NACOS_SERVER:cdh1:8848}
      config:
        server-addr: ${NACOS_SERVER:cdh1:8848}
        prefix: nacos-config-demo
        group: DEFAULT_GROUP
        file-extension: yaml
        ext-config:
          - data-id: crazymaker-db-dev.yml
            group: DEFAULT_GROUP
            refresh: true
          - data-id: crazymaker-redis-dev.yml
            group: DEFAULT_GROUP
            refresh: true
          - data-id: crazymaker-common-dev.yml
            group: DEFAULT_GROUP
            refresh: true
          - data-id: some.properties
            group: DEFAULT_GROUP
            refresh: true

启动程序，发现能够获取到其余data-id的配置 ,你们能够自行配置。

七、配置的隔离

在实际的应用中，存在着如下几种环境隔离的要求：

一、开发环境、测试环境、准生产环境和生产环境须要隔离

二、不一样项目须要隔离

三、同一项目，不一样的模块须要隔离

能够经过三种方式来进行配置隔离：Nacos的服务器、namespace命名空间、group分组，在bootstrap.yml文件中能够经过配置Nacos的server-addr、namespace和group来区分不一样的配置信息。

Nacos的服务器 spring.cloud.nacos.config.server-addr
Nacos的命名空间 spring.cloud.nacos.config.namespace，注意，这里使用命名空间的ID不是名称
Nacos的分组 spring.cloud.nacos.config.group