【cloud-alibaba&Nacos】服务发现和负载均衡

绝地灬酷狼 2024-03-27 16:14 91阅读 0赞

#### 文章目录 ####

*  前言
 *  一、nacos介绍
 *  二、通过代码变迁理解服务发现和负载
 *   *  1.最原始方式，服务调用的本质：ip:port
     *  2.引入注册中心对服务进行管理
     *   *   *   *  1.引入nacos依赖
                 *  2.配置文件中声明注册中心的地址
                 *  3.启动类上开启注册
                 *  4.服务调用
     *  3.自己实现简单的负载策略
     *  4.Ribbon实现负载均衡
     *  5.Fegin实现负载均衡
     *   *   *   *  1.引入fegin依赖
                 *  2.启动类上开启
                 *  3.声明客户端
                 *  4.引入定义好的客户端，进行调用
 *  总结

--------------------

## 前言 ##

涉及主要配置：  
spring.application.name（spring应用名）  
server.servlet.context-path（服务上下文，请求路径头）

以三个常见的服务进行举例，用户服务、商品服务、订单服务，端口号分别为：  
用户服务：  
`server: port: 8060`  
商品服务：  
`server: port: 8070`  
订单服务：  
`server: port: 8080`

--------------------

## 一、nacos介绍 ##

[nacos官网][nacos]（official site: nacos.io）  
Dynamic **Na**ming and **Co**nfiguration **S**ervice的首字母简称，一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。

服务（Service）是 Nacos 世界的一等公民。Nacos 支持几乎所有主流类型的“服务”的发现、配置和管理：  
Kubernetes Service、gRPC & Dubbo RPC Service、Spring Cloud RESTful Service。

主要特性：

*  服务发现和**服务健康监测**
 *  **动态服务配置**
 *  **动态DNS**
 *  **服务及其元数据管理**  
    ![服务注册和服务发现][df746545c536454e9984bcdbb1c0c796.png]

## 二、通过代码变迁理解服务发现和负载 ##

### 1.最原始方式，服务调用的本质：ip:port ###

调用者拼接需要访问进程的ip地址和端口进行请求：

User user = restTemplate.getForObject("http://localhost:8060/user/get/"
                    + orderParams.getUserId(), User.class);

### 2.引入注册中心对服务进行管理 ###

###### 1.引入nacos依赖 ######

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

###### 2.配置文件中声明注册中心的地址 ######

spring:
        cloud:
          nacos:
            discovery:
              server-addr: 192.168.1.178:8848

###### 3.启动类上开启注册 ######

@EnableDiscoveryClient

###### 4.服务调用 ######

@Autowired
        DiscoveryClient discoveryClient;
        
    	// 参数为application.yaml文件中spring: application: name: server-user
        private String getServiceUrl(String serviceName) {
        
            ServiceInstance serviceInstance = discoveryClient.getInstances(serviceName).get(0);
            return serviceInstance.getHost() + ":" + serviceInstance.getPort();
        }
        // 拼接ip地址和端口
        User user = restTemplate.getForObject("http://" + getServiceUrl(userService) + "/user/get/"
                + orderParams.getUserId(), User.class);

### 3.自己实现简单的负载策略 ###

private String getServiceUrl(String serviceName) {
        
            List<ServiceInstance> instances = discoveryClient.getInstances(serviceName);
            ServiceInstance serviceInstance = instances.get(new Random().nextInt(instances.size()));
            // …………后续逻辑省略
        }

### 4.Ribbon实现负载均衡 ###

Ribbon是SpringCloud提供的一个能够**实现负载均衡的组件**，使用Ribbon能够轻松实现微服务之间调用的负载均衡。

@LoadBalanced
        @Bean
        public RestTemplate restTemplate() {
        
            return new RestTemplate();
        }
        // 使用restTemplate
        private String userService = "server-user";
        User user = restTemplate.getForObject("http://" + userService + "/user/get/" + 
        			orderParams.getUserId(), User.class);

使用restTemplate：

private String userService = "server-user";
        User user = restTemplate.getForObject("http://" + userService + "/user/get/" + 
        			orderParams.getUserId(), User.class);

### 5.Fegin实现负载均衡 ###

**Fegin是SpringCloud提供的一个HTTP客户端**，但只是一个**声明式的伪客户端**，它能够使远程调用和本地调用一样简单。阿里巴巴开源的Nacos能够兼容Ribbon，而Fegin又集成了Ribbon，所以，使用Fegin也能够实现负载均衡。

###### 1.引入fegin依赖 ######

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

###### 2.启动类上开启 ######

@EnableFeignClients

###### 3.声明客户端 ######

// 这里填写配置文件中的应用名：spring.application.name
    @FeignClient(value= "server-user",fallback = UserServiceFallBack.class) 
    public interface UserService {
        
        /**
         * 这里填写 server.servlet.context-path
         */
        @GetMapping(value = "/user/get/{uid}")
        User getUser(@PathVariable("uid") Long uid);
    }

###### 4.引入定义好的客户端，进行调用 ######

@Autowired
        UserService userService;
        // 远程调用
        User user = userService.getUser(orderParams.getUserId());

--------------------

## 总结 ##

通过以上代码演化过程，理解微服务治理、服务注册、服务发现、负载均衡等基本逻辑。

[nacos]: https://nacos.io/zh-cn/docs/v2/quickstart/quick-start.html
[df746545c536454e9984bcdbb1c0c796.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/7a0f1eeecda148699225282b670b8397.png