将Nacos注册到springboot使用以及Feign实现服务调用

﹏ヽ暗。殇╰゛Y 2024-05-23 18:57 63阅读 0赞

![168c1abc67f4402ebfc99ff077a3e4da.gif][]

> 哈喽~大家好，这篇来看看将Nacos注册到springboot使用以及Feign实现服务调用。
> 
> ?个人主页：[个人主页][Link 1]
> 
> ? 系列专栏：[【微服务】][Link 2]
> 
> ?推荐专栏： [JavaEE框架 ][JavaEE_]

**目录**

一、前前言

1、什么是服务治理

2、服务发现

3、服务配置

4、服务健康检测

二、前言

1、安装 nacos

2、启动 nacos

3、将服务注册到nacos

三、基于Ribbon实现负载均衡

1、负载均衡

2、注解扩

3、负载策略

四、服务分级存储模型

1、权重配置

2、环境隔离

五、Nacos与Eureka的区别

六、基于Feign实现服务调用

1、什么是Feign

2、实现负载均衡

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

## 一、前前言 ##

### 1、什么是服务治理 ###

> 服务治理是微服务架构中最核心最基本的模块。用于实现各个微服务的**自动化注册与发现**。
> 
> **服务注册：**在服务治理框架中，都会构建一个注册中心，每个服务单元向注册中心登记自己提供服务的详细信息。并在注册中心形成一张服务的清单，服务注册中心需要以心跳的方式去监测清单中的服务是否可用，如果不可用，需要在服务清单中剔除不可用的服务。
> 
> **服务发现：**服务调用方向服务注册中心咨询服务，并获取所有服务的实例清单，实现对具体服务实例的访问。

![e79a33fec2a540d08267a70f84319def.png][]

> 通过上面的调用图会发现，除了微服务，还有一个组件是**服务注册中心**，它是微服务架构非常重要的一个组件，在微服务架构里主要起到了协调者的一个作用。注册中心一般包含如下几个功能：

### 2、服务发现 ###

> **服务注册：**保存服务提供者和服务调用者的信息
> 
> **服务订阅：**服务调用者订阅服务提供者的信息，注册中心向订阅者推送提供者的信息

### 3、服务配置 ###

> 配置订阅：服务提供者和服务调用者订阅微服务相关的配置，配置下发：主动将配置推送给服务提供者和服务调用者

### 4、**服务健康检测** ###

> 检测服务提供者的健康情况，如果发现异常，执行服务剔除
> 
> Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。
> 
> 从上面的介绍就可以看出，**nacos**的作用就是一个**注册中心**，用来管理注册上来的各个微服务。

## 二、前言 ##

> 国内公司一般都推崇阿里巴巴的技术，比如注册中心，SpringCloudAlibaba也推出了一个名为Nacos的注册中心。
> 
> Nacos是阿里巴巴的产品，现在是SpringCloud中的一个组件。相比前文介绍的Eureka功能更加丰富，在国内受欢迎程度较高。

### 1、安装 nacos ###

下载地址

GitHub主页：[GitHub - alibaba/nacos: an easy-to-use dynamic service discovery, configuration and service management platform for building cloud native applications.][GitHub - alibaba_nacos_ an easy-to-use dynamic service discovery_ configuration and service management platform for building cloud native applications.]

GitHub的Release下载页：[Releases · alibaba/nacos · GitHub][Releases _ alibaba_nacos _ GitHub]

下载后直接解压（中文路径）

**注：**Nacos的默认端口是8848，如果你电脑上的其它进程占用了8848端口，请先尝试关闭该进程。

### 2、启动 nacos ###

到安装的bin目录，打开cmd，输入指令

startup.cmd -m standalone

看到这个，启动成功

![95522fd381ee4e0fb51f80fb2546d80a.png][]

直接访问地址 [http://172.168.1.130:8848/nacos/index.html][http_172.168.1.130_8848_nacos_index.html]

账号与密码默认nacos

![0e6bfa4ab9f54847aab6a387e40c38b9.png][]

安装完成。

### 3、将服务注册到nacos ###

> Nacos是SpringCloudAlibaba的组件，而SpringCloudAlibaba也遵循SpringCloud中定义的服务注册、服务发现规范。因此使用Nacos和使用Eureka对于微服务来说，并没有太大区别。
> 
> 主要差异在于：依赖不同、服务地址不同
> 
> 在cloud-demo父工程的pom文件中的`<dependencies>`中引入SpringCloudAlibaba的依赖：

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-dependencies</artifactId>
        <version>2.2.6.RELEASE</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>

然后在user-service和order-service中的pom文件中引入nacos-discovery依赖：

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

**注意**：不要忘了注释掉eureka的依赖。

在主类上添加**@EnableDiscoveryClient**注解

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients // 开启 feign
    @EntityScan("com.example")
    public class ShopOrderApplication {
    
       public static void main(String[] args) {
          SpringApplication.run(ShopOrderApplication.class);
       }
    
       // RestTemplate是Spring提供的用于访问Rest服务的客户端，RestTemplate
       // 提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
       @Bean
       @LoadBalanced
       public RestTemplate restTemplate() {
          return new RestTemplate();
       }
    
    }

在user-service和order-service的application.yml中添加nacos地址：

spring:
      cloud:
        nacos:
          server-addr: localhost:8848

重启微服务后，登录nacos管理页面，可以看到微服务信息：

![155f0274c3a74ef18befdcdac5c11c08.png][]

## 三、基于Ribbon实现负载均衡 ##

### 1、负载均衡 ###

Ribbon是Spring Cloud的一个组件， 它可以让我们使用一个注解就能轻松的搞定负载均衡

第1步：在RestTemplate 的生成方法上添加@LoadBalanced注解

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

@RestController
    @Slf4j
    public class OrderController {
    
       @Autowired
       private RestTemplate restTemplate;
    
       @Autowired
       private OrderService orderService;
    
       @Autowired
       private DiscoveryClient discoveryClient;
    
       //下单
       @RequestMapping("/order/prod/{pid}")
       public Order order(@PathVariable("pid") Integer pid) {
          log.info("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息", pid);
    
    //      //调用商品微服务,查询商品信息
    //      Product product = restTemplate.getForObject( "http://localhost:8081/product/" + pid, Product.class);
          //从nacos中获取服务地址
    //    ServiceInstance serviceInstance = discoveryClient.getInstances("service-product").get(0);
    //    String url = serviceInstance.getHost() + ":" + serviceInstance.getPort();
    //    log.info(">>从nacos中获取到的微服务地址为:" + url);
    //
    //        //通过restTemplate调用商品微服务
    //    Product product = restTemplate.getForObject(
    //          "http://" + url + "/product/" + pid, Product.class);
    //    log.info(">>商品信息,查询结果:" + JSON.toJSONString(product));
    //    //自定义规则实现随机挑选服务
    //    List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
    //    int index = new Random().nextInt(instances.size());
    //    ServiceInstance serviceInstance = instances.get(index);
    //
    //    String url = serviceInstance.getHost() + ":" + serviceInstance.getPort();
    //    log.info(">>从nacos中获取到的微服务地址为:" + url);
    //
    //        //通过restTemplate调用商品微服务
    //    Product product = restTemplate.getForObject("http://" + url + "/product/" + pid, Product.class);
          log.info(">>客户下单，这时候要调用商品微服务查询商品信息");
          //直接使用微服务名字， 从nacos中获取服务地址
          String url = "service-product";
    
            //通过restTemplate调用商品微服务
          Product product = restTemplate.getForObject("http://" + url + "/product/" + pid, Product.class);
    
          log.info("查询到{}号商品的信息,内容是:{}", pid, JSON.toJSONString(product));
    
          //下单(创建订单)
          Order order = new Order();
          order.setUid(1);
          order.setUsername("测试用户");
          order.setPid(pid);
          order.setPname(product.getPname());
          order.setPprice(product.getPprice());
          order.setNumber(1);
    
          orderService.createOrder(order);
    
          log.info("创建订单成功,订单信息为{}", JSON.toJSONString(order));
          ;
          return order;
       }
    }

### 2、注解扩 ###

//@RestController
    // @RestController 是@controller和@ResponseBody 的结合
    
    // @Controller 将当前修饰的类注入SpringBoot IOC容器，使得从该类所在的项目跑起来的过程中，这个类就被实例化。
    // @ResponseBody 它的作用简短截说就是指该类中所有的API接口返回的数据，甭管你对应的方法返回Map或是其他Object，它会以Json字符串的形式返回给客户端
    
    
    // @Slf4j是用作日志输出的，一般会在项目每个类的开头加入该注解，如果不写下面这段代码，并且想用log
    // private final Logger logger = LoggerFactory.getLogger(当前类名.class);
    // 添加了该注释之后，就可以在代码中直接饮用log.info( ) 打印日志了

Ribbon支持的负载均衡策略

Ribbon内置了多种负载均衡策略,内部负载均衡的顶级接口

### 3、负载策略 ###

com.netflix.loadbalancer.IRule , 具体的负载策略如下图所示

<table> 
 <thead> 
  <tr> 
   <th><strong>策略名</strong></th> 
   <th><strong>策略描述</strong></th> 
   <th><strong>实现说明</strong></th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>BestAvailableRule</td> 
   <td>选择一个最小的并发请求的server</td> 
   <td>逐个考察Server，如果Server被tripped了，则忽略，在选择其中ActiveRequestsCount最小的server</td> 
  </tr> 
  <tr> 
   <td>AvailabilityFilteringRule</td> 
   <td>过滤掉那些因为一直连接失败的被标记为circuit tripped的后端server，并过滤掉那些高并发的的后端server（active connections 超过配置的阈值）</td> 
   <td>使用一个AvailabilityPredicate来包含过滤server的逻辑，其实就就是检查status里记录的各个server的运行状态</td> 
  </tr> 
  <tr> 
   <td>WeightedResponseTimeRule</td> 
   <td>根据响应时间分配一个weight，响应时间越长，weight越小，被选中的可能性越低。</td> 
   <td>一个后台线程定期的从status里面读取评价响应时间，为每个server计算一个weight。Weight的计算也比较简单responsetime 减去每个server自己平均的responsetime是server的权重。当刚开始运行，没有形成statas 时，使用roubine策略选择server。</td> 
  </tr> 
  <tr> 
   <td>RetryRule</td> 
   <td>对选定的负载均衡策略机上重试机制。</td> 
   <td>在一个配置时间段内当选择server不成功，则一直尝试使用subRule的方式选择一个可用的server</td> 
  </tr> 
  <tr> 
   <td>RoundRobinRule</td> 
   <td>轮询方式轮询选择 server</td> 
   <td>轮询index，选择index对应位置的 server</td> 
  </tr> 
  <tr> 
   <td>RandomRule</td> 
   <td>随机选择一个server</td> 
   <td>在index上随机，选择index对应位置的server</td> 
  </tr> 
  <tr> 
   <td>ZoneAvoidanceRule</td> 
   <td>复合判断server所在区域的性能和server 的可用性选择server</td> 
   <td>使用ZoneAvoidancePredicate和AvailabilityPredicate来判断是否选择某个server，前一个判断判定一个zone的运行性能是否可用，剔除不可用的zone（的所有server）， AvailabilityPredicate用于过滤掉连接数过多的Server。</td> 
  </tr> 
 </tbody> 
</table>

> 我们可以通过修改配置来调整Ribbon的负载均衡策略，具体代码如下
> 
> service-product: \# 调用的提供者的名称 ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

## 四、服务分级存储模型 ##

> 一个**服务**可以有多个**实例**，例如我们的user-service，可以有:
> 
>  *  127.0.0.1:8081
>  *  127.0.0.1:8082
>  *  127.0.0.1:8083
> 
> 假如这些实例分布于全国各地的不同机房，例如：
> 
>  *  127.0.0.1:8081，在上海机房
>  *  127.0.0.1:8082，在上海机房
>  *  127.0.0.1:8083，在杭州机房
> 
> Nacos就将同一机房内的实例 划分为一个**集群**。
> 
> 也就是说，user-service是服务，一个服务可以包含多个集群，如杭州、上海，每个集群下可以有多个实例，形成分级模型，如图：

![35773f0ee0e146499e3a9359fa3e4eb0.png][]

微服务互相访问时，应该尽可能访问同集群实例，因为本地访问速度更快。当本集群内不可用时，才访问其它集群。杭州机房内的order-service应该优先访问同机房的user-service。

**给user-service配置集群**

修改user-service的application.yml文件，添加集群配置：

spring:
      cloud:
        nacos:
          server-addr: localhost:8848
          discovery:
            cluster-name: SH # 集群名称

**启动UserApplication，查看nacos控制台**

![1d2cc66295db4f3fadd29d0e7abb1ee4.png][]

**修改负载均衡规则**

修改order-service的application.yml文件，修改负载均衡规则：

xuserservice:  
        ribbon:    
            NFLoadBalancerRuleClassName: com.alibaba.cloud.nacos.ribbon.NacosRule # 负载均衡规则

### 1、权重配置 ###

实际部署中会出现这样的场景：

> 服务器设备性能有差异，部分实例所在机器性能较好，另一些较差，我们希望性能好的机器承担更多的用户请求。
> 
> 但默认情况下NacosRule是同集群内随机挑选，不会考虑机器的性能问题。
> 
> 因此，Nacos提供了权重配置来控制访问频率，权重越大则访问频率越高。
> 
> 在nacos控制台，找到user-service的实例列表，点击编辑，即可修改权重：

![edf144a145a843e58fa958c4d74d9c5c.png][]

**注意**：如果权重修改为0，则该实例永远不会被访问

### 2、环境隔离 ###

> Nacos提供了namespace来实现环境隔离功能。
> 
>  *  nacos中可以有多个namespace
>  *  namespace下可以有group、service等
>  *  不同namespace之间相互隔离，例如不同namespace的服务互相不可见

![dcb216cbd03e40da8c301fdb2875f964.png][]

在命名空间里面新建命名空间

![4beef91e51a7404b981388f08563e5ce.png][]

**点击确定**

给微服务配置namespace只能通过修改配置来实现。

例如，修改order-service的application.yml文件：

spring:
      cloud:
        nacos:
          server-addr: localhost:8848
          discovery:
            cluster-name: HZ
            namespace: **** # 命名空间，填ID

重启服务后，访问控制台，可以看到下面的结果：

![85e557b30b84419084514322b1c103fa.png][]

此时访问order-service，因为namespace不同，会导致找不到userservice，控制台会报错，这形成了环境隔离

## 五、Nacos与Eureka的区别 ##

> Nacos的服务实例分为两种类型：
> 
>  *  临时实例：如果实例宕机超过一定时间，会从服务列表剔除，默认的类型。
>  *  非临时实例：如果实例宕机，不会从服务列表剔除，也可以叫永久实例。
> 
>  *  Nacos与eureka的共同点
>     
>      *  都支持服务注册和服务拉取
>      *  都支持服务提供者心跳方式做健康检测
>  *  Nacos与Eureka的区别
>     
>      *  Nacos支持服务端主动检测提供者状态：临时实例采用心跳模式，非临时实例采用主动检测模式
>      *  临时实例心跳不正常会被剔除，非临时实例则不会被剔除
>      *  Nacos支持服务列表变更的消息推送模式，服务列表更新更及时
>      *  Nacos集群默认采用AP方式，当集群中存在非临时实例时，采用CP模式；Eureka采用AP方式

## 六、基于Feign实现服务调用 ##

### 1、什么是Feign ###

> Feign是Spring Cloud提供的一个声明式的伪Http客户端， 它使得调用远程服务就像调用本地服务一样简单， 只需要创建一个接口并添加一个注解即可。
> 
> Nacos很好的兼容了Feign， Feign默认集成了 Ribbon， 所以在Nacos下使用Fegin默认就实现了负载均衡的效果。

### 2、实现负载均衡 ###

**1、加入Fegin的依赖**

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

**2、在主类上添加Fegin的注解 @EnableFeignClients //开启Fegin**

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients//开启Fegin 
    @EntityScan("com.example")
    public class ShopOrderApplication {
    3、order工程里面创建一个service， 并使用Fegin实现微服务调用
    
    @FeignClient("service-product")//声明调用的提供者的name，在yam文件里面
    public interface ProductService {
    
        //根据pid查询商品信息
        @GetMapping(value = "/product/{pid}")
        Product findByPid(@PathVariable("pid") Integer pid);
    }

**4、修改controller代码，并启动验证**

package com.example.shoporder.controller;
    
    import com.alibaba.fastjson.JSON;
    import com.example.shopcommon.domain.Order;
    import com.example.shopcommon.domain.Product;
    import com.example.shoporder.service.OrderService;
    import com.example.shoporder.service.ProductService;
    import lombok.extern.slf4j.Slf4j;
    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.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.List;
    import java.util.Random;
    
    @RestController
    @Slf4j
    public class OrderController {
    
       @Autowired
       private RestTemplate restTemplate;
    
       @Autowired
       private OrderService orderService;
    
       @Autowired
       private DiscoveryClient discoveryClient;
    
    
       @Autowired
       private ProductService productService;
    
       //下单
       @RequestMapping("/order/prod/{pid}")
       public Order order(@PathVariable("pid") Integer pid) {
          log.info("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息", pid);
    
          log.info(">>客户下单，这时候要调用商品微服务查询商品信息");
          
          //通过fegin调用商品微服务
          Product product = productService.findByPid(pid);
    
          log.info("查询到{}号商品的信息,内容是:{}", pid, JSON.toJSONString(product));
    
          //下单(创建订单)
          Order order = new Order();
          order.setUid(1);
          order.setUsername("测试用户");
          order.setPid(pid);
          order.setPname(product.getPname());
          order.setPprice(product.getPprice());
          order.setNumber(1);
    
          orderService.createOrder(order);
    
          log.info("创建订单成功,订单信息为{}", JSON.toJSONString(order));
          
          return order;
       }
    }

> **不积跬步无以至千里，趁年轻，使劲拼，给未来的自己一个交代！向着明天更好的自己前进吧！**
> 
> ![d5358fcd619443fe98143f2fd5fef762.gif][]

[168c1abc67f4402ebfc99ff077a3e4da.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/d34a785e8a8e4b7fab31cb56dd652775.gif
[Link 1]: https://blog.csdn.net/aasd23?spm=1000.2115.3001.5343
[Link 2]: https://blog.csdn.net/aasd23/category_11867778.html?spm=1001.2014.3001.5482
[JavaEE_]: https://blog.csdn.net/aasd23/category_12005462.html?spm=1001.2014.3001.5482
[e79a33fec2a540d08267a70f84319def.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/4b8d8619b87a46f9b868fafce194c15f.png
[GitHub - alibaba_nacos_ an easy-to-use dynamic service discovery_ configuration and service management platform for building cloud native applications.]: https://github.com/alibaba/nacos
[Releases _ alibaba_nacos _ GitHub]: https://github.com/alibaba/nacos/releases
[95522fd381ee4e0fb51f80fb2546d80a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/cbba57e7d3d14d388d6276b5b46aa357.png
[http_172.168.1.130_8848_nacos_index.html]: http://172.168.1.130:8848/nacos/index.html
[0e6bfa4ab9f54847aab6a387e40c38b9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/4f837c1e8dfa455cba27e404c5b84ac9.png
[155f0274c3a74ef18befdcdac5c11c08.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/635c2866d42d43b1925a453f4382ef26.png
[35773f0ee0e146499e3a9359fa3e4eb0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/99ee188003d247d789a6e33054f319dc.png
[1d2cc66295db4f3fadd29d0e7abb1ee4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/03a6d9f3fa05430f916ef5e2e0fd1c20.png
[edf144a145a843e58fa958c4d74d9c5c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/3757dff3735548a1959152141dd51dd2.png
[dcb216cbd03e40da8c301fdb2875f964.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/bcacbc9ecb5a4b6e9c97d43a27d50c7b.png
[4beef91e51a7404b981388f08563e5ce.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/888b24dae88042218707c1a8c7fbb0b5.png
[85e557b30b84419084514322b1c103fa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/02bea59b782340ea9b23390c1b70ee0f.png
[d5358fcd619443fe98143f2fd5fef762.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/23/8787c68ae0ba4c5494f6d96b1bad58cc.gif