• Nacos Discovery--服务治理

    目录

    服务治理介绍

    先来思考一个问题

    什么是服务治理  

    常见的注册中心

    Nacos简介

    nacos实战入门

    搭建nacos环境

    第1步: 安装nacos

    第2步: 启动nacos  

    第3步: 访问nacos

    Nacos的微服务注册

    将商品微服务注册到nacos

    1 在shop-common模块的pom.xml中添加nacos的依赖

     2 在主类上添加@EnableDiscoveryClient注解

    3 在application.yml中添加nacos服务的地址  

    4 启动服务， 观察nacos的控制面板中是否有注册上来的商品微服务

    实现服务调用的负载均衡 

     什么是负载均衡

    第一种方式：DiscoveryClient实现负载均衡

    也能使用8081访问​编辑 修改shop-order 的代码，实现负载均衡

     测试负载均衡

    第二种方式：Ribbon负载均衡实现

    Ribbon支持的负载均衡策略

     第三种方式：基于Feign实现服务调用

    什么是Feign

     Feign的使用

              Feign传参

    服务治理介绍

    先来思考一个问题

    通过上一章的操作，我们已经可以实现微服务之间的调用。但是我们把服务提供者的网络地址 （ip，端口）等硬编码到了代码中，这种做法存在许多问题：

    • 一旦服务提供者地址变化，就需要手工修改代码

    • 一旦是多个服务提供者，无法实现负载均衡功能

    • 一旦服务变得越来越多，人工维护调用关系困难

    那么应该怎么解决呢， 这时候就需要通过注册中心动态的实现服务治理。 

    什么是服务治理  

    服务治理是微服务架构中最核心最基本的模块。用于实现各个微服务的自动化注册与发现。

    • 服务注册：在服务治理框架中，都会构建一个注册中心，每个服务单元向注册中心登记自己提供服 务的详细信息。并在注册中心形成一张服务的清单，服务注册中心需要以心跳的方式去监测清单中 的服务是否可用，如果不可用，需要在服务清单中剔除不可用的服务。

    • 服务发现：服务调用方向服务注册中心咨询服务，并获取所有服务的实例清单，实现对具体服务实 例的访问。

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

    1. 服务发现：

      • 服务注册：保存服务提供者和服务调用者的信息

      • 服务订阅(发现)：服务调用者订阅服务提供者的信息，注册中心向订阅者推送提供者的信息

    2. 服务配置：

      • 配置订阅：服务提供者和服务调用者订阅微服务相关的配置

      • 配置下发：主动将配置推送给服务提供者和服务调用者

    3. 服务健康检测

      • 检测服务提供者的健康情况，如果发现异常，执行服务剔除

    常见的注册中心

    • Zookeeper zookeeper是一个分布式服务框架，是Apache Hadoop 的一个子项目，它主要是用来解决分布式 应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用 配置项的管理等。

    • Eureka Eureka是Springcloud Netflix中的重要组件，主要作用就是做服务注册和发现。但是现在已经闭 源

    • Consul Consul是基于GO语言开发的开源工具，主要面向分布式，服务化的系统提供服务注册、服务发现 和配置管理的功能。Consul的功能都很实用，其中包括：服务注册/发现、健康检查、Key/Value 存储、多数据中心和分布式一致性保证等特性。Consul本身只是一个二进制的可执行文件，所以 安装和部署都非常简单，只需要从官网下载后，在执行对应的启动脚本即可。

    • Nacos Nacos是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。它是 Spring Cloud Alibaba 组件之一，负责服务注册发现和服务配置，可以这样认为nacos=eureka+config。  

    Nacos简介

    Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速 实现动态服务发现、服务配置、服务元数据及流量管理。 从上面的介绍就可以看出，nacos的作用就是一个注册中心，用来管理注册上来的各个微服务。

    nacos实战入门

    接下来，我们就在现有的环境中加入nacos，并将我们的两个微服务注册上去。(上篇文章)

    搭建nacos环境

    第1步: 安装nacos

    下载地址: https://github.com/alibaba/nacos/releases
    下载zip格式的安装包，然后进行解压缩操作

    第2步: 启动nacos  

    解压之后进入bin目录，修改文件startup.cmd

    #切换目录
    cd nacos/bin


    记事本也是一样的。

    1. 将 set MODE="cluster"
    2. 改成 set MODE="standalone"

     将集群方式启动更为单节点方式启动

    #命令启动
    startup.cmd -m standalone

    这就代表着启动成功了 

    第3步: 访问nacos

    打开浏览器输入http://localhost:8848/nacos，即可访问服务， 默认密码是nacos/nacos

     ok,到这里我们就将Nacos的环境搭建起来了。

    Nacos的微服务注册

    将商品微服务注册到nacos

    接下来开始修改shop-product 模块的代码， 将其注册到nacos服务上

    1 在shop-common模块的pom.xml中添加nacos的依赖

    2. <dependency>
    3. 	<groupId>com.alibaba.cloudgroupId>
    4. 	<artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    5. dependency>

     注意在父模块中是否导入了alibaba ！！！

    1.             
    2.             <dependency>
    3.                 <groupId>org.springframework.cloudgroupId>
    4.                 <artifactId>spring-cloud-dependenciesartifactId>
    5.                 <version>${spring-cloud.version}version>
    6.                 <type>pomtype>
    7.                 <scope>importscope>
    8.             dependency>
    9.  
    10.             
    11.             <dependency>
    12.                 <groupId>com.alibaba.cloudgroupId>
    13.                 <artifactId>spring-cloud-alibaba-dependenciesartifactId>
    14.                 <version>${spring-cloud-alibaba.version}version>
    15.                 <type>pomtype>
    16.                 <scope>importscope>
    17.             dependency>

     2 在主类上添加@EnableDiscoveryClient注解

    其他几个微服务也需要添加

    3 在application.yml中添加nacos服务的地址  

    1. spring:
    2.   cloud:
    3.     nacos:
    4.       discovery:
    5.         server-addr: localhost:8848

    其他几个微服务也需要添加

    4 启动服务， 观察nacos的控制面板中是否有注册上来的商品微服务

     如果挂掉一个服务

     Nacos就会少一个

    实现服务调用的负载均衡 

     什么是负载均衡

    通俗的讲， 负载均衡就是将负载（工作任务，访问请求）进行分摊到多个操作单元（服务器,组件）上 进行执行。 根据负载均衡发生位置的不同,一般分为服务端负载均衡和客户端负载均衡。 服务端负载均衡指的是发生在服务提供者一方,比如常见的nginx负载均衡 而客户端负载均衡指的是发生在服务请求的一方，也就是在发送请求之前已经选好了由哪个实例处理请 求。

    我们在微服务调用关系中一般会选择客户端负载均衡，也就是在服务调用的一方来决定服务由哪个提供 者执行。

    第一种方式：DiscoveryClient实现负载均衡

    这种是通过手动代码来操作的

    复制一个

     将此服务运行起来

    可以看到，多了个节点

    也能使用8081访问 修改shop-order 的代码，实现负载均衡

    1. package com.oyang.shoporder.controller;
    2.  
    3. import com.oyang.model.Order;
    4. import com.oyang.model.Product;
    5. import com.oyang.model.User;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.cloud.client.ServiceInstance;
    8. import org.springframework.cloud.client.discovery.DiscoveryClient;
    9. import org.springframework.web.bind.annotation.PathVariable;
    10. import org.springframework.web.bind.annotation.RequestMapping;
    11. import org.springframework.web.bind.annotation.RestController;
    12. import org.springframework.web.client.RestTemplate;
    13.  
    14. import java.util.List;
    15. import java.util.Random;
    16.  
    17. /**
    18.  * @author oyang
    19.  * @site https://blog.csdn.net
    20.  * @qq 1828190940
    21.  * @create  2022-11-24 16:07
    22.  */
    23. @RestController
    24. @RequestMapping("/order")
    25. public class OrderController {
    26.  
    27.     @Autowired
    28.     private RestTemplate restTemplate;
    29.     @Autowired
    30.     private DiscoveryClient discoveryClient;
    31.  
    32.  
    33.  
    34.     @RequestMapping("/get/{uid}/{pid}")
    35.     public Order get(@PathVariable("uid") Integer uid,@PathVariable("pid") Integer pid){
    36.         //可以通过服务名,拿到多个节点的信息
    37.         List instances = discoveryClient.getInstances("shop-product");//返回一个实例数
    38.         //想要实现负载均衡，就得随机调用这几个实例
    39.         int index = new Random().nextInt(instances.size());//随机产生整数，通过随机的去调用
    40.         ServiceInstance serviceInstance = instances.get(index);
    41.         String url = serviceInstance.getHost() + ":" +
    42.                 serviceInstance.getPort();
    43.         /**
    44.          * 要在订单微服务中调用 用户微服务、商品微服务--也就意味着跨项目调用
    45.          * httpClients
    46.          */
    47.         //得到用户对象
    48.         User user = restTemplate.getForObject("http://localhost:8070/user/get/" + uid, User.class);
    49.         //得到商品对象
    50.         Product product = restTemplate.getForObject("http://"+url+"/product/get/" + pid, Product.class);
    51.         Order order = new Order();
    52.         order.setUsername(user.getUsername());
    53.         order.setUid(user.getUid());
    54.         order.setPprice(product.getPprice());
    55.         order.setPname(product.getPname());
    56.         order.setPid(product.getPid());
    57.         order.setOid(System.currentTimeMillis());//随机生成id
    58.         order.setNumber(product.getStock());
    59.         return order;
    60.     }
    61. }

     为了更加了解调用的是哪个服务，再对其他的类加入打印语句

     测试负载均衡

     刷新几次

    8081被调用

     8080也被调用了

    可以发现，这种负载均衡不咋好 ，还需要写一些代码，虽然是固定的，但也不好，让我们来见见第二种负载均衡吧。

    第二种方式：Ribbon负载均衡实现

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

     在启动类添加ribbon负载均衡注解

    通过服务名配置IP地址

     测试一下，在网页多刷新几次

     8081:

     8080：

     第二种方式就加了一个注解，改了一下URL中localhost就可以了

    注意：使用第二种方式之后，设定的localhost：80xx的IP地址就不能使用了，会报错

    Ribbon支持的负载均衡策略

    Ribbon内置了多种负载均衡策略,内部负载均衡的顶级接口为 com.netflix.loadbalancer.IRule , 具体的负载策略如下所示:

    规则名策略描述实备注
    RoundRobinRule线性轮询轮询index，选择index对应位置的server
    WeightedResponseTimeRule根据rt分配一个权重值，rt时间越长，weight越小，被选中的可能性就越低使用一个后台线程默认每30s重新计算一次权重值
    BestAvailableRule选择一个活跃请求数最小的Server忽略已经被熔断的Server
    PredicateBasedRule基于断言器实现的规则本类为抽象类，具体过滤规则交给子类
    AvailabilityFilteringRule过滤掉已熔断or活跃请求数太高的Server后，剩下的执行线性轮询依赖于AvailabilityPredicate这个断言器实现过滤
    ZoneAvoidanceRule复合判断。先选出可用区，然后在按上规则筛选出复合条件的Server们，执行线性轮询使用ZoneAvoidancePredicate和AvailabilityPredicate两个主断言器实现过滤
    RandomRule随机选择一个server在index上随机，选择index对应位置的server
    RetryRule对任何IRule包一层重试机制在一个配置时间段内当选择server不成功，则一直尝试使用subRule的方式选择一个可用的server

    我们可以通过修改配置来调整Ribbon的负载均衡策略，具体代码如下

    1. service-product: # 调用的提供者的名称
    2. 	ribbon:
    3. 		NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

     第三种方式：基于Feign实现服务调用

    什么是Feign

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

     Feign的使用

    加入Fegin的依赖

    1.  
    2.    
    3.      <dependency>
    4.          <groupId>org.springframework.cloudgroupId>
    5.          <artifactId>spring-cloud-starter-openfeignartifactId>
    6. dependency>

    在主类上添加Fegin的注解 

    创建一个service， 并使用Fegin实现微服务调用

    1. package com.oyang.shoporder.service;
    2.  
    3. import com.oyang.model.Product;
    4.         import org.springframework.cloud.openfeign.FeignClient;
    5.         import org.springframework.web.bind.annotation.GetMapping;
    6.         import org.springframework.web.bind.annotation.PathVariable;
    7.  
    8. /**
    9.  * @author oyang
    10.  * @site https://blog.csdn.net
    11.  * @qq 1828190940
    12.  *
    13.  * 帮助消费者 shop-order 调用生产者 shop-product
    14.  */
    15. @FeignClient("shop-product")//声明调用的提供者的name
    16. public interface ProductService {//接口定义，完全遵循restful接口规范 controller怎么写，这里怎么写
    17.     //注意，要记得加上controller上的载化路径
    18.     
    19.     @GetMapping("/product/get/{pid}")
    20.     Product findByPid(@PathVariable("pid") Integer pid);
    21. }

     修改controller代码，并启动验证

    1. package com.oyang.shoporder.controller;
    2.  
    3. import com.oyang.model.Order;
    4. import com.oyang.model.Product;
    5. import com.oyang.model.User;
    6. import com.oyang.shoporder.service.ProductService;
    7. import org.apache.http.HttpRequest;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.cloud.client.discovery.DiscoveryClient;
    10. import org.springframework.web.bind.annotation.PathVariable;
    11. import org.springframework.web.bind.annotation.RequestMapping;
    12. import org.springframework.web.bind.annotation.RestController;
    13. import org.springframework.web.client.RestTemplate;
    14.  
    15. /**
    16.  * @author oyang
    17.  * @site https://blog.csdn.net
    18.  * @qq 1828190940
    19.  * @create  2022-11-24 16:07
    20.  */
    21. @RestController
    22. @RequestMapping("/order")
    23. public class OrderController {
    24.  
    25.     @Autowired
    26.     private RestTemplate restTemplate;
    27.     @Autowired
    28.     public ProductService productService;
    29.  
    30.     @RequestMapping("/get/{uid}/{pid}")
    31.     public Order get(@PathVariable("uid") Integer uid, @PathVariable("pid") Integer pid){
    32.         String url = "shop-product";
    33.         String url2 ="shop-user";
    34.  
    35.         /**
    36.          * 要在订单微服务中调用 用户微服务、商品微服务--也就意味着跨项目调用
    37.          * httpClients
    38.          */
    39.         //得到用户对象
    40.         User user = restTemplate.getForObject("http://"+url2+"/user/get/" + uid, User.class);
    41.         //得到商品对象
    42. //        Product product = restTemplate.getForObject("http://"+url+"/product/get/" + pid, Product.class);
    43.         //通过restTemplate调用商品微服务
    44.         Product product = productService.findByPid(pid);
    45.         Order order = new Order();
    46.         order.setUsername(user.getUsername());
    47.         order.setUid(user.getUid());
    48.         order.setPprice(product.getPprice());
    49.         order.setPname(product.getPname());
    50.         order.setPid(product.getPid());
    51.         order.setOid(System.currentTimeMillis());//随机生成id
    52.         order.setNumber(product.getStock());
    53.         return order;
    54.     }
    55. }

    重启order微服务,查看效果  

    1. FeignClient接口，不能使用@GettingMapping之类的组合注解
    2.  
    3. FeignClient接口中，如果使用到@PathVariable必须指定其value
    4.  
    5. 只要参数是复杂对象，即使指定了是GET方法，feign依然会以POST方法进行发送请求，同时生产者必须支持POST请求并给参数添加@RequestBody注解 建议使用公共vo+@RequestBody方式
    6.  
    7. springcloud中feign访问其他服务并传参数出现错误的问题：status 405 reading LogisticsOrderService#getLogistics(Integer,String,Integer,Integer) 当使用feign传参数的时候,需要加上@RequestParam注解,否则对方服务无法识别参数; @GetMapping("/order/getLogistics") public ResponseObj getLogistics( @RequestParam(value = "logisticsType") Integer logisticsType, @RequestParam(value="token") String token, @RequestParam(value = "currentPage", defaultValue = "1") Integer currentPage, @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize);

    测试负载均衡

     

     Feign传参

    在使用Feign用作服务注册时作为后台需要注意一下几点

    1. 基本数据类型参数需要带上@PathVariable("uid")注解
    2. 对象参数需要加上@RequestBody注释
    1. package com.oyang.shopproduct.controller;
    2.  
    3. import com.oyang.model.Product;
    4. import lombok.extern.slf4j.Slf4j;
    5. import org.springframework.web.bind.annotation.*;
    6.  
    7. @Slf4j
    8. @RestController
    9. @RequestMapping("/feignServer")
    10. public class FeignServerController {
    11.     @RequestMapping("/findByParameter")
    12.     public String findByParameter(String name,Double price){
    13.         log.info("服务提供者日志:{}",name);
    14.         return "hello:"+name;
    15.     }
    16.     @RequestMapping("/findByParameter2")
    17.     public String findByParameter2(
    18.             @RequestParam("name") String name,
    19.             @RequestParam("price") Double price){
    20.         log.info("服务提供者日志:{},{}",name,price);
    21.         return "hello:"+name+price;
    22.     }
    23.     @RequestMapping("/findByPathVariable")
    24.     public String findByPathVariable(@PathVariable String name){
    25.         log.info("服务提供者日志:{}",name);
    26.         return "hello:"+name;
    27.     }
    28.     @RequestMapping("/findByRequestBody")
    29.     public Product findByRequestBody(@RequestBody Product product){
    30.         log.info("服务提供者日志:{}",product.getPname());
    31.         return product;
    32.     }
    33. }

  • 相关阅读:
    打印 Logger 日志时，需不需要再封装一下工具类？
    Ubuntu18.04安装 ROS Melodic教程
    如何看待 30 岁学云计算，转行做云计算运维这件事？
    重塑感知，荣耀金洋！金洋奖两项用户体验奖项公布
    《QT从基础到进阶·二十八》QProcess使用，从一个exe程序启动另一个exe程序
    nodejs+vue+elementui餐厅点餐系统
    win11系统前端IIS部署发布网站步骤
    k8s-10 cni 网络
    一次企业网丢包故障定位过程
    数据结构-双向链表
  • 原文地址：https://blog.csdn.net/weixin_65211978/article/details/128084815