首頁手記 Nacos配置中心項目實戰入門教程

Nacos配置中心項目實戰入門教程

標簽：

Java Spring Cloud 微服務

概述

本文将详细介绍Nacos配置中心项目实战，包括Nacos的基本概念、核心功能以及与Spring Cloud的集成方法。通过环境搭建、配置中心的基本使用、服务发现与管理等内容，帮助读者全面掌握Nacos的使用技巧。文中还将通过实战案例演示如何在实际项目中应用Nacos进行配置管理和服务发现。

Nacos简介

什么是Nacos

Nacos 是一个动态服务发现、配置管理和服务管理的平台。Nacos 名称来源于 Dynamic Naming and Configuration Service 的缩写。它可以帮助您管理微服务架构中的动态配置和服务发现，并实现服务之间的健康检查和负载均衡。

Nacos的核心功能

Nacos 提供了以下核心功能：

动态配置服务：通过 Nacos 可以集中管理应用的配置，并支持实时动态更新配置，使配置更改可以立即生效。
服务发现与负载均衡：Nacos 支持基于域名的服务发现，并提供了内置的负载均衡器，可以实现服务之间的负载均衡。
健康检查与服务管理：Nacos 提供了服务的健康检查功能，可以自动发现并剔除不可用的服务实例，提高服务的可用性。
元数据管理：除了配置和服务信息，Nacos 还可以管理元数据，如服务的版本、环境等。

Nacos与Spring Cloud的关系

Nacos 可以与 Spring Cloud 配合使用，以提供更强大的微服务管理功能。Spring Cloud 提供了一套完整的微服务解决方案，其中包含了服务发现、配置管理和负载均衡等功能。Nacos 可以作为 Spring Cloud 的配置中心和注册中心，替代原有的 Eureka 和 Config Server。

Nacos 与 Spring Cloud 集成的优势在于：

配置中心：可以使用 Nacos 作为 Spring Cloud Config Server 的替代方案，实现配置的集中管理和实时动态更新。
注册中心：可以使用 Nacos 作为 Eureka 的替代方案，实现服务的注册和发现，并支持服务的健康检查。
负载均衡：Nacos 内置了负载均衡的功能，可以简化服务之间的负载均衡配置。

环境搭建

安装Java环境

为了运行 Nacos 服务，首先需要安装 Java 开发工具包（JDK）。这里以安装 OpenJDK 作为示例。

下载 OpenJDK：

wget https://downloads.apache.org/openjdk/jdk8u/jdk8u232-b09/freertos-8u232-b09-linux-x64-1.8.2720.08-28-06-2020.tar.gz
tar -xzf freertos-8u232-b09-linux-x64-1.8.2720.08-28-06-2020.tar.gz

设置环境变量：

echo "export JAVA_HOME=/path/to/jdk" >> ~/.bashrc
echo "export PATH=\$JAVA_HOME/bin:\$PATH" >> ~/.bashrc
source ~/.bashrc

检查 Java 安装：
```
java -version
```

下载并启动Nacos服务

下载 Nacos：

wget https://github.com/alibaba/nacos/releases/download/2.0.3/nacos-server-2.0.3.tar.gz
tar -xzf nacos-server-2.0.3.tar.gz
cd nacos/nacos-server-2.0.3

启动 Nacos 服务：
```
sh bin/startup.sh -m standalone
```
查看 Nacos 启动日志：
```
tail -f logs/standalone.log
```
访问 Web 控制台：
打开浏览器并访问 http://localhost:8848/nacos。默认的用户名和密码为 nacos。

创建Nacos账号和配置空间

登录 Nacos Web 控制台。
创建账号：
- 在左侧菜单中选择“用户管理”。
- 点击“添加用户”按钮，填写用户名和密码。
创建配置空间：
- 在左侧菜单中选择“配置管理”。
- 点击“创建配置”按钮，填写配置空间名称。
- 例如，创建一个名称为 example-config 的配置空间。

配置中心基本使用

添加配置文件

登录 Nacos Web 控制台。
在左侧菜单中选择“配置管理”。
选择已创建的配置空间，点击“新增配置”或“编辑配置”按钮，添加配置文件。
- 例如，添加一个名为 application.properties 的配置文件，内容如下：
```
server.port=8080
spring.application.name=example-app
```

从Nacos读取配置

为了从 Nacos 读取配置，可以在应用程序中引入 Nacos 客户端库。以下是在 Spring Boot 项目中引入 Nacos 客户端依赖的具体步骤：

引入 Nacos 客户端依赖：

<dependency>
   <groupId>com.alibaba.nacos</groupId>
   <artifactId>nacos-client</artifactId>
   <version>2.0.1</version>
</dependency>

读取配置示例代码：

import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.ConfigListener;
import com.alibaba.nacos.api.exception.NacosException;

import java.util.Properties;

public class NacosConfigExample {
   public static void main(String[] args) throws NacosException {
       String serverAddr = "localhost:8848";
       String dataId = "example-config";
       String group = "DEFAULT_GROUP";
       String configType = "properties";

       Properties properties = new Properties();
       properties.put("serverAddr", serverAddr);
       ConfigService configService = NacosFactory.createConfigService(dataId, group, properties);

       String configInfo = configService.getConfig(dataId, group, 5000);
       System.out.println("配置内容: " + configInfo);

       // 添加配置监听器
       configService.addListener(dataId, group, new ConfigListener() {
           @Override
           public void receiveConfigInfo(String configInfo) {
               System.out.println("配置已更新: " + configInfo);
           }
       });
   }
}

实时刷新配置

Nacos 支持配置的实时刷新，可以通过添加配置监听器实现。例如，在 Spring Boot 项目中，可以通过配置刷新注解 @RefreshScope 实现动态刷新。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

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

    @RestController
    @RefreshScope
    public class ConfigController {
        @GetMapping("/config")
        public String getConfig() {
            return "Hello, Config!";
        }
    }
}

服务发现与管理

注册服务到Nacos

为了将服务注册到 Nacos，需要在服务提供者和服务消费者中引入 Nacos 客户端库。以下是在 Spring Boot 项目中引入 Nacos 客户端依赖的具体步骤：

引入 Nacos 客户端依赖：

<dependency>
   <groupId>com.alibaba.nacos</groupId>
   <artifactId>nacos-client</artifactId>
   <version>2.0.1</version>
</dependency>

注册服务示例代码：

import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingFactory;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.listener.NamingEvent;
import com.alibaba.nacos.api.naming.listener.NamingEventListener;

public class NacosNamingExample {
   public static void main(String[] args) throws NacosException {
       String serverAddr = "localhost:8848";
       String groupName = "DEFAULT_GROUP";
       String serviceName = "example-service";
       String ip = "127.0.0.1";
       int port = 8080;

       NamingService namingService = NacosFactory.createNamingService(serverAddr);
       namingService.registerInstance(serviceName, ip, port);

       // 添加服务监听器
       namingService.subscribe(serviceName, groupName, new NamingEventListener() {
           @Override
           public void onEvent(NamingEvent event) {
               System.out.println("服务变更: " + event.getInstance());
           }
       });
   }
}

服务消费示例代码

以下是在服务消费端调用服务提供者的示例代码：

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.RestController;

@RestController
public class ConsumerController {
    @Autowired
    private DiscoveryClient discoveryClient;

    @GetMapping("/call")
    public String callService() {
        ServiceInstance serviceInstance = discoveryClient.getLocalServiceInstance();
        String host = serviceInstance.getHostname();
        int port = serviceInstance.getPort();
        // 通过 host 和 port 调用服务提供者
        return "调用了服务提供者 " + host + ":" + port;
    }
}

服务发现的基本原理

Nacos 通过 DNS 或者长轮询机制来实现服务发现。服务提供者通过 Nacos 注册自己的服务实例，服务消费者从 Nacos 获取服务实例列表，并根据需要选择实例进行调用。

动态服务列表更新

当服务实例发生变化时，Nacos 会实时推送变更信息到服务消费者。例如，服务实例宕机或新增服务实例时，服务消费者会收到通知并更新服务实例列表。

实战案例

配置管理的微服务应用

这里将演示如何在一个简单的微服务应用中使用 Nacos 进行配置管理。

服务端代码

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
@RestController
public class ConfigServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }

    @GetMapping("/config")
    public String getConfig() {
        return "Hello, Config Server!";
    }
}

客户端代码

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
@RefreshScope
@RestController
public class ConfigClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }

    @GetMapping("/config")
    public String getConfig() {
        return "Hello, Config Client!";
    }
}

实时更新配置的示例代码

为了实现配置的实时更新，可以在客户端中引入 Nacos 客户端库，并监听配置变化。

引入 Nacos 客户端依赖：

<dependency>
   <groupId>com.alibaba.nacos</groupId>
   <artifactId>nacos-client</artifactId>
   <version>2.0.1</version>
</dependency>

客户端配置监听示例代码：

import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.ConfigListener;
import com.alibaba.nacos.api.exception.NacosException;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
@RefreshScope
@RestController
public class ConfigClientApplication {
   public static void main(String[] args) {
       SpringApplication.run(ConfigClientApplication.class, args);
   }

   @Value("${server.port}")
   private int serverPort;

   @GetMapping("/config")
   public String getConfig() {
       return "Hello, Config Client! Server Port: " + serverPort;
   }

   public void initConfigListener() throws NacosException {
       String serverAddr = "localhost:8848";
       String dataId = "example-config";
       String group = "DEFAULT_GROUP";
       String configType = "properties";

       Properties properties = new Properties();
       properties.put("serverAddr", serverAddr);
       ConfigService configService = NacosFactory.createConfigService(dataId, group, properties);

       configService.addListener(dataId, group, new ConfigListener() {
           @Override
           public void receiveConfigInfo(String configInfo) {
               System.out.println("配置已更新: " + configInfo);
               // 更新配置信息
               Properties newProperties = new Properties();
               try {
                   newProperties.load(new StringReader(configInfo));
                   serverPort = Integer.parseInt(newProperties.getProperty("server.port"));
               } catch (Exception e) {
                   e.printStackTrace();
               }
           }
       });
   }
}

常见问题与解决

常见报错及解决方法

Nacos 服务未启动
- 确认 Nacos 服务已经在本地启动，并且可以访问 http://localhost:8848/nacos。
- 检查 Nacos 的日志文件，查看是否有启动失败的日志信息。
配置未更新
- 确认配置文件已经保存到 Nacos 中，并且客户端已经正确注册了配置监听器。
- 检查客户端的配置监听器是否正确注册，可以尝试手动更新配置并观察客户端的响应。
服务注册失败
- 确认服务端已经引入 Nacos 客户端依赖，并且服务端代码已经正确注册服务实例。
- 检查服务端的日志文件，查看是否有注册失败的日志信息。
服务发现失败
- 确认服务端已经注册服务实例，并且客户端已经正确订阅了服务列表。
- 检查客户端的日志文件，查看是否有订阅失败的日志信息。

性能优化与注意事项

减少配置文件数量
- 配置文件过多会增加 Nacos 的存储和更新压力，建议将相似的配置合并到一个配置文件中。
合理设置配置监听器
- 配置监听器会增加客户端的网络通信开销，建议根据实际需求合理设置监听器。
定期清理无效配置
- 定期清理不再使用的配置文件，释放存储空间。
使用缓存
- 在客户端使用缓存机制减少配置的频繁读取，减少对 Nacos 服务的访问压力。
优化网络配置
- 确保 Nacos 服务和客户端之间的网络连接稳定，避免网络抖动导致配置更新不及时。

通过以上优化措施，可以提高 Nacos 的性能和稳定性，确保配置和服务管理的高效运行。

點擊查看更多內容

為 TA 點贊

若覺得本文不錯，就分享一下吧！

評論

評論

共同學習，寫下你的評論

評論加載中...

展開查看更多評論

作者其他優質文章

正在加載中

慕仙森

手記
篇

粉絲

37

獲贊與收藏

105

關注作者，訂閱最新文章

閱讀免費教程

Java并發工具

23個小節 19845 321

Java 并發原理入門教程

26個小節 40025 580

Java 入門教程

50個小節 351805 3256

推薦

評論

收藏

共同學習，寫下你的評論



感謝您的支持，我會繼續努力的～

掃碼打賞，你說多少就多少

贊賞金額會直接到老師賬戶

支付方式

打開微信掃一掃，即可進行掃碼打賞哦

今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與放棄機會

點擊
抽獎

慕課手記新用戶專享福利

恭喜你，你的運氣太好了，居然抽中了 100個積分！

恭喜你，抽中了價值元的專欄！

太棒了，直接落到你賬戶里！

積分商城里的羅技鼠標、機械鍵盤、
Kindle 閱讀器、小米平衡車
Apple iPad （10.2英寸）、大額優惠券
在等著你去兌換了噢

作者：

免費贈送

兌換碼：1111222211 復制

優惠券可用于購買實戰課、體系課
無門檻使用

先去看看，有什么好東西馬上兌換我愛學習，選課去


亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

熱搜

最近搜索清空

Nacos配置中心項目實戰入門教程

什么是Nacos

Nacos的核心功能

Nacos与Spring Cloud的关系

安装Java环境

下载并启动Nacos服务

创建Nacos账号和配置空间

添加配置文件

从Nacos读取配置

实时刷新配置

注册服务到Nacos

服务消费示例代码

服务发现的基本原理

动态服务列表更新

配置管理的微服务应用

服务端代码

客户端代码

实时更新配置的示例代码

常见报错及解决方法

性能优化与注意事项

閱讀免費教程