写点什么

Nacos 实战及其源码分析

用户头像
程序员Fox
关注
发布于: 2020 年 11 月 20 日
Nacos实战及其源码分析

1.什么是 Nacos

官方文档: https://nacos.io/zh-cn/docs/what-is-nacos.html

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



Nacos 的关键特性包括:

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

  • 动态配置服务

  • 动态 DNS 服务

  • 服务及其元数据管理

Nacos 架构



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

Nacos Server部署

下载源码编译

源码下载地址:https://github.com/alibaba/nacos/

cd nacos/
mvn -Prelease-nacos clean install -U
cd nacos/distribution/target/

下载安装包

下载地址:https://github.com/alibaba/Nacos/releases



单机模式

官方文档: https://nacos.io/zh-cn/docs/deployment.html

解压,进入nacos目录



单机启动nacos,执行命令

bin/startup.sh -m standalone

访问nocas的管理端:http://192.168.3.14:8848/nacos ,默认的用户名密码是 nocas/nocas



集群模式

官网文档: https://nacos.io/zh-cn/docs/cluster-mode-quick-start.html

1)单机搭建伪集群,复制nacos安装包,修改为nacos8849,nacos8850,nacos8851



2)以nacos8849为例,进入nacos8849目录

2.1)修改conf\application.properties的配置,使用外置数据源

#使用外置mysql数据源
spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://192.168.3.14:3306/nacos_test?characterEncoding=utf8
&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=root





2.2)将conf\cluster.conf.example改为cluster.conf,添加节点配置

# ip:port
192.168.3.14:8849
192.168.3.14:8850
192.168.3.14:8851

nacos8850,nacos8851 按同样的方式配置。

3)创建mysql数据库,sql文件位置:conf\nacos-mysql.sql

4) 修改启动脚本(bin\startup.sh)的jvm参数



5) 分别启动nacos8849,nacos8850,nacos8851

以nacos8849为例,进入nacos8849目录,启动nacos

bin/startup.sh





6) 测试

登录 http://192.168.3.14:8849/nacos ,用户名和密码都是nacos



7)官方推荐,nginx反向代理

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

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

http://nacos.com:port/openAPI 域名 + VIP模式,可读性好,而且换ip方便,推荐模式





nginx的配置如下:



测试访问: http://192.168.3.14:8847/nacos



2.Nacos注册中心

官方文档: https://github.com/alibaba/spring-cloud-alibaba/wiki/Nacos-discovery

微服务之间如何调用

RestTemplate实现服务间调用

Spring框架提供的RestTemplate类可用于在应用中调用rest服务,它简化了与http服务的通信方式,统一了RESTful的标准,封装了http链接, 我们只需要传入url及返回值类型即可。相较于HttpClient,RestTemplate是一种更优雅的调用RESTful服务的方式。在SpringBoot中可以通过RestTemplate 调用方式来进行服务调用,比如user服务(服务消费者)调用order服务(服务提供者)。

示例代码如下:

String url = "http://localhost:8010/order/findOrderByUserId/"+id;
ResponseEntity<List> responseEntity = restTemplate.getForEntity(url,
List.class);
List<Order> orderList = responseEntity.getBody();

思考: 如何动态的实现服务的发现?

注册中心演进

https://www.processon.com/view/link/5e71cc85e4b011fcce9d604d



注册中心架构



核心功能

服务注册:Nacos Client会通过发送REST请求的方式向Nacos Server注册自己的服务,提供自身的元数据,比如ip地址、端口等信息。Nacos Server接收到注册请求后,就会把这些元数据信息存储在一个双层的内存Map中。

服务心跳:在服务注册后,Nacos Client会维护一个定时心跳来持续通知Nacos Server,说明服务一直处于可用状态,防止被剔除。默认5s发送一次心跳。

服务同步:Nacos Server集群之间会互相同步服务实例,用来保证服务信息的一致性。

服务发现:服务消费者(Nacos Client)在调用服务提供者的服务时,会发送一个REST请求给Nacos Server,获取上面注册的服务清单,并且缓存在Nacos Client本地,同时会在Nacos Client本地开启一个定时任务定时拉取服务端最新的注册表信息更新到本地缓存。

服务健康检查:Nacos Server会开启一个定时任务用来检查注册服务实例的健康情况,对于超过15s没有收到客户端心跳的实例会将它的healthy属性置为false(客户端服务发现时不会发现),如果某个实例超过30秒没有收到心跳,直接剔除该实例(被剔除的实例如果恢复发送心跳则会重新注册)。



快速开始

搭建Nacos-client服务

1)引入依赖

父Pom中支持spring cloud&spring cloud alibaba, 引入依赖。

<dependencyManagement>
<dependencies>
<!--引入springcloud的版本-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Greenwich.SR3</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>2.1.1.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<repositories>
<repository>
<id>spring</id>
<url>https://maven.aliyun.com/repository/spring</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>

当前项目pom中引入依赖

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

2) application.properties中配置

server.port=8002
#微服务名称
spring.application.name=service-user
#配置 Nacos server 的地址
spring.cloud.nacos.discovery.server-addr=localhost:8848

更多配置:https://github.com/alibaba/spring-cloud-alibaba/wiki/Nacos-discovery



3)启动springboot应用,nacos管理端界面查看是否成功注册



4)测试

使用RestTemplate进行服务调用,可以使用微服务名称 (spring.application.name)

String url = "http://service-order/order/findOrderByUserId/"+id;
ResponseEntity<List> responseEntity = restTemplate.getForEntity(url,
List.class);
List<Order> orderList = responseEntity.getBody();

注意:需要添加@LoadBalanced注解

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



服务注册表结构



数据模型

Nacos 数据模型 Key 由三元组唯一确定, Namespace默认是空串,公共命名空间(public),分组默认是 DEFAULT_GROUP。



服务领域模型



官网地址:https://nacos.io/zh-cn/docs/architecture.html

服务实例数据

[{
"clusterName": "DEFAULT",
"enabled": true,
"ephemeral": true,
"healthy": true,
"instanceHeartBeatInterval": 5000,
"instanceHeartBeatTimeOut": 15000,
"instanceId": "127.0.0.1#8880#DEFAULT#DEFAULT_GROUP@@orderService",
"instanceIdGenerator": "simple",
"ip": "127.0.0.1",
"ipDeleteTimeout": 30000,
"metadata": {},
"port": 8880,
"serviceName": "DEFAULT_GROUP@@orderService",
"weight": 1.0
}, {
"clusterName": "DEFAULT",
"enabled": true,
"ephemeral": true,
"healthy": true,
"instanceHeartBeatInterval": 5000,
"instanceHeartBeatTimeOut": 15000,
"instanceId": "127.0.0.1#8888#DEFAULT#DEFAULT_GROUP@@orderService",
"instanceIdGenerator": "simple",
"ip": "127.0.0.1",
"ipDeleteTimeout": 30000,
"metadata": {},
"port": 8888,
"serviceName": "DEFAULT_GROUP@@orderService",
"weight": 1.0
}]



3.Nacos源码分析

为什么看源码

  • 提升技术功底

  • 深度掌握技术框架

  • 快速定位线上问题

  • 面试必问

  • 技术追求

原则

  • 定焦原则: 抓主线(抓住一个核心流程去分析,不要漫无目的的去看源代码)

  • 宏观原则: 站在上帝视角,先脉络后枝叶 (切忌试图搞清楚每一行代码)

方法

  1. 先会使用,了解框架的设计思想和功能架构

  2. 抓主线,多尝试静态看代码

  3. 在源码中写注释&画流程图

  4. 整合总结

技巧

  1. 断点(观察调用栈,利用条件断点,表达式)

  2. 反调 (Find Usages)

  3. 根据接口方法找到具体实现

  4. 猜测类名方法名

  5. 看控制台日志

心态

  • 克服对源码的恐惧心理

  • 静下心读源码

Nacos源码编译运行

源码下载地址:https://github.com/alibaba/nacos/

版本: Nacos 1.1.4



1)进入nacos目录,执行编译命令

mvn -Prelease-nacos -DskipTests clean install -U

编译成功后会在distribution/target目录下生成nacos-server-1.1.4.tar.gz



2)启动nacos

进入console模块,找到启动类 com.alibaba.nacos.Nacos,执行main方法



  • 配置启动参数

单机模式执行需要指定nacos.standalone=true

-Dnacos.standalone=true -Dnacos.home=D:\code\java_yuanma\nacos-1.1.4
  • 创建nacos_config数据库(distribution/conf/nacos-mysql.sql)

  • 在application.properties中添加mysql配置

# 支持mysql
spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos_config?characterEncoding=utf8\
&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=root

3)进入http://localhost:8848/nacos,用户名和密码默认nacos



注册中心源码分析

https://www.processon.com/view/link/5ea27ca15653bb6efc68eb8c



发布于: 2020 年 11 月 20 日阅读数: 66
用户头像

程序员Fox

关注

思想比技术更重要,有术无道止于术 2019.03.12 加入

多年中间件开发经验,擅长分布式,微服务架构技术,精通各大源码框架,源码控,喜欢分享技术

评论

发布
暂无评论
Nacos实战及其源码分析