跨境互联网 跨境互联网
首页
  • AI 工具

    • 绘图提示词工具 (opens new window)
    • ChatGPT 指令 (opens new window)
  • ChatGPT

    • ChatGP T介绍
    • ChatGPT API 中文开发手册
    • ChatGPT 中文调教指南
    • ChatGPT 开源项目
  • Midjourney

    • Midjourney 文档
  • Stable Diffusion

    • Stable Diffusion 文档
  • 其他

    • AIGC 热门文章
    • 账号合租 (opens new window)
    • 有趣的网站
  • Vue

    • Vue3前置
  • JAVA基础

    • Stream
    • Git
    • Maven
    • 常用第三方类库
    • 性能调优工具
    • UML系统建模
    • 领域驱动设计
    • 敏捷开发
    • Java 测试
    • 代码规范及工具
    • Groovy 编程
  • 并发编程&多线程

    • 并发编程
    • 高性能队列 Disruptor
    • 多线程并发在电商系统下的应用
  • 其他

    • 面试题
  • 消息中间中间件

    • Kafka
    • RabbitMQ
    • RocketMQ
  • 任务调度

    • Quartz
    • XXL-Job
    • Elastic-Job
  • 源码解析

    • Mybatis 高级使用
    • Mybatis 源码剖析
    • Mybatis-Plus
    • Spring Data JPA
    • Spring 高级使用
    • Spring 源码剖析
    • SpringBoot 高级使用
    • SpringBoot 源码剖析
    • Jdk 解析
    • Tomcat 架构设计&源码剖析
    • Tomcat Web应用服务器
    • Zookeeper 高级
    • Netty
  • 微服务框架

    • 分布式原理
    • 分布式集群架构场景化解决方案
    • Dubbo 高级使用
    • Dubbo 核心源码剖析
    • Spring Cloud Gateway
    • Nacos 实战应用
    • Sentinel 实战应用
    • Seata 分布式事务
  • 数据结构和算法的深入应用
  • 存储

    • 图和Neo4j
    • MongoDB
    • TiDB
    • MySQL 优化
    • MySQL 平滑扩容实战
    • MySQL 海量数据存储与优化
    • Elasticsearch
  • 缓存

    • Redis
    • Aerospike
    • Guava Cache
    • Tair
  • 文件存储

    • 阿里云 OSS 云存储
    • FastDF 文件存储
  • 基础

    • Linux 使用
    • Nginx 使用与配置
    • OpenResty 使用
    • LVS+Keepalived 高可用部署
    • Jekins
  • 容器技术

    • Docker
    • K8S
    • K8S
  • 01.全链路(APM)
  • 02.电商终极搜索解决方案
  • 03.电商亿级数据库设计
  • 04.大屏实时计算
  • 05.分库分表的深入实战
  • 06.多维系统下单点登录
  • 07.多服务之间分布式事务
  • 08.业务幂等性技术架构体系
  • 09.高并发下的12306优化
  • 10.每秒100W请求的秒杀架构体系
  • 11.集中化日志管理平台的应用
  • 12.数据中台配置中心
  • 13.每天千万级订单的生成背后痛点及技术突破
  • 14.红包雨的架构设计及源码实现
  • 人工智能

    • Python 笔记
    • Python 工具库
    • 人工智能(AI) 笔记
    • 人工智能(AI) 项目笔记
  • 大数据

    • Flink流处理框架
  • 加密区

    • 机器学习(ML) (opens new window)
    • 深度学习(DL) (opens new window)
    • 自然语言处理(NLP) (opens new window)
AI 导航 (opens new window)

Revin

首页
  • AI 工具

    • 绘图提示词工具 (opens new window)
    • ChatGPT 指令 (opens new window)
  • ChatGPT

    • ChatGP T介绍
    • ChatGPT API 中文开发手册
    • ChatGPT 中文调教指南
    • ChatGPT 开源项目
  • Midjourney

    • Midjourney 文档
  • Stable Diffusion

    • Stable Diffusion 文档
  • 其他

    • AIGC 热门文章
    • 账号合租 (opens new window)
    • 有趣的网站
  • Vue

    • Vue3前置
  • JAVA基础

    • Stream
    • Git
    • Maven
    • 常用第三方类库
    • 性能调优工具
    • UML系统建模
    • 领域驱动设计
    • 敏捷开发
    • Java 测试
    • 代码规范及工具
    • Groovy 编程
  • 并发编程&多线程

    • 并发编程
    • 高性能队列 Disruptor
    • 多线程并发在电商系统下的应用
  • 其他

    • 面试题
  • 消息中间中间件

    • Kafka
    • RabbitMQ
    • RocketMQ
  • 任务调度

    • Quartz
    • XXL-Job
    • Elastic-Job
  • 源码解析

    • Mybatis 高级使用
    • Mybatis 源码剖析
    • Mybatis-Plus
    • Spring Data JPA
    • Spring 高级使用
    • Spring 源码剖析
    • SpringBoot 高级使用
    • SpringBoot 源码剖析
    • Jdk 解析
    • Tomcat 架构设计&源码剖析
    • Tomcat Web应用服务器
    • Zookeeper 高级
    • Netty
  • 微服务框架

    • 分布式原理
    • 分布式集群架构场景化解决方案
    • Dubbo 高级使用
    • Dubbo 核心源码剖析
    • Spring Cloud Gateway
    • Nacos 实战应用
    • Sentinel 实战应用
    • Seata 分布式事务
  • 数据结构和算法的深入应用
  • 存储

    • 图和Neo4j
    • MongoDB
    • TiDB
    • MySQL 优化
    • MySQL 平滑扩容实战
    • MySQL 海量数据存储与优化
    • Elasticsearch
  • 缓存

    • Redis
    • Aerospike
    • Guava Cache
    • Tair
  • 文件存储

    • 阿里云 OSS 云存储
    • FastDF 文件存储
  • 基础

    • Linux 使用
    • Nginx 使用与配置
    • OpenResty 使用
    • LVS+Keepalived 高可用部署
    • Jekins
  • 容器技术

    • Docker
    • K8S
    • K8S
  • 01.全链路(APM)
  • 02.电商终极搜索解决方案
  • 03.电商亿级数据库设计
  • 04.大屏实时计算
  • 05.分库分表的深入实战
  • 06.多维系统下单点登录
  • 07.多服务之间分布式事务
  • 08.业务幂等性技术架构体系
  • 09.高并发下的12306优化
  • 10.每秒100W请求的秒杀架构体系
  • 11.集中化日志管理平台的应用
  • 12.数据中台配置中心
  • 13.每天千万级订单的生成背后痛点及技术突破
  • 14.红包雨的架构设计及源码实现
  • 人工智能

    • Python 笔记
    • Python 工具库
    • 人工智能(AI) 笔记
    • 人工智能(AI) 项目笔记
  • 大数据

    • Flink流处理框架
  • 加密区

    • 机器学习(ML) (opens new window)
    • 深度学习(DL) (opens new window)
    • 自然语言处理(NLP) (opens new window)
AI 导航 (opens new window)
  • 分布式原理

  • 分布式集群架构场景化解决方案
  • Dubbo

  • SpringCloud

  • SpringCloudAlibaba

    • Nacos实战应用
      • 1 Nacos安装
        • 1.1 Nacos概要
        • Nacos是什么
        • Nacos特性
        • 动态配置服务
        • 动态 DNS 服务
        • 服务及其元数据管理
        • Nacos版图
        • Nacos 生态图
        • 1.2 Nacos架构
        • 1.3 Nacos安装
        • Nacos Derby安装
        • Nacos MySQL版安装
        • Docker 安装Nacos
      • 2 Nacos功能应用
        • 2.1 Nacos服务注册与发现
        • 2.2 负载均衡
        • 2.3 配置中心
        • 2.3.1 配置管理
        • 2.3.2 多环境切换
        • 2.3.3 共享/扩展 配置
        • 2.3.4 配置刷新
        • Environment自动刷新
        • @Value刷新
        • 2.3.5 灰度发布
      • 3 Nacos集群
        • 3.1 集群架构
        • 3.2 Nacos集群部署
        • 3.3 客户端接入Nacos集群
    • Sentinel实战应用
    • Seata分布式事务
    • 资料
  • 微服务框架
  • SpringCloudAlibaba
Revin
2023-07-22
目录

Nacos实战应用

# 1 Nacos安装

Nacos是Alibaba微服务生态组件中的重要组件之一,主要用它实现应用的动态服务发现、配置管理、服务管理。

https://github.com/alibaba/spring-cloud-alibaba/wiki/Nacos-discovery

# 1.1 Nacos概要

# Nacos是什么

1613787203255

Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。

Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。 Nacos 是构建以“服务”为中心的现代应用架构 (例如微服务范式、云原生范式) 的服务基础设施。

Nacos 支持几乎所有主流类型的“服务”的发现、配置和管理:

1:Kubernetes Service
2:gRPC & Dubbo RPC Service
3:Spring Cloud RESTful Service
1
2
3

# Nacos特性

服务发现和服务健康监测:

Nacos 支持基于 DNS 和基于 RPC 的服务发现。服务提供者使用 原生SDK、OpenAPI、或一个独立的Agent TODO注册 Service 后,服务消费者可以使用DNS TODO 或HTTP&API查找和发现服务。

Nacos 提供对服务的实时的健康检查,阻止向不健康的主机或服务实例发送请求。Nacos 支持传输层 (PING 或 TCP)和应用层 (如 HTTP、MySQL、用户自定义)的健康检查。 对于复杂的云环境和网络拓扑环境中(如 VPC、边缘网络等)服务的健康检查,Nacos 提供了 agent 上报模式和服务端主动检测2种健康检查模式。Nacos 还提供了统一的健康检查仪表盘,帮助您根据健康状态管理服务的可用性及流量。
1
2
3

# 动态配置服务

动态配置服务可以让您以中心化、外部化和动态化的方式管理所有环境的应用配置和服务配置。


动态配置消除了配置变更时重新部署应用和服务的需要,让配置管理变得更加高效和敏捷。


配置中心化管理让实现无状态服务变得更简单,让服务按需弹性扩展变得更容易。


Nacos 提供了一个简洁易用的UI (控制台样例 Demo) 帮助您管理所有的服务和应用的配置。Nacos 还提供包括配置版本跟踪、金丝雀发布、一键回滚配置以及客户端配置更新状态跟踪在内的一系列开箱即用的配置管理特性,帮助您更安全地在生产环境中管理配置变更和降低配置变更带来的风险。
1
2
3
4
5
6
7
8
9
10

# 动态 DNS 服务

动态 DNS 服务支持权重路由,让您更容易地实现中间层负载均衡、更灵活的路由策略、流量控制以及数据中心内网的简单DNS解析服务。动态DNS服务还能让您更容易地实现以 DNS 协议为基础的服务发现,以帮助您消除耦合到厂商私有服务发现 API 上的风险。


Nacos 提供了一些简单的 DNS APIs TODO 帮助您管理服务的关联域名和可用的 IP:PORT 列表.
1
2
3
4

# 服务及其元数据管理

Nacos 能让您从微服务平台建设的视角管理数据中心的所有服务及元数据,包括管理服务的描述、生命周期、服务的静态依赖分析、服务的健康状态、服务的流量管理、路由及安全策略、服务的 SLA 以及最首要的 metrics 统计数据。
1

# Nacos版图

1613787928592

  • 特性大图:要从功能特性,非功能特性,全面介绍我们要解的问题域的特性诉求
  • 架构大图:通过清晰架构,让您快速进入 Nacos 世界
  • 业务大图:利用当前特性可以支持的业务场景,及其最佳实践
  • 生态大图:系统梳理 Nacos 和主流技术生态的关系
  • 优势大图:展示 Nacos 核心竞争力
  • 战略大图:要从战略到战术层面讲 Nacos 的宏观优势

# Nacos 生态图

1613788041519

Nacos 无缝支持一些主流的开源生态:

1:Spring Cloud
2:Apache Dubbo and Dubbo Mesh
3:Kubernetes and CNCF。
1
2
3

使用 Nacos 简化服务发现、配置管理、服务治理及管理的解决方案,让微服务的发现、管理、共享、组合更加容易。

# 1.2 Nacos架构

参考官方文档:https://nacos.io/zh-cn/docs/architecture.html

# 1.3 Nacos安装

关于Nacos安装,可以直接参考官网安装 https://nacos.io/zh-cn/docs/quick-start.html,我们接下来学习基于Docker实现Nacos单机安装和基于Docker实现Nacos集群安装。

采用Docker-Compose安装Nacos要更方便,所以大家可以先学习一下Docker-Compose。

Nacos安装模式有多种:

单机模式 Derby:
    这种模式是极简模式,数据没法持久化存储,适合开发环境。
    
单机模式 MySQL:(支持MySQL5.7和MySQL8.0,我们这里学习MySQL5.7安装模式,因为当前主流还是MySQL5.7)
    这种模式支持数据持久化,数据会存储到MySQL中,适合生产环境。


集群模式:
    这种模式适合生产环境并且服务节点个数较多,不存在单点故障问题。
1
2
3
4
5
6
7
8
9

克隆项目:

#克隆项目
git clone https://github.com/nacos-group/nacos-docker.git


#进入nacos-docker目录
cd nacos-docker


#查看文件列表
ce example
ll
1
2
3
4
5
6
7
8
9
10
11

example中文件列表如下:

1613893569603

# Nacos Derby安装

安装Nacos生产环境会结合prometheus和grafana实现对Nacos的监控,我们这里不做它们的监控操作,需要将docker-compose的配置注释掉,修改example/standalone-derby.yaml,配置如下:

1613897645208

进入到example目录下执行如下命令:

docker-compose -f standalone-derby.yaml up -d
1

安装完成后,我们可以直接访问它的控制台 http://192.168.200.200:8848/nacos,账号密码都是nacos,效果如下:

1613894414636

关于控制台的使用,我们在后面详细讲解。

# Nacos MySQL版安装

1、我们先停掉之前安装的服务,并删掉之前的容器

#停掉容器
docker stop nacos-standalone


#删掉容器
docker rm nacos-standalone


#或者一步到位
docker-compose -f standalone-derby.yaml down
1
2
3
4
5
6
7
8
9
10

2、使用example/standalone-mysql-5.7.yaml

version: "2"
services:
  nacos:
    image: nacos/nacos-server:${NACOS_VERSION}
    container_name: nacos-standalone-mysql
    env_file:
      - ../env/nacos-standlone-mysql.env
    volumes:
      - ./standalone-logs/:/home/nacos/logs
      - ./init.d/custom.properties:/home/nacos/init.d/custom.properties
    ports:
      - "8848:8848"
      - "9848:9848"
      - "9555:9555"
    depends_on:
      - mysql
    restart: on-failure
  mysql:
    container_name: mysql
    image: nacos/nacos-mysql:5.7
    env_file:
      - ../env/mysql.env
    volumes:
      - ./mysql:/var/lib/mysql
    ports:
      - "3306:3306"
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

3、在example目录下使用docker-compose命令启动

docker-compose -f standalone-mysql-5.7.yaml up -d
1

数据库脚本在nacos的nacos\config\src\main\resources\META-INF工程中有对应脚本,也可以通过下面的网址获取SQL:

https://github.com/alibaba/nacos/blob/develop/config/src/main/resources/META-INF/nacos-db.sql
1

创建数据库nacos_config,并执行初始化操作,初始化脚本后,数据库数据如下:

1613895445020

4、新建配置,查看存储

此时访问后台 http://192.168.200.200:8848/nacos ,并创建一个配置信息,如下图:

1613897367911

此时我们可以随意填写些配置,如下图:

1613896703407

配置填写后,数据会添加到数据库中的config_info表中,如下表:

1613896771931

# Docker 安装Nacos

我们也可以直接采用Docker的方式安装Nacos,这样安装不要克隆项目也不需要修改配置文件,会更方便,安装命令如下:

docker run -d \
-e MODE=standalone \
-e SPRING_DATASOURCE_PLATFORM=mysql \
-e MYSQL_SERVICE_HOST=192.168.200.129 \
-e MYSQL_SERVICE_PORT=3306 \
-e MYSQL_SERVICE_USER=root \
-e MYSQL_SERVICE_PASSWORD=root \
-e MYSQL_SERVICE_DB_NAME=nacos_config \
-p 8848:8848 \
--restart=always \
--name nacos nacos/nacos-server
1
2
3
4
5
6
7
8
9
10
11

注意:需要提取准备好msyql数据库

访问 http://192.168.200.200:8848/nacos 效果如下:

1613961905828

# 2 Nacos功能应用

# 2.1 Nacos服务注册与发现

服务发现是微服务架构体系中最关键的组件之一。如果尝试着用手动的方式来给每一个客户端来配置所有服务提供者的服务列表是一件非常困难的事,而且也不利于 服务的动态扩缩容。Nacos Discovery Starter 可以帮助您将服务自动注册到 Nacos 服务端并且能够动态感知和刷新某个服务实例的服务列表。除此之外,Nacos Discovery Starter 也将服务实例自身的一些元数据信息-例如 host,port,健康检查URL,主页等-注册到 Nacos 。

接下来我们学习一下如何使用Nacos作为服务的注册中心,并实现服务注册和服务发现。当前项目开发主流技术是SpringBoot,我们就讲解基于SpringBoot如何使用Nacos实现服务注册与发现。

1613903167694

如上图,我们以打车项目为例,当用户打车成功的时候,会调用hailtaxi-order,hailtaxi-order会下订单,同时修改司机状态,修改状态需要调用hailtaxi-driver,我们把hailtaxi-order服务和hailtaxi-driver服务都注册到Nacos中,并实现服务调用,如果整个调用都没有问题,就说明服务注册发现没问题。

关于SpringCloud Alibaba和SpringBoot的版本,我们可以通过 https://start.spring.io/actuator/info 查看。

1613904626739

SpringBoot我们修改成2.2.10版本,SpringCloud版本改成Hoxton.SR11版本。要使用Nacos需要引入依赖包,并且将Consul依赖移除。

1、注释掉hailtaxi-api和hailtaxi-gateway中的consul依赖包:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
1
2
3
4
5
6
7
8

另外在hailtaxi-order和hailtaxi-pay中也注意要注释掉consul的相关依赖坐标

2、在hailtaxi-api和hailtaxi-gateway中引入如下依赖:

<!--nacos-discovery-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    <version>2.2.5.RELEASE</version>
</dependency>
<!--nacos-config-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    <version>2.2.5.RELEASE</version>
</dependency>
1
2
3
4
5
6
7
8
9
10
11
12

3、配置bootstrap.yml

bootstrap.yml(bootstrap.properties)用来在程序引导时执行,应用于更加早期配置信息读取,如可以使用来配置application.yml中使用到参数等。

application.yml(application.properties) 应用程序特有配置信息,可以用来配置后续各个模块中需使用的公共参数等。

bootstrap.yml 先于 application.yml加载。

项目中如果使用Nacos,需要使用bootstrap.yml,因此我们需要将项目中的application.yml换成bootstrap.yml。

在hailtaxi-gateway中创建bootstrap.yml配置文件,添加如下配置:

spring:
  application:
    name: hailtaxi-gateway
  cloud:
    nacos:
      discovery:
        # nacos 服务注册地址
        server-addr: 192.168.200.200:8848
      config:
        server-addr: 192.168.200.200:8848
1
2
3
4
5
6
7
8
9
10

注释/删掉 :application.yml中和consul相关的配置以及spring.application.name的配置,application.yml中剩余的配置如下:

server:
  port: 8001
spring:
#  application:
#    name: hailtaxi-gateway
  main:
    allow-bean-definition-overriding: true


  cloud:
#    #Consul配置
#    consul:
#      host: 127.0.0.1
#      port: 8500
#      discovery:
#        #注册到Consul中的服务名字
#        service-name: ${spring.application.name}
#        #注册的服务的实例 Id,最好不要重复,这里参考官网建议的方式 带随机数 默认:应用名:port
#        #instance-id: ${spring.application.name}:${vcap.application.instance_id:${spring.application.i nstance_id:${random.value}}}
#        # 自定义实例id为:应用名:ip:port
#        instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}
#        prefer-ip-address: true
#        # 开启服务注册
#        register: true
#        # 开启服务发现
#        enabled: true
#        #2 分钟之后健康检查未通过取消注册
#        health-check-critical-timeout: 2m
#        #consul 健康检查的轮询周期  源码查看debug的时候把时间设置长一点
#        health-check-interval: 7200s
    gateway:
      #路由配置
      routes:
        #唯一标识符
        - id: hailtaxi-driver
          uri: lb://hailtaxi-driver
          #路由断言
          predicates:
            - Path=/driver/**
            - Cookie=username,itheima
            - Header=token,^(?!\d+$)[\da-zA-Z]+$
            - Method=GET,POST
            #- Token=Authorization
          filters:
            - PayMethod=alipay,业务整合
            - name: RequestRateLimiter #请求数限流 名字不能随便写 ,使用默认的facatory
              args:
                key-resolver: "#{@ipKeyResolver}"
                redis-rate-limiter.replenishRate: 1
                redis-rate-limiter.burstCapacity: 1
        #唯一标识符
        - id: hailtaxi-order
          uri: lb://hailtaxi-order
          #路由断言
          predicates:
            - Path=/order/**
        #唯一标识符
        - id: hailtaxi-pay
          uri: lb://hailtaxi-pay
          #路由断言
          predicates:
            - Path=/pay/**
  redis:
    host: 192.168.200.200
    port: 6379
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

4、在项目启动类上添加开启服务发现的注解

@SpringBootApplication
@EnableDiscoveryClient 
public class GatewayApplication {


    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class,args);
    }
}
1
2
3
4
5
6
7
8
9

此时我们运行hailtaxi-gateway,可以发现在Nacos中已经注册了相关服务,如下图:

1613963714031

5、按相同方式配置hailtaxi-driver,hailtaxi-order,hailtaxi-pay三个项目

hailtaxi-driver中创建bootstrap.yml并配置如下:

spring:
application:
name: hailtaxi-driver
cloud:
nacos:
 discovery:
   # nacos 服务注册地址
   server-addr: 192.168.200.200:8848
 config:
   server-addr: 192.168.200.200:8848
1
2
3
4
5
6
7
8
9
10

并注释掉/删掉 application.yml中跟consul相关的配置以及spring.application.name的配置

其他两个项目按相同方式操作即可!!!

6、启动各个服务,查看服务列表

注意:启动前,将hailtaxi-driver中的异常错误处理掉!!!

img

7、测试

使用postman测试:

http://localhost:8001/driver/info/1

http://localhost:8001/order

此时服务调用没有任何问题,说明服务注册和服务发现正常。

# 2.2 负载均衡

1613969752401

如上图,如果此时用户打车成功,会调用订单服务,订单服务会修改司机状态,此时会调用hailtaxi-driver,如果是生产环境,每个节点一定是集群状态,比如有2个hailtaxi-driver节点,此时如何实现负载均衡?

1613970021993

我们可以发现服务注册到Nacos中,有一个权重属性,这个权重属性就是Nacos的负载均衡机制,此时需要用到Nacos的负载均衡策略NacosRule,我们可以在程序中先初始化负载均衡算法,再到bootstrap.yml中配置权重。

1、初始化负载均衡算法

在hailtaxi-order中初始化负载均衡算法:

/***
 * Nacos负载均衡算法
 * @return
 */
@Bean
@Scope(value="prototype")
public IRule loadBalanceRule(){
    return new NacosRule();
}
1
2
3
4
5
6
7
8
9

2、权重配置,因为是基于权重的

为了演示集群效果,我们启动多个hailtaxi-driver,并在bootstrap.yml中配置权重

spring:
  application:
    name: hailtaxi-driver
  cloud:
    nacos:
      discovery:
        # nacos 服务注册地址
        server-addr: 192.168.200.200:8848
        weight: 1
      config:
        server-addr: 192.168.200.200:8848
1
2
3
4
5
6
7
8
9
10
11

这是默认18082的,对于18085和18086的配置如下

img

img

最终可以在nacos控制台查看服务的权重信息:

img

为了方便查看调用了哪个节点,我们把每个节点的端口号输出,我们请求打车测试

http://localhost:8001/order ,执行6次,应该会按1:2:3 的比例来调用

注意:如果hailtaxi-order模块通过openfeign调用超时,可以设置它的超时时间

由于openfeign底层默认使用的是ribbon,故可以采用如下配置:

ribbon:
    # 处理请求的超时时间
    ReadTimeout: 5000
    # 连接建立的超时时长
    ConnectTimeout: 5000
1
2
3
4
5

如果我们把算法NacosRule注释,默认就是和Ribbon集成,且默认开启,可以通过如下配置实现关闭或开启:

ribbon:
  nacos:
    enabled: true
1
2
3

# 2.3 配置中心

Nacos 提供用于存储配置和其他元数据的 key/value 存储,为分布式系统中的外部化配置提供服务器端和客户端支持。使用 Spring Cloud Alibaba Nacos Config,您可以在 Nacos Server 集中管理你 Spring Cloud 应用的外部属性配置。

Spring Cloud Alibaba Nacos Config 是 Config Server 和 Client 的替代方案,客户端和服务器上的概念与 Spring Environment 和 PropertySource 有着一致的抽象,在特殊的 bootstrap 阶段,配置被加载到 Spring 环境中。当应用程序通过部署管道从开发到测试再到生产时,您可以管理这些环境之间的配置,并确保应用程序具有迁移时需要运行的所有内容。

# 2.3.1 配置管理

1、我们可以在Nacos控制台配置项目的配置数据,先打开Nacos控制台,在命名空间中点击新建命名空间,如下图:

命名空间可以用于数据隔离,默认在public 命名空间中!!!

1613977703487

2、修改hailtaxi-driver中的bootstrap.yml配置文件,指定命名空间

spring:
  application:
    name: hailtaxi-driver
  cloud:
    nacos:
      discovery:
        # nacos 服务注册地址
        server-addr: 192.168.200.200:8848
        weight: 1
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
      config:
        server-addr: 192.168.200.200:8848
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
        # 如果将配置信息保存到nacos,指定配置文件扩展名
        file-extension: yaml
        # nacos config dataid name 默认加载 ${spring.application.name}.${file-extension},当然也可指定
        #name: hailtaxi-driver.yaml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

1620704955336

3、在nacos中添加配置

在配置管理>配置列表中添加,如下图:

1613977844047

将hailtaxi-driver原来在application.yml中的配置全部填写到下面表单中,然后将application.yml配置文件删除,或者删除所有配置,如下图:

Data ID:默认加载${spring.application.name}.${file-extension}

另外对于web服务的端口server.port一般留在application.yml中

1620704999354

注意Data ID的配置。

4、启动测试:

我们启动hailtaxi-driver服务,默认加载${spring.application.name}.${file-extension:properties} 配置,加载完成后,配置数据会生效,并访问

http://localhost:18081/driver/info/1 测试,效果如下:

1613979781750

5、配置hailtaxi-gateway,hailtaxi-order,hailtaxi-pay等几个项目

按照相同的方式,将各个项目中application.yml中的配置配置到nacos中,并注释/删除掉本地application.yml中的配置(端口的配置一般留在项目中)

最后启动所有项目,测试走网关的API。

# 2.3.2 多环境切换

spring-cloud-starter-alibaba-nacos-config在加载配置的时候,不仅仅加载以 dataid 为 ${spring.application.name}.${file-extension:properties} 为前缀的基础配置,还加载dataid为 ${spring.application.name}-${profile}.${file-extension:properties} 的基础配置。在日常开发中如果遇到多套环境下的不同配置,可以通过Spring 提供的 ${spring.profiles.active} 这个配置项来配置。

1、在nacos中创建hailtaxi-driver-dev.yaml作为开发环节的配置,创建hailtaxi-driver-test.yaml作为测试环境的配置文件,创建如下:

hailtaxi-driver-test.yaml
1

1613980232905

hailtaxi-driver-dev.yaml
1

1613980280737

这样多出来两份配置信息如下:

img

2、在hailtaxi-driver项目的bootstrap.yml中激活配置,如下:

1613980500168

启动项目,看是否能正常启动!!!

1613980500168

访问:http://localhost:18081/driver/info/1

1613980500168

3、将active换成test,启动后访问:http://localhost:18081/driver/info/1

1613980500168

# 2.3.3 共享/扩展 配置

在实际的业务场景中应用和共享配置间的关系可能,Spring Cloud Alibaba Nacos Config 从 0.2.1 版本后,可支持自定义 Data Id 的配置,通过它可以解决配置共享问题。

共享配置:

1、创建一个Data ID 为:datasource.yaml 的配置,用于配置数据库连接,如下图:

1613982784196

2、在hailtaxi-driver-dev.yaml中将数据库的配置信息删除,如下图:

1613982696525

3、在bootstrap.yml中引入共享配置需要使用shared-configs属性,配置如下:

spring:
  application:
    name: hailtaxi-driver
  profiles:
    # 激活 dev 配置
    active: dev
  cloud:
    nacos:
      discovery:
        # nacos 服务注册地址
        server-addr: 192.168.200.200:8848
        weight: 1
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
      config:
        server-addr: 192.168.200.200:8848
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
        # 如果将配置信息保存到nacos,指定配置文件扩展名
        file-extension: yaml
        # nacos config dataid name 默认加载 ${spring.application.name}.${file-extension},当然也可指定
        #name: hailtaxi-driver.yaml
        # 加载共享配置信息
        shared-configs[0]:
          dataId: datasource.yaml
          refresh: true
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

1613983119823

配置信息的加载由NacosConfigProperties完成

1613983119823

1613983119823

启动测试访问 http://localhost:18081/driver/info/1,此时能访问数据库,同时也能获取hailtaxi-driver-dev.yaml中的配置,效果如下:

1613983159016

扩展配置:

nacos除了支持读取以上所支持的的配置信息外,用户还可以自定义扩展配置

1、在nacos中 创建一个Data ID 为:custom.yaml 的配置,配置信息如下图:

app: 
  version: v1.0
1
2

img

2、在hailtaxi-driver模块的bootstrap.yml中加载该配置,使用extension-configs属性,如下:

spring:
  application:
    name: hailtaxi-driver
  profiles:
    active: dev
  cloud:
    nacos:
      discovery:
        # nacos 服务注册地址
        server-addr: 192.168.200.200:8848
        weight: 1
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
      config:
        server-addr: 192.168.200.200:8848
        # 指定命名空间的id
        namespace: 1ebba5f6-49da-40cc-950b-f75c8f7d07b3
        # 如果将配置信息保存到nacos,指定配置文件扩展名
        file-extension: yaml
        # nacos config dataid name 默认加载 ${spring.application.name}.${file-extension},当然也可指定
        #name: hailtaxi-driver.yaml
        # 加载共享配置信息
        shared-configs[0]:
          dataId: datasource.yaml
          refresh: true
        # 加载扩展配置
        extension-configs:
          - dataId: custom.yaml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

3、在应用程序中去读该配置,在DriverController中添加如下代码

@Value("${app.version:v0}")
private String version;


@GetMapping("/appinfo")
public String getAppInfo() {
    return version;
}
1
2
3
4
5
6
7
8

4、测试访问:http://localhost:18081/driver/appinfo 查看结果

# 2.3.4 配置刷新

配置自动刷新对程序来说非常重要,Nacos支持配置自动刷新,并且提供了多种刷新机制。

# Environment自动刷新

spring-cloud-starter-alibaba-nacos-config 支持配置的动态更新,Environment能实时更新到最新的配置信息,启动 Spring Boot 应用测试的代码如下:

1、在hailtaxi-driver-dev.yaml中添加一个配置项,如下

app: 
  name: itheima
1
2

img

2、在hailtaxi-driver的启动类中添加一段测试代码:

@SpringBootApplication
@EnableDiscoveryClient
@MapperScan(basePackages = "com.itheima.driver.mapper")
public class DriverApplication {


    public static void main(String[] args) {
        ApplicationContext applicationContext = SpringApplication.run(DriverApplication.class,args);


        while(true) {
            //当动态配置刷新时,会更新到 Enviroment中,
            String name = applicationContext.getEnvironment().getProperty("app.name");
            String version = applicationContext.getEnvironment().getProperty("app.version");
            System.out.println("app.name="+name+";app.version=" + version);
            try {
                TimeUnit.SECONDS.sleep(5); // 每隔5秒中从Enviroment中获取一下
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

3、启动查看控制台输出,

4、在nacos中修改app.name 和 app.version,再次查看控制台输出

5、默认情况下,shared-configs 和 extension-configs 是不自动刷新的,【其他配置可以】,如果要支持刷新,需要添加refresh属性,如下

        # 加载共享配置信息
        shared-configs[0]:
          dataId: datasource.yaml
          refresh: true
        # 加载扩展配置
        extension-configs:
          - dataId: custom.yaml
            refresh: true
1
2
3
4
5
6
7
8
# @Value刷新

程序中如果写了@Value注解,可以采用@RefreshScope实现刷新,只需要在指定类上添加该注解即可,如下代码:

@RestController
@RequestMapping(value = "/driver")
@RefreshScope
public class DriverController {


    @Value("${app.version}")
    private String version;
    @Value("${app.name}")
    private String appname;


    @GetMapping("/appinfo")
    public String getAppInfo() {
        return appname + ";"+version;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

启动测试: http://localhost:18081/driver/appinfo

修改完配置信息后再次测试,查看是否能动态刷新!

# 2.3.5 灰度发布

灰度配置指的是指定部分客户端IP进行新配置的下发,其余客户端配置保持不变,用以验证新配置对客户端的影响,保证配置的平稳发布。灰度配置是生产环境中一个比较重要的功能,对于保证生产环境的稳定性非常重要。在1.1.0中,Nacos支持了以IP为粒度的灰度配置,具体使用步骤如下:

1、将hailtaxi-driver项目打包,上传到服务器,并启动

2、本地也启动

查看nacos中的服务列表

img

img

3、在nacos中,找到hailtaxi-driver-dev.yaml 中,编辑配置,勾选“Beta发布”,在文本框里填入要下发配置配置的IP,多个IP用逗号分隔,操作如下:

1614048453837

修改配置内容,点击“发布Beta”按钮,即可完成灰度配置的发布,点击“发布Beta”后,“发布Beta”按钮变灰,此时可以选择“停止Beta”或者“发布”。“停止Beta”表示取消停止灰度发布,当前灰度发布配置的IP列表和配置内容都会删除,页面回到正常发布的样式。“发布”表示将灰度配置在所有客户端生效,之前的配置也会被覆盖,同时页面回到正常发布的样式:

1614048729667

4、测试:

访问:

http://localhost:18081/driver/appinfo

http://192.168.200.200:18081/driver/appinfo

# 3 Nacos集群

在生产环境Nacos一般都不是单节点存在,如果是单节点,很容易存在单点故障,因此生产环境一般都以集群形式存在。

# 3.1 集群架构

Nacos集群模式有多种,但其实无论哪种都是将3个Nacos服务进行集群发布。

集群需要采用数据共享模式进行配置信息共享,也就是要将数据存入到同一个数据库中,我们对每种集群模式进行说明:

1)直连模式

http://ip1:port/openAPI 直连ip模式,机器挂则需要修改ip才可以使用。

比如我现在有3个Nacos,每次操作数据的时候,都需要使用IP:端口的模式,这种模式效率极低,并且一旦节点故障无法识别,因此官方不推荐这种模式。

2)VIP模式

http://VIP:port/openAPI 挂载VIP模式,直连vip即可,下面挂server真实ip,可读性不好。

3)域名模式

http://nacos.com:port/openAPI 域名 + VIP模式,可读性好,而且换ip方便,因此官方推荐该模式,该模式的结构图如下:

1614050197069

# 3.2 Nacos集群部署

我们搭建Nacos集群环境,集群环境配置如下:

节点 IP 端口
Nacos1 192.168.211.145 8848
Nacos2 192.168.211.146 8848
Nacos3 192.168.211.147 8848

1)服务下载

在https://github.com/alibaba/nacos/releases/下载需要的服务,当前使用的是1.4.1, 我们可以选择下载1.4.1版本,版本如下:

1614060532599

解压压缩包后,包结构如下:

1614060842807

2)配置数据库

修改conf/application.properties配置数据库,配置如下:

1614061050180

3)集群配置

修改conf/cluster.conf配置集群:

192.168.211.145:8848
192.168.211.146:8848
192.168.211.147:8848
1
2
3

4)节点同步

将修改好的服务分别上传到192.168.211.146、192.168.211.147服务:

scp -r nacos 192.168.211.146:/usr/local/server/alibaba/
scp -r nacos 192.168.211.147:/usr/local/server/alibaba/
1
2

5)启动每个节点

进入到每个节点nacos/bin目录下,执行启动:

sh startup.sh
1

访问任何一个单节点,信息如下:

1614060196503

注:

学习阶段,为了节省资源,可以直接使用nacos-docker中已配置好的集群启动 yml 进行启动

# 3.3 客户端接入Nacos集群

客户端接入,不建议写多个节点的IP:Port,建议以域名的方式连接Nacos,因此需要配置Nacos域名,在192.168.211.145节点中配置域名nacos.hailtaxi.com,nginx配置如下:

#负载均衡池配置
upstream hailtaxi-nacos{
    server 192.168.211.145:8848;
    server 192.168.211.146:8848;
    server 192.168.211.147:8848;
}


server {
    listen       80;
    server_name  nacos.hailtaxi.com;


    location / {
        proxy_pass http://hailtaxi-nacos;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

配置nacos.hailtaxi.com域名映射:

#修改hosts文件
vi /etc/hots


#添加如下映射关系
192.168.211.145 hailtaxinacos.com
1
2
3
4
5
6

保存Nginx配置,并启动Nginx,修改本地C:\Windows\System32\drivers\hosts,添加如下配置:

192.168.211.145 hailtaxinacos.com
1

访问http://hailtaxinacos.com/nacos,效果如下:

1614062368155

项目中使用:

方式1:

项目中Nacos地址可以把多个地址写到一起,用逗号隔开,如下代码:

1614063943737

Nacos效果如下:

1620726263452

方式2:

通过Nginx访问即可,配置如下:

192.168.211.145:80
1
上次更新: 2025/04/03, 11:07:08
SpringCloudGateway
Sentinel实战应用

← SpringCloudGateway Sentinel实战应用→

最近更新
01
tailwindcss
03-26
02
PaddleSpeech
02-18
03
whisper
02-18
更多文章>
Theme by Vdoing | Copyright © 2019-2025 跨境互联网 | 豫ICP备14016603号-5 | 豫公网安备41090002410995号
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式