Nacos 构建 Spring Cloud Alibaba 服务发现体系

2.2.2 添加 Nacos 注册中心依赖

<dependencies>
    <!-- Spring Cloud Alibaba Nacos Discovery -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!-- Spring Web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- Spring Boot Test -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

2.2.3 添加 Nacos 配置中心依赖 (可选但推荐)

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

三、服务提供者 (Provider) 实践

服务提供者负责注册自身服务，并对外提供服务接口。

3.1 服务提供者的配置

3.1.1 application.yml 配置文件

server:
  port: 8081
spring:
  application:
    name: service-provider # 应用名称，也是服务名的一部分
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 # Nacos Server 地址
      config:
        server-addr: localhost:8848 # 配置中心地址 (可选)
        file-extension: yaml
management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics
  endpoint:
    health:
      show-details: always

3.1.2 主类配置

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient // 启用服务发现客户端
public class ServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceProviderApplication.class, args);
    }
}

📝 关键注解说明：@EnableDiscoveryClient 启用服务发现客户端功能，使应用能够向 Nacos 注册自身并发现其他服务。spring.application.name 是服务名的关键部分。

3.2 实现服务接口

3.2.1 创建服务接口类

package com.example.service;

public interface EchoService {
    String echo(String message);
}

3.2.2 实现服务接口

package com.example.service.impl;

import com.example.service.EchoService;
import org.springframework.stereotype.Service;

@Service
public class EchoServiceImpl implements EchoService {
    @Override
    public String echo(String message) {
        return "Echo from provider: " + message;
    }
}

3.2.3 创建 RESTful 控制器

package com.example.controller;

import com.example.service.EchoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class EchoController {
    @Autowired
    private EchoService echoService;

    @GetMapping("/echo")
    public String echo(@RequestParam String message) {
        return echoService.echo(message);
    }
}

3.2.4 运行服务提供者

编译并运行 ServiceProviderApplication 类。启动成功后，你应该能在 Nacos 控制台的'服务列表'页面看到名为 service-provider 的服务。

四、服务消费者 (Consumer) 实践

服务消费者需要能够发现并调用服务提供者提供的服务。

4.1 服务消费者的配置

4.1.1 application.yml 配置文件

server:
  port: 8080
spring:
  application:
    name: service-consumer
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
      config:
        server-addr: localhost:8848
        file-extension: yaml
management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics
  endpoint:
    health:
      show-details: always

4.1.2 主类配置

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient // 启用服务发现
@EnableFeignClients // 启用 Feign 客户端
public class ServiceConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceConsumerApplication.class, args);
    }
}

4.2 实现服务调用

4.2.1 使用 RestTemplate 调用 (传统方式)

4.2.1.1 配置 RestTemplate Bean

package com.example.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class RestTemplateConfig {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

4.2.1.2 创建服务调用类

package com.example.service;

import com.alibaba.nacos.api.exception.NacosException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.List;

@Service
public class RestTemplateCallService {
    private static final Logger logger = LoggerFactory.getLogger(RestTemplateCallService.class);

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private LoadBalancerClient loadBalancerClient;

    /**
     * 调用服务提供者
     * 方式一：通过 LoadBalancerClient 获取实例并调用
     */
    public String callProviderWithLoadBalancer(String message) {
        try {
            ServiceInstance instance = loadBalancerClient.choose("service-provider");
            if (instance != null) {
                String url = "http://" + instance.getHost() + ":" + instance.getPort() + "/echo?message=" + message;
                logger.info("调用服务 URL: {}", url);
                return restTemplate.getForObject(url, String.class);
            } else {
                logger.error("未能找到服务实例：service-provider");
                return "Error: No service instance found";
            }
        } catch (Exception e) {
            logger.error("调用服务失败", e);
            return "Error: " + e.getMessage();
        }
    }
}

📝 说明：LoadBalancerClient 是 Spring Cloud 提供的通用负载均衡客户端，可以自动根据策略选择实例。

4.2.1.3 创建调用控制器

package com.example.controller;

import com.example.service.RestTemplateCallService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ConsumerController {
    @Autowired
    private RestTemplateCallService restTemplateCallService;

    @GetMapping("/call-with-lb")
    public String callProviderWithLoadBalancer(@RequestParam String message) {
        return restTemplateCallService.callProviderWithLoadBalancer(message);
    }
}

4.2.2 使用 OpenFeign 调用 (推荐方式)

OpenFeign 是 Spring Cloud 提供的一个声明式 HTTP 客户端，极大地简化了服务调用的代码编写。

4.2.2.1 添加 Feign 依赖

确保在 pom.xml 中包含 spring-cloud-starter-openfeign 依赖。

4.2.2.2 定义 Feign 客户端接口

package com.example.client;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(name = "service-provider", fallback = EchoServiceFallback.class)
public interface EchoServiceClient {
    @GetMapping("/echo")
    String echo(@RequestParam String message);
}

4.2.2.3 实现 Feign 降级处理 (可选但推荐)

package com.example.client;

import org.springframework.stereotype.Component;

@Component
public class EchoServiceFallback implements EchoServiceClient {
    @Override
    public String echo(String message) {
        return "Fallback: Service is currently unavailable.";
    }
}

4.2.2.4 使用 Feign 客户端

package com.example.service;

import com.example.client.EchoServiceClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class FeignCallService {
    @Autowired
    private EchoServiceClient echoServiceClient;

    public String callProvider(String message) {
        return echoServiceClient.echo(message);
    }
}

4.2.2.5 创建 Feign 调用控制器

package com.example.controller;

import com.example.service.FeignCallService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class FeignConsumerController {
    @Autowired
    private FeignCallService feignCallService;

    @GetMapping("/call-feign")
    public String callProvider(@RequestParam String message) {
        return feignCallService.callProvider(message);
    }
}

4.2.3 运行服务消费者

编译并运行 ServiceConsumerApplication 类。访问 http://localhost:8080/call-feign?message=Hello，你应该能看到来自服务提供者的响应。

五、配置管理实践

Spring Cloud Alibaba 的 Nacos 配置中心功能非常强大，可以实现配置的集中化管理和动态刷新。

5.1 Nacos 配置中心配置

5.1.1 application.yml 配置文件

spring:
  application:
    name: config-demo
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
      config:
        server-addr: localhost:8848
        file-extension: yaml
        group: DEFAULT_GROUP
management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics

5.1.2 创建配置文件

在 Nacos 控制台创建配置：

• Data ID: config-demo.yaml
• Group: DEFAULT_GROUP
• 配置内容：

demo:
  message: "Hello from Nacos Config!"
  count: 100
  enable-feature: true
timeout: 5000

5.1.3 加载配置到应用

5.1.3.1 使用 @Value 注解

package com.example.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class ConfigProperties {
    @Value("${demo.message:Default Message}")
    private String message;

    @Value("${demo.count:0}")
    private Integer count;

    // Getters ...
}

5.1.3.2 使用 @ConfigurationProperties 注解

package com.example.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "demo")
public class DemoConfigProperties {
    private String message;
    private Integer count;
    private Boolean enableFeature;

    // Getters and Setters ...
}

5.1.3.3 使用 @RefreshScope 实现动态刷新

package com.example.controller;

import com.example.config.ConfigProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.Map;

@RestController
@RefreshScope
public class ConfigController {
    @Autowired
    private ConfigProperties configProperties;

    @GetMapping("/config-info")
    public Map<String, Object> getConfigInfo() {
        Map<String, Object> info = new HashMap<>();
        info.put("demo.message", configProperties.getMessage());
        return info;
    }
}

5.1.4 验证配置加载

启动应用后，访问 /config-info 查看从 Nacos 加载的配置值。

5.1.5 动态刷新配置

修改 Nacos 控制台中的配置，再次访问接口即可看到更新后的值。

六、负载均衡与服务治理

6.1 负载均衡器选择

Spring Cloud Alibaba 默认集成了 Ribbon 和 Spring Cloud LoadBalancer。

6.1.1 Ribbon (已废弃，但仍可使用)

Ribbon 是 Netflix 开源的客户端负载均衡器，虽然已被官方弃用，但在某些场景下仍可使用。

service-provider:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule

6.1.2 Spring Cloud LoadBalancer (推荐)

Spring Cloud LoadBalancer 是新一代负载均衡器，性能更好。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

6.2 负载均衡实践

Feign 默认会集成 LoadBalancer，因此在 Feign 客户端中无需额外配置即可享受负载均衡。启动多个服务提供者实例，多次调用消费者接口，观察返回的实例 IP 和端口，可以验证负载均衡的效果。

七、服务健康检查与监控

7.1 健康检查机制

Nacos 通过心跳机制来监控服务实例的健康状态。

7.1.1 心跳配置

spring:
  cloud:
    nacos:
      discovery:
        heartbeat-interval: 5000
        heartbeat-timeout: 15000
        ephemeral: true

7.1.2 健康状态展示

在 Nacos 控制台的服务列表页面，可以清晰地看到每个服务实例的健康状态（UP/DOWN）。

7.2 Actuator 集成

7.2.1 添加 Actuator 依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

7.2.2 配置 Actuator

management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics
  endpoint:
    health:
      show-details: always

7.2.3 访问监控信息

访问 http://localhost:8080/actuator/health 查看健康状态。

八、服务治理与限流熔断 (Sentinel)

8.1 Sentinel 简介

Sentinel 是阿里巴巴开源的流量控制、熔断降级和系统保护组件，专为微服务设计。

8.2 整合 Sentinel

8.2.1 添加依赖

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

8.2.2 配置 Sentinel

spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080

8.2.3 使用 Sentinel 注解

package com.example.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SentinelController {
    @GetMapping("/sentinel-test")
    @SentinelResource(value = "sentinel-test", blockHandler = "handleBlock", fallback = "handleFallback")
    public String sentinelTest(@RequestParam String name) {
        if ("error".equals(name)) {
            throw new RuntimeException("模拟异常");
        }
        return "Hello " + name;
    }

    public String handleBlock(String name, BlockException ex) {
        return "Blocked by Sentinel: " + name;
    }

    public String handleFallback(String name, Throwable ex) {
        return "Fallback for " + name;
    }
}

8.2.4 访问 Sentinel 控制台

启动 Sentinel Dashboard 并进行流量控制规则配置。

九、部署与高可用方案

9.1 集群部署

9.1.1 Nacos 集群部署

Nacos 支持集群部署以保证高可用性。通常需要至少 3 个节点组成集群。

9.1.1.1 配置文件

修改 conf/application.properties：

nacos.cluster.members=192.168.1.100:8848,192.168.1.101:8848,192.168.1.102:8848

9.1.1.2 启动集群

在每个节点上启动 Nacos：sh startup.sh -m cluster

9.1.2 Spring Cloud 应用部署

应用可以部署在多台机器上，只需要确保 spring.cloud.nacos.discovery.server-addr 指向集群地址即可。

9.2 负载均衡与服务网关

在生产环境中，通常会配合 Spring Cloud Gateway 作为 API 网关。

spring:
  cloud:
    gateway:
      routes:
        - id: service-provider-route
          uri: lb://service-provider
          predicates:
            - Path=/provider/**

9.3 安全加固

9.3.1 Nacos 认证

启用 Nacos 的认证功能，在 conf/application.properties 中添加：

nacos.core.auth.enabled=true

9.3.2 应用配置认证

在应用配置中指定认证信息：

spring:
  cloud:
    nacos:
      discovery:
        username: nacos
        password: nacos

十、常见问题与排查指南

10.1 服务注册失败

• 常见原因：Nacos Server 地址配置错误、网络不通、服务名冲突。
• 排查步骤：检查 Nacos 控制台、查看应用日志、测试网络连通性。

10.2 服务发现失败

• 常见原因：服务名不一致、服务未注册、网络问题。
• 排查步骤：确认服务名、检查实例状态、查看消费者日志。

10.3 配置加载失败

• 常见原因：配置中心地址错误、Data ID 或 Group 错误、命名空间问题。
• 排查步骤：查看 Nacos 控制台、检查应用日志、验证配置格式。

10.4 心跳超时

• 常见原因：网络延迟高、服务实例负载过高、配置不合理。
• 解决方案：调整心跳间隔和超时时间、优化网络、监控资源。

十一、总结与展望

本文全面介绍了如何利用 Spring Cloud Alibaba 构建一个基于 Nacos 的服务发现体系。从基础的环境搭建、服务注册与发现、配置管理，到负载均衡、服务治理、高可用部署等关键环节，我们都提供了详细的配置说明和 Java 代码示例。

通过整合 Nacos 的两大核心功能——服务注册与发现以及配置管理，我们构建了一个动态、可扩展、易于维护的微服务架构。同时，结合 Spring Cloud Gateway 和 Sentinel 等组件，可以进一步提升系统的整体性能、可靠性和安全性。

随着微服务架构的不断发展，Nacos 作为核心组件，其功能也在持续增强。未来，我们可以期待 Nacos 在智能化、自动化方面带来更多的创新，为开发者提供更加便捷的微服务开发体验。