Spring Cloud实现微服务调用的负载均衡(详解)

 更新时间:2024年03月05日 09:55:12   作者:阿Q说代码  
负载均衡就是将负载(工作任务,访问请求)进行分摊到多个操作单元(服务器,组件)上进行执行,根据负载均衡发生位置的不同,一般分为服务端负载均衡和客户端负载均衡,本文给大家介绍Spring Cloud实现微服务调用的负载均衡的相关知识,感兴趣的朋友一起看看吧

什么是负载均衡

通俗的讲,负载均衡就是将负载(工作任务,访问请求)进行分摊到多个操作单元(服务器,组件)上进行执行。

根据负载均衡发生位置的不同,一般分为服务端负载均衡客户端负载均衡

  • 服务端负载均衡指的是发生在服务提供者一方,比如常见的 nginx 负载均衡。
  • 客户端负载均衡指的是发生在服务请求的一方,也就是在发送请求之前已经选好了由哪个实例处理请求。

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

自定义实现负载均衡

启动shop-product微服务

在启动 shop-product 微服务的基础上,通过idea再启动一个 shop-product 微服务,设置其端口为8082。

命令为-Dserver.port=8082

通过nacos查看微服务的启动情况

自定义实现负载均衡

修改 shop-order 的代码

public ShopOrder order(@PathVariable("pid") Long pid) {
        log.info("客户下单,这时候要调用商品微服务查询商品信息。。。");
        //从nacos中获取服务地址
        List<ServiceInstance> instances = discoveryClient.getInstances("shop-product");
        //自定义规则实现随机挑选服务
        int index = new Random().nextInt(instances.size());
        ServiceInstance serviceInstance = instances.get(index);
        String url = serviceInstance.getHost()+":"+serviceInstance.getPort();
        log.info(">>从nacos中获取到的微服务地址为:"+ url);
        //通过restTemplate调用商品微服务
        ShopProduct shopProduct = restTemplate.getForObject("http://"+url+"/product/"+pid, ShopProduct.class);
        log.info("当前用户信息为自己,假设我们设置为1");
        ShopOrder shopOrder = new ShopOrder();
        shopOrder.setUid(1L);
        shopOrder.setUsername("公众号:阿Q说代码");
        shopOrder.setPid(shopProduct.getId());
        shopOrder.setPname(shopProduct.getPname());
        orderService.save(shopOrder);
        //商品扣减库存的逻辑
        ProductReduceDTO productReduceDTO = new ProductReduceDTO();
        productReduceDTO.setProductId(pid);
        productReduceDTO.setReductCount(1);
        Integer count = restTemplate.postForObject("http://"+url+"/product/reduceStock", productReduceDTO, Integer.class);
        return shopOrder;
    }

启动两个服务提供者和一个服务消费者,多访问几次消费者,测试效果:

基于Ribbon实现负载均衡

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

添加注解

在 RestTemplate 的生成方法上添加@LoadBalanced注解

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

修改服务调用的方法

将上一步中的代码注释掉,改为直接使用微服务名字,从nacos中获取服务地址

//从nacos中获取服务地址
//自定义规则实现随机挑选服务
//List<ServiceInstance> instances = discoveryClient.getInstances("shop-product");
//int index = new Random().nextInt(instances.size());
//ServiceInstance serviceInstance = instances.get(index);
//String url = serviceInstance.getHost()+":"+serviceInstance.getPort();
//直接使用微服务名字,从nacos中获取服务地址
String url="shop-product";

重启服务进行测试,微服务调用成功。

Ribbon支持的负载均衡策略

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

通过修改配置来调整 Ribbon 的负载均衡策略

# 负载均衡规则
shop-product:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

通过注入Bean来调整 Ribbon 的负载均衡策略

 @Bean
 public IRule randomRule(){
     return new RandomRule();
 }

饥饿加载

为何要开启饥饿加载,因为在我们第一次加载时候,响应时间比较慢,原因是第一次加服务需要从服务注册列表中拉取服务实例,以及初始化相关的组件到 Spring 中。

开启饥饿加载的相关配置之后这些操作会在服务启动就会完成。

ribbon:
  eager-load:
    clients:
      - shop-product

总结

到这儿,我们微服务调用的负载均衡实现就结束了。下一篇将为大家带来基于feign实现微服务调用的文章,敬请期待吧!

后续的文章,我们将继续完善我们的微服务系统,集成更多的Alibaba组件。想要了解更多JAVA后端知识,请点击文末名片与我交流吧。留下您的一键三连,让我们在这个寒冷的东西互相温暖吧!

到此这篇关于Spring Cloud实现微服务调用的负载均衡的文章就介绍到这了,更多相关Spring Cloud微服务调用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 一文搞清楚Java中Comparable和Comparator的区别

    一文搞清楚Java中Comparable和Comparator的区别

    Java中的Comparable和Comparator都是用于集合排序的接口,但它们有明显的区别,文中通过一些实例代码详细介绍了Java中Comparable和Comparator的区别,感兴趣的同学跟着小编一起学习吧
    2023-05-05
  • springboot服务正常启动之后,访问服务url无响应问题及解决

    springboot服务正常启动之后,访问服务url无响应问题及解决

    这篇文章主要介绍了springboot服务正常启动之后,访问服务url无响应问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • 怎样使用PowerMockito 测试静态方法

    怎样使用PowerMockito 测试静态方法

    这篇文章主要介绍了使用PowerMockito 测试静态的方法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-07-07
  • SpringBoot整合SQLite数据库全过程

    SpringBoot整合SQLite数据库全过程

    sqlite是一个很轻量级的数据库,可以满足日常sql的需求,下面这篇文章主要给大家介绍了关于SpringBoot整合SQLite数据库的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2023-03-03
  • Java获取最后插入MySQL记录的自增ID值的3种方法

    Java获取最后插入MySQL记录的自增ID值的3种方法

    这篇文章介绍了Java获取最后插入MySQL记录的自增ID值的3种方法,有需要的朋友可以参考需要
    2013-08-08
  • Java怎样创建集合才能避免造成内存泄漏你了解吗

    Java怎样创建集合才能避免造成内存泄漏你了解吗

    内存泄漏是指无用对象持续占有内存或无用对象的内存得不到及时释放,从而造成内存空间的浪费称为内存泄漏。长生命周期的对象持有短生命周期对象的引用就很可能发生内存泄漏,尽管短生命周期对象已经不再需要,但是因为长生命周期持有它的引用而导致不能被回收
    2021-09-09
  • Java利用apache ftp工具实现文件上传下载和删除功能

    Java利用apache ftp工具实现文件上传下载和删除功能

    这篇文章主要为大家详细介绍了Java利用apache ftp工具实现文件上传下载、删除功能,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-06-06
  • Java多线程 生产者消费者模型实例详解

    Java多线程 生产者消费者模型实例详解

    这篇文章主要介绍了Java多线程 生产者消费者模型实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Hibernate之环境搭建及demo分享

    Hibernate之环境搭建及demo分享

    下面小编就为大家分享一篇Hibernate之环境搭建及demo,具有很好的参考价值,希望对大家有所帮助
    2017-11-11
  • Java实现将数组的元素用逗号连接的多种方法

    Java实现将数组的元素用逗号连接的多种方法

    在 Java 开发中,我们经常需要将数组中的元素用逗号连接成一个字符串,这种需求在日志记录、数据导出、API 响应等场景中非常常见,本文将详细介绍如何在 Java 中实现这一功能,并提供多种简洁的方法和优化建议,需要的朋友可以参考下
    2025-01-01

最新评论